/unit/src/ |
H A D | nxt_buf_filter.c | 39 f = obj; in nxt_buf_filter() 115 ret = f->run->filter_sync_last(f); in nxt_buf_filter() 132 ret = f->run->filter_process(f); in nxt_buf_filter() 169 task, f, f->data); in nxt_buf_filter() 187 f->run->filter_next(f); in nxt_buf_filter_nobuf() 204 f->run->filter_next(f); in nxt_buf_filter_next() 215 if (!f->queued && !f->done) { in nxt_buf_filter_enqueue() 229 ff = f->run->job_file_create(f); in nxt_buf_filter_file_read_start() 298 f->run->job_file_retain(f); in nxt_buf_filter_file_read() 348 f->run->job_file_release(f); in nxt_buf_filter_file_job_completion() [all …]
|
H A D | nxt_buf_filter.h | 71 nxt_int_t (*filter_ready)(nxt_buf_filter_t *f); 72 nxt_int_t (*filter_process)(nxt_buf_filter_t *f); 73 nxt_int_t (*filter_flush)(nxt_buf_filter_t *f); 75 nxt_int_t (*filter_sync_nobuf)(nxt_buf_filter_t *f); 76 nxt_int_t (*filter_sync_flush)(nxt_buf_filter_t *f); 77 nxt_int_t (*filter_sync_last)(nxt_buf_filter_t *f); 79 void (*filter_next)(nxt_buf_filter_t *f); 82 nxt_buf_filter_file_t *(*job_file_create)(nxt_buf_filter_t *f); 83 void (*job_file_retain)(nxt_buf_filter_t *f); 84 void (*job_file_release)(nxt_buf_filter_t *f); [all …]
|
H A D | nxt_sprintf.c | 94 (fabs(f) <= FLT_EPSILON) 101 double f, i; in nxt_vsprintf() local 373 f = va_arg(args, double); in nxt_vsprintf() 375 if (f < 0) { in nxt_vsprintf() 377 f = -f; in nxt_vsprintf() 380 if (nxt_slow_path(isnan(f))) { in nxt_vsprintf() 386 } else if (nxt_slow_path(isinf(f))) { in nxt_vsprintf() 393 (void) modf(f, &i); in nxt_vsprintf() 425 f = modf(f, &i); in nxt_vsprintf() 431 f *= 10; in nxt_vsprintf() [all …]
|
H A D | nxt_port_memory_int.h | 177 nxt_free_map_t *f; in nxt_port_mmap_chk_set_chunk_busy() local 180 f = m + FREE_IDX(c); in nxt_port_mmap_chk_set_chunk_busy() 182 while ( (*f & FREE_MASK(c)) != 0 ) { in nxt_port_mmap_chk_set_chunk_busy() 184 free_val = *f | FREE_MASK(c); in nxt_port_mmap_chk_set_chunk_busy() 187 if (nxt_atomic_cmp_set(f, free_val, busy_val) != 0) { in nxt_port_mmap_chk_set_chunk_busy()
|
H A D | nxt_http_request.c | 322 nxt_http_field_t *f, **fields; in nxt_http_request_client_ip() local 343 nxt_list_each(f, r->fields) { in nxt_http_request_client_ip() 346 && f->value_length > 0 in nxt_http_request_client_ip() 354 *fields = f; in nxt_http_request_client_ip() 364 f = fields[i]; in nxt_http_request_client_ip() 365 start = f->value; in nxt_http_request_client_ip() 366 len = f->value_length; in nxt_http_request_client_ip() 913 nxt_http_field_t *f; in nxt_http_cookies_parse() local 924 nxt_list_each(f, r->fields) { in nxt_http_cookies_parse() 927 || f->name_length != 6 in nxt_http_cookies_parse() [all …]
|
/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/pkg/docker/ |
H A D | docker-entrypoint.sh | 35 for f in $(/usr/bin/find /docker-entrypoint.d/ -type f -name "*.pem"); do 36 echo "$0: Uploading certificates bundle: $f" 37 curl_put $f "certificates/$(basename $f .pem)" 41 for f in $(/usr/bin/find /docker-entrypoint.d/ -type f -name "*.json"); do 42 echo "$0: Applying configuration $f"; 43 curl_put $f "config" 47 for f in $(/usr/bin/find /docker-entrypoint.d/ -type f -name "*.sh"); do 48 echo "$0: Launching $f"; 49 "$f" 53 …for f in $(/usr/bin/find /docker-entrypoint.d/ -type f -not -name "*.sh" -not -name "*.json" -not … [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 …]
|
H A D | nxt_jni_Response.c | 400 f->skip = 0; in nxt_java_add_int_header() 494 if (f == NULL) { in nxt_java_Response_getHeader() 562 if (f == NULL) { in nxt_java_Response_getHeaders() 681 f = resp->fields; in nxt_java_response_set_header() 687 f = nxt_java_findHeader(f, e, name, name_len); in nxt_java_response_set_header() 705 ++f; in nxt_java_response_set_header() 803 f = resp->fields; in nxt_java_response_remove_header() 807 f = nxt_java_findHeader(f, e, name, name_len); in nxt_java_response_remove_header() 812 f->skip = 1; in nxt_java_response_remove_header() 814 ++f; in nxt_java_response_remove_header() [all …]
|
H A D | nxt_jni_Request.c | 277 nxt_unit_field_t *f; in nxt_java_Request_getHeader() local 292 if (f == NULL) { in nxt_java_Request_getHeader() 316 nxt_unit_field_t *f; in nxt_java_Request_getHeaders() local 331 if (f == NULL) { in nxt_java_Request_getHeaders() 347 nxt_unit_field_t *f; in nxt_java_Request_getIntHeader() local 364 if (f == NULL) { in nxt_java_Request_getIntHeader() 442 nxt_unit_field_t *f; in nxt_java_Request_getContentType() local 601 nxt_unit_field_t *f; in nxt_java_Request_getServerName() local 608 if (f != NULL) { in nxt_java_Request_getServerName() 629 nxt_unit_field_t *f; in nxt_java_Request_getServerPort() local [all …]
|
H A D | nxt_jni.c | 107 nxt_java_findHeader(nxt_unit_field_t *f, nxt_unit_field_t *end, in nxt_java_findHeader() argument 112 for (/* void */ ; f < end; f++) { in nxt_java_findHeader() 113 if (f->skip != 0 || f->name_length != name_len) { in nxt_java_findHeader() 117 field_name = nxt_unit_sptr_get(&f->name); in nxt_java_findHeader() 120 return f; in nxt_java_findHeader()
|
/unit/test/unit/applications/lang/ |
H A D | java.py | 25 for f in os.listdir(script_path): 26 file_path = script_path + f 28 if f.endswith('.java'): 32 if f.startswith('.') or f == 'Makefile': 36 if f == 'WEB-INF': 39 shutil.copytree(file_path, app_path + '/' + f) 42 if f == 'web.xml':
|
H A D | go.py | 53 with open(temp_dir + 'go.mod', 'w') as f: 54 f.write( 55 f"""module test/app
|
/unit/test/unit/applications/ |
H A D | proto.py | 20 with Log.open(name) as f: 21 return re.findall(pattern, f.read()) 24 with Log.open(name) as f: 25 return re.search(pattern, f.read()) 28 with Log.open(name) as f: 30 found = re.search(pattern, f.read())
|
/unit/go/ |
H A D | request.go | 83 f := &fields[i] 85 n := GoStringN(&f.name, C.int(f.name_length)) 86 v := GoStringN(&f.value, C.int(f.value_length)) 95 f := uintptr(unsafe.Pointer(req)) + uintptr(C.NXT_FIELDS_OFFSET) 98 Data: unsafe.Pointer(f),
|
/unit/test/unit/ |
H A D | utils.py | 16 for f in files: 17 os.chmod(os.path.join(root, f), 0o777) 24 for f in files: 25 if not os.path.exists(f): 41 for f in glob.glob(pattern):
|
H A D | log.py | 9 f = open(Log.get_path(name), 'r', encoding=encoding, errors='ignore') 10 f.seek(Log.pos.get(name, 0)) 12 return f
|
/unit/test/python/body_io_file/ |
H A D | wsgi.py | 3 f = open('file', 'rb') 4 return f
|
/unit/test/python/body_io/ |
H A D | wsgi.py | 6 f = io.BytesIO(b'0123456789') 7 return f
|
/unit/test/ |
H A D | test_static.py | 50 with open(path, 'w+') as f: 51 f.write(str(version)) 53 with open(temp_dir + '/state/version', 'r') as f: 54 assert int(f.read().rstrip()) > 12500, 'current version' 107 with open(temp_dir + '/assets/large', 'wb') as f: 108 f.seek(file_size - 1) 109 f.write(b'\0') 123 with open(temp_dir + '/assets/index.html', 'w') as f: 124 f.write('blah')
|
H A D | test_tls_sni.py | 33 with open(option.temp_dir + '/ca.conf', 'w') as f: 34 f.write( 60 with open(option.temp_dir + '/certserial', 'w') as f: 61 f.write('1000') 63 with open(option.temp_dir + '/certindex', 'w') as f: 64 f.write('')
|
/unit/auto/modules/ |
H A D | java_chk_sha512 | 38 if [ -f "$NXT_JAR_CHK_FILE" ]; then 45 rm -f $NXT_JAR_CHK_FILE 48 rm -f $NXT_JAR_CHK
|
/unit/auto/ |
H A D | clang | 150 void *f(void) __attribute__ ((__malloc__)); 152 void *f(void) { 157 if (f() != NULL) { 186 nxt_feature_test="static void f(void) __attribute__ ((__unused__)); 188 static void f(void)
|
/unit/test/python/lifespan/empty/ |
H A D | asgi.py | 6 with open(prefix + 'version', 'w+') as f: 7 f.write(
|