/unit/src/perl/ |
H A D | nxt_perl_psgi_layer.c | 141 if (f == NULL) { in nxt_perl_psgi_layer_stream_open() 145 f = PerlIO_push(aTHX_ f, self, mode, arg); in nxt_perl_psgi_layer_stream_open() 151 return f; in nxt_perl_psgi_layer_stream_open() 173 PERL_UNUSED_ARG(f); in nxt_perl_psgi_layer_stream_fileno() 184 if (f == NULL) { in nxt_perl_psgi_layer_stream_read() 224 PERL_UNUSED_ARG(f); in nxt_perl_psgi_layer_stream_seek() 232 PERL_UNUSED_ARG(f); in nxt_perl_psgi_layer_stream_tell() 240 PERL_UNUSED_ARG(f); in nxt_perl_psgi_layer_stream_fill() 282 f = PerlIOBase_dup(aTHX_ f, o, param, flags); in nxt_perl_psgi_layer_stream_dup() 284 if (f != NULL) { in nxt_perl_psgi_layer_stream_dup() [all …]
|
/unit/test/ |
H A D | test_static_mount.py | 15 os.makedirs(f'{temp_dir}/assets/dir/mount') 16 os.makedirs(f'{temp_dir}/assets/dir/dir') 17 os.makedirs(f'{temp_dir}/assets/mount') 18 Path(f'{temp_dir}/assets/index.html').write_text('index') 27 f'{temp_dir}/assets/mount', 28 f'{temp_dir}/assets/dir/mount', 88 os.symlink(f'{temp_dir}/assets/dir', f'{temp_dir}/assets/link') 119 "share": f'{temp_dir}/assets/dir$uri', 120 "chroot": f'{temp_dir}/assets', 129 "share": f'{temp_dir}/assets/dir$uri', [all …]
|
H A D | test_static_chroot.py | 15 os.makedirs(f'{temp_dir}/assets/dir') 17 Path(f'{temp_dir}/assets/dir/file').write_text('blah') 19 client.test_path = f'/{os.path.relpath(Path(__file__))}' 55 f'{temp_dir}/assets/dir', ["/blah", f'{temp_dir}/assets$uri'] 60 f'{temp_dir}/assets/$host', 61 ['/blah', f'{temp_dir}/assets$uri'], 66 f'{temp_dir}/assets/dir', ['/blah', '/blah2'] 74 os.chmod(f'{temp_dir}/assets/dir', 0o100) 77 f'{temp_dir}/assets/dir' 115 f'{temp_dir}/assets/dir/$host', [all …]
|
H A D | test_static_variables.py | 12 os.makedirs(f'{temp_dir}/assets/dir') 13 os.makedirs(f'{temp_dir}/assets/d$r') 14 Path(f'{temp_dir}/assets/index.html').write_text('0123456789') 15 Path(f'{temp_dir}/assets/dir/file').write_text('file') 16 Path(f'{temp_dir}/assets/d$r/file').write_text('d$r') 30 return client.conf(f'"{share}"', 'routes/0/action/share') 40 assert 'success' in update_share(f'{temp_dir}/assets${{uri}}') 53 "share": [f'{temp_dir}/assets$uri', '$uri'], 79 assert 'error' in update_share(f'{temp_dir}/assets/d$r$uri') 80 assert 'error' in update_share(f'{temp_dir}/assets/$$uri') [all …]
|
H A D | test_static_types.py | 11 Path(f'{temp_dir}/assets').mkdir() 13 Path(f'{temp_dir}/assets/file{ext}').write_text(ext) 15 Path(f'{temp_dir}/assets/index.html').write_text('index') 23 "routes": [{"action": {"share": f'{temp_dir}/assets$uri'}}], 40 action_update({"share": f'{temp_dir}/assets$uri'}) 45 {"share": f'{temp_dir}/assets$uri', "types": "application/xml"} 54 action_update({"share": f'{temp_dir}/assets$uri', "types": [""]}) 60 {"share": f'{temp_dir}/assets$uri', "types": ["application/*"]} 80 "share": f'{temp_dir}/assets$uri', 92 "share": f'{temp_dir}/assets$uri', [all …]
|
H A D | test_static.py | 15 assets_dir = f'{temp_dir}/assets' 18 f'{assets_dir}/README', 'w' 20 f'{assets_dir}/dir/file', 'w' 89 with open(f'{temp_dir}/assets/large', 'wb') as f: 90 f.seek(file_size - 1) 91 f.write(b'\0') 106 with open(f'{temp_dir}/assets/index.html', 'w') as f: 107 f.write('blah') 123 f'{assets_dir}/dir/file', 129 os.rename(f'{assets_dir}/dir', f'{assets_dir}/di r') [all …]
|
H A D | test_static_symlink.py | 14 os.makedirs(f'{temp_dir}/assets/dir/dir') 15 Path(f'{temp_dir}/assets/index.html').write_text('0123456789') 16 Path(f'{temp_dir}/assets/dir/file').write_text('blah') 21 "routes": [{"action": {"share": f'{temp_dir}/assets$uri'}}], 29 os.symlink(f'{temp_dir}/assets/dir', f'{temp_dir}/assets/link') 54 os.symlink(f'{temp_dir}/assets/dir', f'{temp_dir}/assets/link') 61 "share": f'{temp_dir}/assets$uri', 68 "share": f'{temp_dir}/assets$uri', 83 os.symlink(f'{temp_dir}/assets/dir/file', f'{temp_dir}/assets/dir/dir/link') 89 "share": f'{temp_dir}/assets$uri', [all …]
|
H A D | test_tls.py | 56 with open(f'{option.temp_dir}/ca.conf', 'w') as f: 57 f.write( 58 f"""[ ca ] 78 with open(f'{option.temp_dir}/certserial', 'w') as f: 79 f.write('1000') 81 with open(f'{option.temp_dir}/certindex', 'w') as f: 82 f.write('') 84 with open(f'{option.temp_dir}/certindex.attr', 'w') as f: 85 f.write('') 90 {"pass": f"applications/{application}"}, f'listeners/*:{port}' [all …]
|
H A D | test_tls_sni.py | 63 f'{option.temp_dir}/{b}.csr', 65 f'{option.temp_dir}/{b}.key', 83 f'{option.temp_dir}/ca.conf', 89 f'{option.temp_dir}/{b}.csr', 107 with open(f'{option.temp_dir}/ca.conf', 'w') as f: 108 f.write( 109 f"""[ ca ] 129 with open(f'{option.temp_dir}/certserial', 'w') as f: 130 f.write('1000') 132 with open(f'{option.temp_dir}/certindex', 'w') as f: [all …]
|
H A D | test_static_share.py | 12 os.makedirs(f'{temp_dir}/assets/dir') 13 os.makedirs(f'{temp_dir}/assets/dir2') 15 Path(f'{temp_dir}/assets/dir/file').write_text('1') 16 Path(f'{temp_dir}/assets/dir2/file2').write_text('2') 21 "routes": [{"action": {"share": f'{temp_dir}/assets$uri'}}], 35 action_update({"share": [f'{temp_dir}/assets/dir$uri']}) 43 f'{temp_dir}/assets/dir$uri', 44 f'{temp_dir}/assets/dir2$uri', 55 f'{temp_dir}/assets/dir2$uri', 56 f'{temp_dir}/assets/dir3$uri',
|
H A D | test_njs.py | 18 "routes": [{"action": {"share": f"{temp_dir}/assets$uri"}}], 24 assets_dir = f'{option.temp_dir}/assets/' 27 [open(assets_dir + f, 'a') for f in files] 28 waitforfiles(*[assets_dir + f for f in files]) 36 set_share(f'"`{option.temp_dir}/assets{expression}`"') 47 set_share(f'"{temp_dir}/assets/`string`"') 74 set_share(f'"`{temp_dir}/assets/${{cookies.foo}}`"') 82 set_share(f'"`{temp_dir}/assets/${{args.foo}}`"')
|
H A D | test_python_targets.py | 10 python_dir = f'{option.test_dir}/python' 28 "working_directory": f'{python_dir}/targets/', 29 "path": f'{python_dir}/targets/', 55 python_dir = f'{option.test_dir}/python' 73 "working_directory": f'{python_dir}/targets/', 74 "path": f'{python_dir}/targets/',
|
H A D | test_static_fallback.py | 12 assets_dir = f'{temp_dir}/assets' 13 os.makedirs(f'{assets_dir}/dir') 14 Path(f'{assets_dir}/index.html').write_text('0123456789') 16 os.makedirs(f'{assets_dir}/403') 17 os.chmod(f'{assets_dir}/403', 0o000) 25 "routes": [{"action": {"share": f'{assets_dir}$uri'}}], 33 os.chmod(f'{assets_dir}/403', 0o777) 55 {"share": f"{temp_dir}/assets$uri", "fallback": {"return": 200}} 92 "fallback": {"share": f"{temp_dir}/assets$uri"},
|
/unit/test/unit/applications/lang/ |
H A D | java.py | 16 app_path = f'{option.temp_dir}/java' 17 web_inf_path = f'{app_path}/WEB-INF/' 18 classes_path = f'{web_inf_path}classes/' 26 for f in os.listdir(script_path): 27 file_path = f'{script_path}{f}' 29 if f.endswith('.java'): 33 if f.startswith('.') or f == 'Makefile': 37 if f == 'WEB-INF': 43 if f == 'web.xml': 78 f'{classpath}:{ws_jars[0]}', [all …]
|
H A D | go.py | 17 temp_dir = f'{option.temp_dir}/go/' 22 cache_dir = f'{option.cache_dir}/go-build' 42 f'{temp_dir}{name}', 43 f'{temp_dir}{name}.go', 50 f'{temp_dir}{name}', 51 f'{temp_dir}{name}.go', 56 with open(f'{temp_dir}go.mod', 'w') as f: 57 f.write( 58 f"""module test/app 83 wdir = f'{option.test_dir}/go/{script}' [all …]
|
H A D | node.py | 17 f'{option.test_dir}/node/{script}', f'{option.temp_dir}/node' 22 f'{option.current_dir}/node/node_modules', 23 f'{option.temp_dir}/node/node_modules', 26 public_dir(f'{option.temp_dir}/node') 47 "*:8080": {"pass": f"applications/{quote(script, '')}"} 53 "working_directory": f'{option.temp_dir}/node',
|
H A D | php.py | 13 script_path = f'{option.test_dir}/php/{script}' 18 if not os.path.exists(f'{rootfs}/app/php/'): 19 os.makedirs(f'{rootfs}/app/php/') 21 if not os.path.exists(f'{rootfs}/app/php/{script}'): 22 shutil.copytree(script_path, f'{rootfs}/app/php/{script}') 24 script_path = f'/app/php/{script}' 45 "listeners": {"*:8080": {"pass": f"applications/{script}"}},
|
H A D | ruby.py | 14 f'{option.test_dir}/ruby/{script}', 15 f'{option.temp_dir}/ruby/{script}', 18 public_dir(f'{option.temp_dir}/ruby/{script}') 23 script_path = f'{option.temp_dir}/ruby/{script}' 29 "script": f'{script_path}/{name}', 40 "listeners": {"*:8080": {"pass": f"applications/{script}"}},
|
/unit/test/unit/check/ |
H A D | isolation.py | 29 "working_directory": f"{option.test_dir}/go/empty", 30 "executable": f"{option.test_dir}/go/app", 43 "path": f"{option.test_dir}/python/empty", 58 "root": f"{option.test_dir}/php/phpinfo", 76 "script": f"{option.temp_dir}/ruby/empty/config.ru", 89 "unit_jars": f"{option.current_dir}/build", 93 "webapp": f"{option.temp_dir}/java", 108 "working_directory": f"{option.temp_dir}/node", 135 addr=f'{option.temp_dir}/control.unit.sock', 150 with open(unp_clone_path, 'r') as f: [all …]
|
/unit/pkg/docker/ |
H A D | docker-entrypoint.sh | 47 for f in $(/usr/bin/find /docker-entrypoint.d/ -type f -name "*.pem"); do 49 curl_put $f "certificates/$(basename $f .pem)" 53 for f in $(/usr/bin/find /docker-entrypoint.d/ -type f -name "*.js"); do 55 curl_put $f "js_modules/$(basename $f .js)" 59 for f in $(/usr/bin/find /docker-entrypoint.d/ -type f -name "*.json"); do 60 echo "$0: Applying configuration $f"; 61 curl_put $f "config" 65 for f in $(/usr/bin/find /docker-entrypoint.d/ -type f -name "*.sh"); do 66 echo "$0: Launching $f"; 67 "$f" [all …]
|
/unit/test/unit/applications/ |
H A D | tls.py | 25 f'/CN={name}/', 27 f'{option.temp_dir}/openssl.conf', 29 f'{option.temp_dir}/{name}.crt', 31 f'{option.temp_dir}/{name}.key', 43 key_path = f'{option.temp_dir}/{key}.key' 44 crt_path = f'{option.temp_dir}/{crt}.crt' 70 a_names += f'IP.{i} = {k[1]}\n' 72 a_names += f'DNS.{i} = {k[0]}\n' 82 with open(conf_path, 'w') as f: 83 f.write( [all …]
|
/unit/src/java/ |
H A D | nxt_jni_HeaderNamesEnumeration.c | 91 nxt_unit_field_t *f; in nxt_java_HeaderNamesEnumeration_nextElementPos() local 93 f = nxt_jlong2ptr(headers_ptr); in nxt_java_HeaderNamesEnumeration_nextElementPos() 101 && f[pos].hash == f[pos - 1].hash in nxt_java_HeaderNamesEnumeration_nextElementPos() 102 && f[pos].name_length == f[pos - 1].name_length) in nxt_java_HeaderNamesEnumeration_nextElementPos() 118 nxt_unit_field_t *f; in nxt_java_HeaderNamesEnumeration_nextElement() local 120 f = nxt_jlong2ptr(headers_ptr); in nxt_java_HeaderNamesEnumeration_nextElement() 124 && f[pos].hash == f[pos - 1].hash in nxt_java_HeaderNamesEnumeration_nextElement() 125 && f[pos].name_length == f[pos - 1].name_length) in nxt_java_HeaderNamesEnumeration_nextElement() 137 f += pos; in nxt_java_HeaderNamesEnumeration_nextElement() 140 tmp = name[f->name_length]; in nxt_java_HeaderNamesEnumeration_nextElement() [all …]
|
H A D | nxt_jni_HeadersEnumeration.c | 91 nxt_unit_field_t *f, *init_field; in nxt_java_HeadersEnumeration_nextElementPos() local 93 f = nxt_jlong2ptr(headers_ptr); in nxt_java_HeadersEnumeration_nextElementPos() 95 init_field = f + ipos; in nxt_java_HeadersEnumeration_nextElementPos() 101 f += pos; in nxt_java_HeadersEnumeration_nextElementPos() 103 if (f->hash != init_field->hash in nxt_java_HeadersEnumeration_nextElementPos() 124 nxt_unit_field_t *f, *init_field; in nxt_java_HeadersEnumeration_nextElement() local 126 f = nxt_jlong2ptr(headers_ptr); in nxt_java_HeadersEnumeration_nextElement() 128 init_field = f + ipos; in nxt_java_HeadersEnumeration_nextElement() 136 f += pos; in nxt_java_HeadersEnumeration_nextElement() 138 if (f->hash != init_field->hash in nxt_java_HeadersEnumeration_nextElement() [all …]
|
/unit/src/ |
H A D | nxt_http_set_headers.c | 74 nxt_http_field_t *f; in nxt_http_resp_header_find() local 76 nxt_list_each(f, r->resp.fields) { in nxt_http_resp_header_find() 78 if (f->skip) { in nxt_http_resp_header_find() 82 if (length == f->name_length in nxt_http_resp_header_find() 83 && nxt_memcasecmp(name, f->name, f->name_length) == 0) in nxt_http_resp_header_find() 85 return f; in nxt_http_resp_header_find() 100 nxt_http_field_t *f; in nxt_http_set_headers() local 157 if (f == NULL) { in nxt_http_set_headers() 167 f->value = value[i].start; in nxt_http_set_headers() 170 } else if (f != NULL) { in nxt_http_set_headers() [all …]
|
/unit/test/python/lifespan/empty/ |
H A D | asgi.py | 6 with open(f'{prefix}version', 'w+') as f: 7 f.write( 8 f"{scope['asgi']['version']} {scope['asgi']['spec_version']}" 13 os.remove(f'{prefix}startup') 16 os.remove(f'{prefix}shutdown')
|