/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/unit/applications/lang/ |
H A D | java.py | 15 app_path = f'{option.temp_dir}/java' 16 web_inf_path = f'{app_path}/WEB-INF/' 17 classes_path = f'{web_inf_path}classes/' 25 for f in os.listdir(script_path): 26 file_path = f'{script_path}{f}' 28 if f.endswith('.java'): 32 if f.startswith('.') or f == 'Makefile': 36 if f == 'WEB-INF': 42 if f == 'web.xml': 77 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 | 16 f'{option.test_dir}/node/{script}', f'{option.temp_dir}/node' 21 f'{option.current_dir}/node/node_modules', 22 f'{option.temp_dir}/node/node_modules', 25 public_dir(f'{option.temp_dir}/node') 46 "*:7080": {"pass": f"applications/{quote(script, '')}"} 52 "working_directory": f'{option.temp_dir}/node',
|
H A D | php.py | 12 script_path = f'{option.test_dir}/php/{script}' 17 if not os.path.exists(f'{rootfs}/app/php/'): 18 os.makedirs(f'{rootfs}/app/php/') 20 if not os.path.exists(f'{rootfs}/app/php/{script}'): 21 shutil.copytree(script_path, f'{rootfs}/app/php/{script}') 23 script_path = f'/app/php/{script}' 44 "listeners": {"*:7080": {"pass": f"applications/{script}"}},
|
H A D | ruby.py | 13 f'{option.test_dir}/ruby/{script}', 14 f'{option.temp_dir}/ruby/{script}', 17 public_dir(f'{option.temp_dir}/ruby/{script}') 22 script_path = f'{option.temp_dir}/ruby/{script}' 28 "script": f'{script_path}/{name}', 39 "listeners": {"*:7080": {"pass": f"applications/{script}"}},
|
H A D | python.py | 23 script_path = f'{option.test_dir}/python/{script}' 28 if not os.path.exists(f'{rootfs}/app/python/'): 29 os.makedirs(f'{rootfs}/app/python/') 31 if not os.path.exists(f'{rootfs}/app/python/{name}'): 32 shutil.copytree(script_path, f'{rootfs}/app/python/{name}') 34 script_path = f'/app/python/{name}' 61 "*:7080": {"pass": f"applications/{quote(name, '')}"}
|
/unit/test/ |
H A D | test_static_mount.py | 17 os.makedirs(f'{temp_dir}/assets/dir/mount') 18 os.makedirs(f'{temp_dir}/assets/dir/dir') 19 os.makedirs(f'{temp_dir}/assets/mount') 20 Path(f'{temp_dir}/assets/index.html').write_text('index') 29 f'{temp_dir}/assets/mount', 30 f'{temp_dir}/assets/dir/mount', 88 os.symlink(f'{temp_dir}/assets/dir', f'{temp_dir}/assets/link') 118 "share": f'{temp_dir}/assets/dir$uri', 119 "chroot": f'{temp_dir}/assets', 128 "share": f'{temp_dir}/assets/dir$uri', [all …]
|
H A D | test_static_variables.py | 13 os.makedirs(f'{temp_dir}/assets/dir') 14 os.makedirs(f'{temp_dir}/assets/d$r') 15 Path(f'{temp_dir}/assets/index.html').write_text('0123456789') 16 Path(f'{temp_dir}/assets/dir/file').write_text('file') 17 Path(f'{temp_dir}/assets/d$r/file').write_text('d$r') 22 "routes": [{"action": {"share": f'{temp_dir}/assets$uri'}}], 30 return self.conf(f'"{share}"', 'routes/0/action/share') 44 [f'{temp_dir}/assets$uri', '$uri'] 53 "share": [f'{temp_dir}/assets$uri', '$uri'], 76 assert 'error' in self.update_share(f'{temp_dir}/assets/$$uri') [all …]
|
H A D | test_static_chroot.py | 14 os.makedirs(f'{temp_dir}/assets/dir') 16 Path(f'{temp_dir}/assets/dir/file').write_text('blah') 18 self.test_path = f'/{os.path.relpath(Path(__file__))}' 50 f'{temp_dir}/assets/dir', ["/blah", f'{temp_dir}/assets$uri'] 55 f'{temp_dir}/assets/$host', 56 ['/blah', f'{temp_dir}/assets$uri'], 61 f'{temp_dir}/assets/dir', ['/blah', '/blah2'] 69 os.chmod(f'{temp_dir}/assets/dir', 0o100) 72 f'{temp_dir}/assets/dir' 107 f'{temp_dir}/assets/dir/$host', [all …]
|
H A D | test_static_symlink.py | 13 os.makedirs(f'{temp_dir}/assets/dir/dir') 14 Path(f'{temp_dir}/assets/index.html').write_text('0123456789') 15 Path(f'{temp_dir}/assets/dir/file').write_text('blah') 20 "routes": [{"action": {"share": f'{temp_dir}/assets$uri'}}], 27 os.symlink(f'{temp_dir}/assets/dir', f'{temp_dir}/assets/link') 51 os.symlink(f'{temp_dir}/assets/dir', f'{temp_dir}/assets/link') 58 "share": f'{temp_dir}/assets$uri', 65 "share": f'{temp_dir}/assets$uri', 80 f'{temp_dir}/assets/dir/file', f'{temp_dir}/assets/dir/dir/link' 87 "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' 87 with open(f'{temp_dir}/assets/large', 'wb') as f: 88 f.seek(file_size - 1) 89 f.write(b'\0') 103 with open(f'{temp_dir}/assets/index.html', 'w') as f: 104 f.write('blah') 118 f'{assets_dir}/dir/file', 124 os.rename(f'{assets_dir}/dir', f'{assets_dir}/di r') [all …]
|
H A D | test_static_types.py | 12 Path(f'{temp_dir}/assets').mkdir() 14 Path(f'{temp_dir}/assets/file{ext}').write_text(ext) 16 Path(f'{temp_dir}/assets/index.html').write_text('index') 24 "routes": [{"action": {"share": f'{temp_dir}/assets$uri'}}], 38 self.action_update({"share": f'{temp_dir}/assets$uri'}) 63 {"share": f'{temp_dir}/assets$uri', "types": ["video/*"]} 78 "share": f'{temp_dir}/assets$uri', 89 "share": f'{temp_dir}/assets$uri', 107 {"share": f'{temp_dir}/assets$uri', "types": ["vIdEo/mp4"]} 115 {"share": f'{temp_dir}/assets$uri', "types": ["vIdEo/*"]} [all …]
|
H A D | test_tls_sni.py | 32 with open(f'{option.temp_dir}/ca.conf', 'w') as f: 33 f.write( 34 f"""[ ca ] 54 with open(f'{option.temp_dir}/certserial', 'w') as f: 55 f.write('1000') 57 with open(f'{option.temp_dir}/certindex', 'w') as f: 58 f.write('') 77 f'{option.temp_dir}/{b}.csr', 79 f'{option.temp_dir}/{b}.key', 97 f'{option.temp_dir}/ca.conf', [all …]
|
H A D | test_tls.py | 25 {"pass": f"applications/{application}"}, f'listeners/*:{port}' 49 with open(f'{option.temp_dir}/ca.conf', 'w') as f: 50 f.write( 51 f"""[ ca ] 71 with open(f'{option.temp_dir}/certserial', 'w') as f: 72 f.write('1000') 74 with open(f'{option.temp_dir}/certindex', 'w') as f: 75 f.write('') 77 with open(f'{option.temp_dir}/certindex.attr', 'w') as f: 78 f.write('') [all …]
|
H A D | test_static_share.py | 13 os.makedirs(f'{temp_dir}/assets/dir') 14 os.makedirs(f'{temp_dir}/assets/dir2') 16 Path(f'{temp_dir}/assets/dir/file').write_text('1') 17 Path(f'{temp_dir}/assets/dir2/file2').write_text('2') 22 "routes": [{"action": {"share": f'{temp_dir}/assets$uri'}}], 34 self.action_update({"share": [f'{temp_dir}/assets/dir$uri']}) 42 f'{temp_dir}/assets/dir$uri', 43 f'{temp_dir}/assets/dir2$uri', 54 f'{temp_dir}/assets/dir2$uri', 55 f'{temp_dir}/assets/dir3$uri',
|
H A D | test_njs.py | 18 {"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]) 34 self.set_share(f'"`{option.temp_dir}/assets{expression}`"') 44 self.set_share(f'"{temp_dir}/assets/`string`"') 68 self.set_share(f'"`{temp_dir}/assets/${{cookies.foo}}`"') 76 self.set_share(f'"`{temp_dir}/assets/${{args.foo}}`"')
|
H A D | test_python_targets.py | 9 python_dir = f'{option.test_dir}/python' 27 "working_directory": f'{python_dir}/targets/', 28 "path": f'{python_dir}/targets/', 53 python_dir = f'{option.test_dir}/python' 71 "working_directory": f'{python_dir}/targets/', 72 "path": f'{python_dir}/targets/',
|
H A D | test_static_fallback.py | 13 assets_dir = f'{temp_dir}/assets' 14 os.makedirs(f'{assets_dir}/dir') 15 Path(f'{assets_dir}/index.html').write_text('0123456789') 17 os.makedirs(f'{assets_dir}/403') 18 os.chmod(f'{assets_dir}/403', 0o000) 26 "routes": [{"action": {"share": f'{assets_dir}$uri'}}], 34 os.chmod(f'{assets_dir}/403', 0o777) 53 {"share": f"{temp_dir}/assets$uri", "fallback": {"return": 200}} 88 "fallback": {"share": f"{temp_dir}/assets$uri"},
|
/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' 68 a_names += f'IP.{i} = {k[1]}\n' 70 a_names += f'DNS.{i} = {k[0]}\n' 80 with open(conf_path, 'w') as f: 81 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/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')
|