Home
last modified time | relevance | path

Searched refs:len (Results 1 – 25 of 113) sorted by relevance

12345

/unit/test/
H A Dtest_python_procman.py49 assert len(pids) == 2, 'prefork 2'
57 assert len(pids) == 4, 'prefork 4'
81 assert len(pids) == 1, 'on-demand 1'
96 assert len(pids) == 2, 'updown 2'
100 assert len(pids_new) == 3, 'updown 3'
109 assert len(pids) == 2, 'updown stop idle'
122 assert len(pids) == 2, 'reconf 2'
126 assert len(pids_new) == 3, 'reconf 3'
132 assert len(pids) == 6, 'reconf 6'
144 assert len(pids) == 1, 'idle timeout 1'
[all …]
H A Dtest_ruby_application.py42 'Content-Length': str(len(body)),
371 assert len(headers['X-Copyright']) > 0, 'RUBY_COPYRIGHT'
372 assert len(headers['X-Description']) > 0, 'RUBY_DESCRIPTION'
373 assert len(headers['X-Engine']) > 0, 'RUBY_ENGINE'
374 assert len(headers['X-Engine-Version']) > 0, 'RUBY_ENGINE_VERSION'
375 assert len(headers['X-Patchlevel']) > 0, 'RUBY_PATCHLEVEL'
376 assert len(headers['X-Platform']) > 0, 'RUBY_PLATFORM'
377 assert len(headers['X-Release-Date']) > 0, 'RUBY_RELEASE_DATE'
378 assert len(headers['X-Revision']) > 0, 'RUBY_REVISION'
379 assert len(headers['X-Version']) > 0, 'RUBY_VERSION'
[all …]
/unit/src/
H A Dnxt_mem_map.c11 nxt_mem_mmap(void *addr, size_t len, nxt_uint_t protection, nxt_uint_t flags, in nxt_mem_mmap() argument
16 p = mmap(addr, len, protection, flags, fd, offset); in nxt_mem_mmap()
20 addr, len, protection, flags, fd, offset, p); in nxt_mem_mmap()
24 addr, len, protection, flags, fd, offset, nxt_errno); in nxt_mem_mmap()
32 nxt_mem_munmap(void *addr, size_t len) in nxt_mem_munmap() argument
34 if (nxt_fast_path(munmap(addr, len) == 0)) { in nxt_mem_munmap()
35 nxt_thread_log_debug("munmap(%p, %uz)", addr, len); in nxt_mem_munmap()
38 nxt_thread_log_alert("munmap(%p, %uz) failed %E", addr, len, nxt_errno); in nxt_mem_munmap()
H A Dnxt_djb_hash.c11 nxt_djb_hash(const void *data, size_t len) in nxt_djb_hash() argument
19 while (len != 0) { in nxt_djb_hash()
21 len--; in nxt_djb_hash()
29 nxt_djb_hash_lowcase(const void *data, size_t len) in nxt_djb_hash_lowcase() argument
38 while (len != 0) { in nxt_djb_hash_lowcase()
41 len--; in nxt_djb_hash_lowcase()
H A Dnxt_parse.h11 NXT_EXPORT nxt_int_t nxt_int_parse(const u_char *p, size_t len);
12 NXT_EXPORT ssize_t nxt_size_t_parse(const u_char *p, size_t len);
13 NXT_EXPORT ssize_t nxt_size_parse(const u_char *p, size_t len);
14 NXT_EXPORT nxt_off_t nxt_off_t_parse(const u_char *p, size_t len);
20 NXT_EXPORT nxt_time_t nxt_time_parse(const u_char *p, size_t len);
21 NXT_EXPORT nxt_int_t nxt_term_parse(const u_char *p, size_t len,
H A Dnxt_mem_map.h49 #define nxt_mem_map(addr, ctx, len, protection, flags, fd, offset) \ argument
50 nxt_mem_mmap(addr, len, protection, flags, fd, offset)
53 #define nxt_mem_unmap(addr, ctx, len) \ argument
54 nxt_mem_munmap(addr, len)
57 NXT_EXPORT void *nxt_mem_mmap(void *addr, size_t len, nxt_uint_t protection,
59 NXT_EXPORT void nxt_mem_munmap(void *addr, size_t len);
H A Dnxt_fastcgi_source.c16 uint32_t len; member
25 p[1] = (u_char) len; len >>= 8; \
207 param.len = 0; in nxt_fastcgi_request_create()
260 if (nxt_fast_path(len >= param.len)) { in nxt_fastcgi_request_create()
261 len = param.len; in nxt_fastcgi_request_create()
265 param.len -= len; in nxt_fastcgi_request_create()
272 size += len; in nxt_fastcgi_request_create()
371 param->len = fs->u.request.name.len; in nxt_fastcgi_next_param()
377 param->len = fs->u.request.value.len; in nxt_fastcgi_next_param()
555 if (len > 255) { in nxt_fastcgi_source_header_process()
[all …]
H A Dnxt_upstream_source.c30 lhq.key_hash = nxt_djb_hash(unv->name, unv->len); in nxt_upstream_header_hash_add()
32 lhq.key.len = unv->len; in nxt_upstream_header_hash_add()
57 if (lhq->key.len == unv->len in nxt_upstream_header_hash_test()
58 && nxt_memcasecmp(lhq->key.data, unv->name, unv->len) == 0) in nxt_upstream_header_hash_test()
H A Dnxt_websocket_accept.c12 nxt_websocket_base64_encode(u_char *d, const uint8_t *s, size_t len) in nxt_websocket_base64_encode() argument
18 while (len > 2) { in nxt_websocket_base64_encode()
29 len -= 3; in nxt_websocket_base64_encode()
32 if (len > 0) { in nxt_websocket_base64_encode()
36 if (len == 1) { in nxt_websocket_base64_encode()
H A Dnxt_murmur_hash.c11 nxt_murmur_hash2(const void *data, size_t len) in nxt_murmur_hash2() argument
18 h = 0 ^ (uint32_t) len; in nxt_murmur_hash2()
20 while (len >= 4) { in nxt_murmur_hash2()
34 len -= 4; in nxt_murmur_hash2()
37 switch (len) { in nxt_murmur_hash2()
H A Dnxt_file.h25 size_t len; member
34 #define nxt_file_name_alloc(mem_pool, len) \ argument
35 nxt_mp_nget(mem_pool, len)
38 #define nxt_file_name_copy(dst, src, len) \ argument
39 nxt_cpymem(dst, src, len)
42 #define nxt_file_name_add(dst, src, len) \ argument
43 nxt_cpymem(dst, src, len)
209 NXT_EXPORT size_t nxt_dir_current(char *buf, size_t len);
H A Dnxt_socket.c79 socklen_t len; in nxt_socket_getsockopt() local
81 len = sizeof(val); in nxt_socket_getsockopt()
83 if (nxt_fast_path(getsockopt(s, level, sockopt, &val, &len) == 0)) { in nxt_socket_getsockopt()
101 socklen_t len; in nxt_socket_setsockopt() local
103 len = sizeof(val); in nxt_socket_setsockopt()
105 if (nxt_fast_path(setsockopt(s, level, sockopt, &val, len) == 0)) { in nxt_socket_setsockopt()
321 socklen_t len; in nxt_socket_error() local
324 len = sizeof(int); in nxt_socket_error()
329 ret = getsockopt(s, SOL_SOCKET, SO_ERROR, (void *) &err, &len); in nxt_socket_error()
H A Dnxt_http_source.c117 if (nxt_fast_path(len >= src->len)) { in nxt_http_source_copy()
118 len = src->len; in nxt_http_source_copy()
119 src->len = 0; in nxt_http_source_copy()
122 src->len -= len; in nxt_http_source_copy()
126 src->data += len; in nxt_http_source_copy()
128 return nxt_cpymem(p, s, len); in nxt_http_source_copy()
356 lhq.key.len = nv->name_len; in nxt_http_source_header_line_process()
623 if (len > NXT_MAX_ERROR_STR - 300) { in nxt_http_source_message()
624 len = NXT_MAX_ERROR_STR - 300; in nxt_http_source_message()
625 p[len++] = '.'; p[len++] = '.'; p[len++] = '.'; in nxt_http_source_message()
[all …]
H A Dnxt_clone.c87 int len, mapfd; in nxt_clone_credential_map_write() local
108 len = nxt_strlen(mapinfo); in nxt_clone_credential_map_write()
110 n = write(mapfd, (char *)mapinfo, len); in nxt_clone_credential_map_write()
111 if (nxt_slow_path(n != len)) { in nxt_clone_credential_map_write()
139 nxt_int_t ret, len; in nxt_clone_credential_map_set() local
146 len = sizeof(u_char) * (10 + 10 + 10 + 2 + 1); in nxt_clone_credential_map_set()
149 len = len * map->size + 1; in nxt_clone_credential_map_set()
151 mapinfo = nxt_malloc(len); in nxt_clone_credential_map_set()
157 end = mapinfo + len; in nxt_clone_credential_map_set()
178 mapinfo = nxt_malloc(len); in nxt_clone_credential_map_set()
[all …]
/unit/src/java/nginx/unit/
H A DInputStream.java18 public int readLine(byte[] b, int off, int len) throws IOException { in readLine() argument
20 if (len <= 0) { in readLine()
23 return readLine(req_info_ptr, b, off, len); in readLine()
26 private static native int readLine(long req_info_ptr, byte[] b, int off, int len); in readLine() argument
61 public int read(byte b[], int off, int len) throws IOException { in read() argument
64 } else if (off < 0 || len < 0 || len > b.length - off) { in read()
66 } else if (len == 0) { in read()
70 return read(req_info_ptr, b, off, len); in read()
73 private static native int read(long req_info_ptr, byte b[], int off, int len); in read() argument
H A DOutputStream.java26 public void write(byte b[], int off, int len) throws IOException in write() argument
30 } else if ((off < 0) || (off > b.length) || (len < 0) || in write()
31 ((off + len) > b.length) || ((off + len) < 0)) { in write()
33 } else if (len == 0) { in write()
37 write(req_info_ptr, b, off, len); in write()
40 private static native void write(long req_info_ptr, byte b[], int off, int len); in write() argument
/unit/src/test/
H A Dnxt_utf8_test.c43 nxt_utf8_overlong(nxt_thread_t *thr, u_char *overlong, size_t len) in nxt_utf8_overlong() argument
53 d = nxt_utf8_decode(&pp, overlong + len); in nxt_utf8_overlong()
55 len = pp - overlong; in nxt_utf8_overlong()
62 if (len != size || nxt_memcmp(overlong, utf8, size) != 0) { in nxt_utf8_overlong()
65 for (i = 0; i < len; i++) { in nxt_utf8_overlong()
71 u, len, d, size); in nxt_utf8_overlong()
85 size_t len; in nxt_utf8_test() local
121 len = invalid[i]; in nxt_utf8_test()
129 d = nxt_utf8_decode(&pp, utf8 + len); in nxt_utf8_test()
134 for (i = 0; i < len; i++) { in nxt_utf8_test()
[all …]
/unit/test/perl/input_copy/
H A Dpsgi.pl6 my $len = int($environ->{'CONTENT_LENGTH'});
7 $fh->read(my $body, $len);
9 return ['200', ['Content-Length' => $len], [$body]];
/unit/test/perl/variables/
H A Dpsgi.pl4 my $len = int($environ->{'CONTENT_LENGTH'});
5 $environ->{'psgi.input'}->read(my $body, $len);
11 'Content-Length' => $len,
/unit/test/python/delayed/
H A Dwsgi.py11 write = start_response('200', [('Content-Length', str(len(body)))])
17 step = int(len(body) / parts)
18 for i in range(0, len(body), step):
H A Dasgi.py36 'headers': [(b'content-length', str(len(body)).encode()),],
44 step = int(len(body) / parts)
45 for i in range(0, len(body), step):
/unit/test/perl/input_read_empty/
H A Dpsgi.pl4 $len = $environ->{'psgi.input'}->read(my $body, 1024);
6 return ['200', ['Content-Length' => $len], [$body]];
/unit/src/java/
H A Dnxt_jni.c129 nxt_java_strcaseeq(const char *str1, const char *str2, int len) in nxt_java_strcaseeq() argument
134 end1 = str1 + len; in nxt_java_strcaseeq()
157 nxt_java_newString(JNIEnv *env, char *str, uint32_t len) in nxt_java_newString() argument
162 tmp = str[len]; in nxt_java_newString()
165 str[len] = '\0'; in nxt_java_newString()
171 str[len] = tmp; in nxt_java_newString()
/unit/test/python/input_iter/
H A Dwsgi.py7 content_length += len(l)
13 ('X-Lines-Count', str(len(body))),
/unit/test/python/input_readline/
H A Dwsgi.py11 content_length += len(l)
17 ('X-Lines-Count', str(len(body))),

12345