Home
last modified time | relevance | path

Searched refs:f (Results 1 – 25 of 78) sorted by relevance

1234

/unit/src/
H A Dnxt_buf_filter.c39 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 Dnxt_buf_filter.h71 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 Dnxt_sprintf.c94 (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 Dnxt_port_memory_int.h177 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 Dnxt_http_request.c322 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 Dnxt_perl_psgi_layer.c141 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 Ddocker-entrypoint.sh35 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 Dnxt_jni_HeaderNamesEnumeration.c91 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 Dnxt_jni_HeadersEnumeration.c91 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 Dnxt_jni_Response.c400 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 Dnxt_jni_Request.c277 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 Dnxt_jni.c107 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 Djava.py25 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 Dgo.py53 with open(temp_dir + 'go.mod', 'w') as f:
54 f.write(
55 f"""module test/app
/unit/test/unit/applications/
H A Dproto.py20 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 Drequest.go83 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 Dutils.py16 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 Dlog.py9 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 Dwsgi.py3 f = open('file', 'rb')
4 return f
/unit/test/python/body_io/
H A Dwsgi.py6 f = io.BytesIO(b'0123456789')
7 return f
/unit/test/
H A Dtest_static.py50 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 Dtest_tls_sni.py33 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 Djava_chk_sha51238 if [ -f "$NXT_JAR_CHK_FILE" ]; then
45 rm -f $NXT_JAR_CHK_FILE
48 rm -f $NXT_JAR_CHK
/unit/auto/
H A Dclang150 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 Dasgi.py6 with open(prefix + 'version', 'w+') as f:
7 f.write(

1234