Home
last modified time | relevance | path

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

12345

/unit/src/
H A Dnxt_cgroup.c20 int len; in nxt_cgroup_proc_add() local
42 len = strlen(cgprocs); in nxt_cgroup_proc_add()
44 len = snprintf(cgprocs + len, NXT_MAX_PATH_LEN - len, "/cgroup.procs"); in nxt_cgroup_proc_add()
45 if (nxt_slow_path(len >= NXT_MAX_PATH_LEN - len)) { in nxt_cgroup_proc_add()
59 if (nxt_slow_path(len < 0)) { in nxt_cgroup_proc_add()
95 int i, len; in nxt_mk_cgpath_relative() local
107 len = -1; in nxt_mk_cgpath_relative()
143 return len; in nxt_mk_cgpath_relative()
150 int len; in nxt_mk_cgpath() local
164 if (len == -1) { in nxt_mk_cgpath()
[all …]
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_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)
214 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_clone.c73 int len, mapfd; in nxt_clone_credential_map_write() local
94 len = nxt_strlen(mapinfo); in nxt_clone_credential_map_write()
96 n = write(mapfd, (char *)mapinfo, len); in nxt_clone_credential_map_write()
97 if (nxt_slow_path(n != len)) { in nxt_clone_credential_map_write()
125 nxt_int_t ret, len; in nxt_clone_credential_map_set() local
132 len = sizeof(u_char) * (10 + 10 + 10 + 2 + 1); in nxt_clone_credential_map_set()
135 len = len * map->size + 1; in nxt_clone_credential_map_set()
137 mapinfo = nxt_malloc(len); in nxt_clone_credential_map_set()
143 end = mapinfo + len; in nxt_clone_credential_map_set()
164 mapinfo = nxt_malloc(len); in nxt_clone_credential_map_set()
[all …]
H A Dnxt_djb_hash.h14 NXT_EXPORT uint32_t nxt_djb_hash(const void *data, size_t len);
15 NXT_EXPORT uint32_t nxt_djb_hash_lowcase(const void *data, size_t len);
/unit/test/
H A Dtest_python_procman.py50 assert len(pids) == 2, 'prefork 2'
58 assert len(pids) == 4, 'prefork 4'
82 assert len(pids) == 1, 'on-demand 1'
97 assert len(pids) == 2, 'updown 2'
101 assert len(pids_new) == 3, 'updown 3'
110 assert len(pids) == 2, 'updown stop idle'
123 assert len(pids) == 2, 'reconf 2'
127 assert len(pids_new) == 3, 'reconf 3'
133 assert len(pids) == 6, 'reconf 6'
145 assert len(pids) == 1, 'idle timeout 1'
[all …]
H A Dtest_ruby_application.py40 'Content-Length': str(len(body)),
368 assert len(headers['X-Copyright']) > 0, 'RUBY_COPYRIGHT'
369 assert len(headers['X-Description']) > 0, 'RUBY_DESCRIPTION'
370 assert len(headers['X-Engine']) > 0, 'RUBY_ENGINE'
371 assert len(headers['X-Engine-Version']) > 0, 'RUBY_ENGINE_VERSION'
372 assert len(headers['X-Patchlevel']) > 0, 'RUBY_PATCHLEVEL'
373 assert len(headers['X-Platform']) > 0, 'RUBY_PLATFORM'
374 assert len(headers['X-Release-Date']) > 0, 'RUBY_RELEASE_DATE'
375 assert len(headers['X-Revision']) > 0, 'RUBY_REVISION'
376 assert len(headers['X-Version']) > 0, 'RUBY_VERSION'
[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 || 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/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/perl/input_read_empty/
H A Dpsgi.pl4 $len = $environ->{'psgi.input'}->read(my $body, 1024);
6 return ['200', ['Content-Length' => $len], [$body]];
/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))),
/unit/test/python/input_readline_size/
H A Dwsgi.py11 if len(l) > 9:
15 start_response('200', [('X-Lines-Count', str(len(body)))])

12345