/unit/test/ |
H A D | test_asgi_application.py | 46 'content-length': str(len(body)), 457 assert len(socks) == len(threads), 'threads differs'
|
H A D | test_procman.py | 62 assert len(pids) == 2, 'prefork 2' 70 assert len(pids) == 4, 'prefork 4' 96 assert len(pids) == 1, 'on-demand 1' 112 assert len(pids) == 2, 'updown 2' 116 assert len(pids_new) == 3, 'updown 3' 125 assert len(pids) == 2, 'updown stop idle' 139 assert len(pids) == 2, 'reconf 2' 143 assert len(pids_new) == 3, 'reconf 3' 149 assert len(pids) == 6, 'reconf 6' 162 assert len(pids) == 1, 'idle timeout 1' [all …]
|
H A D | test_node_application.py | 84 'Content-Length': str(len(body)),
|
H A D | test_ruby_application.py | 42 'Content-Length': str(len(body)), 422 assert len(headers['X-Copyright']) > 0, 'RUBY_COPYRIGHT' 423 assert len(headers['X-Description']) > 0, 'RUBY_DESCRIPTION' 424 assert len(headers['X-Engine']) > 0, 'RUBY_ENGINE' 425 assert len(headers['X-Engine-Version']) > 0, 'RUBY_ENGINE_VERSION' 426 assert len(headers['X-Patchlevel']) > 0, 'RUBY_PATCHLEVEL' 427 assert len(headers['X-Platform']) > 0, 'RUBY_PLATFORM' 428 assert len(headers['X-Release-Date']) > 0, 'RUBY_RELEASE_DATE' 429 assert len(headers['X-Revision']) > 0, 'RUBY_REVISION' 430 assert len(headers['X-Version']) > 0, 'RUBY_VERSION' [all …]
|
H A D | test_upstreams_rr.py | 60 if ups > len(resps) - 1: 61 resps.extend([0] * (ups - len(resps) + 1)) 219 sum_r = [0] * len(args[0])
|
H A D | test_tls.py | 278 assert len(chain) == 1, 'certificate chain length' 332 assert len(chain) == 1, 'certificate chain end length' 357 assert len(chain) == 1, 'certificate chain int length' 376 assert len(chain) == 2, 'certificate chain end-int length' 438 assert len(chain) == chain_length - 1, 'certificate chain length'
|
H A D | test_tls_conf_command.py | 64 if len(protocols) > 1: 91 if len(ciphers) > 1:
|
H A D | test_settings.py | 174 if len(resp) != 0: 291 data_len = 1048576 if len(values) == 0 else 10 * max(values) 303 assert len(data) < data_len, 'send timeout data ' 309 assert len(data) > data_len, 'send timeout data 2' 438 return len(findall(r'"fallback" taken')) 586 assert len(findall(r'\[notice\].*http request line')) == 7 587 assert len(findall(r'\[notice\].*selected')) == 10 588 assert len(findall(r'\[info\].*discarded')) == 2
|
/unit/test/python/body_bytearray/ |
H A D | asgi.py | 16 'headers': [(b'content-length', str(len(body)).encode())],
|
/unit/src/wasm-wasi-component/src/ |
H A D | lib.rs | 31 length: s.len(), in nxt_string() 46 compat_length: COMPAT.len() * 4, 392 response.headers().len().try_into().unwrap(), in send_response() 396 .map(|(k, v)| k.as_str().len() + v.len()) in send_response() 508 if total_bytes_read >= rest.len() { in request_read() 514 dst.set_len(dst.len() + total_bytes_read); in request_read() 523 data.len(), in response_write() 546 key.len().try_into().unwrap(), in add_field() 548 val.len().try_into().unwrap(), in add_field() 573 len: u32, in get_str() [all …]
|
/unit/src/ |
H A D | nxt_application.c | 993 size_t len; in nxt_cstr_dup() local 995 len = nxt_strlen(src); in nxt_cstr_dup() 998 dst = nxt_mp_alloc(mp, len + 1); in nxt_cstr_dup() 1004 p = nxt_cpymem(dst, src, len); in nxt_cstr_dup()
|
H A D | nxt_runtime.c | 901 rt->certs.length = file_name.len; in nxt_runtime_conf_init() 918 rt->scripts.length = file_name.len; in nxt_runtime_conf_init()
|
H A D | nxt_file.h | 25 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) 216 NXT_EXPORT size_t nxt_dir_current(char *buf, size_t len);
|
H A D | nxt_file.c | 768 nxt_dir_current(char *buf, size_t len) in nxt_dir_current() argument 770 if (nxt_fast_path(getcwd(buf, len) != NULL)) { in nxt_dir_current() 774 nxt_thread_log_alert("getcwd(%uz) failed %E", len, nxt_errno); in nxt_dir_current()
|
H A D | nxt_conf.c | 2332 size_t len; in nxt_conf_json_array_length() local 2339 len = 2; in nxt_conf_json_array_length() 2366 return len + n; in nxt_conf_json_array_length() 2434 len = 2; in nxt_conf_json_object_length() 2459 len += pretty->level + 2; in nxt_conf_json_object_length() 2462 return len; in nxt_conf_json_object_length() 2542 size_t len; in nxt_conf_json_escape_length() local 2544 len = size; in nxt_conf_json_escape_length() 2550 len++; in nxt_conf_json_escape_length() 2560 len++; in nxt_conf_json_escape_length() [all …]
|
H A D | nxt_isolation.c | 613 size_t i, n, rootfs_len, len; in nxt_isolation_set_lang_mounts() local 901 size_t len; in nxt_isolation_make_private_mount() local 973 len = nxt_strlen(rootfs); in nxt_isolation_make_private_mount() 975 parent_mnt = nxt_malloc(len + 1); in nxt_isolation_make_private_mount() 981 parent_mnt[len] = '\0'; in nxt_isolation_make_private_mount() 983 if (parent_mnt[len - 1] == '/') { in nxt_isolation_make_private_mount() 984 parent_mnt[len - 1] = '\0'; in nxt_isolation_make_private_mount() 985 len--; in nxt_isolation_make_private_mount() 1001 while (parent_mnt[len - 1] != '/' && len > 0) { in nxt_isolation_make_private_mount() 1002 len--; in nxt_isolation_make_private_mount() [all …]
|
H A D | nxt_http_request.c | 18 nxt_http_request_t *r, u_char *start, size_t len); 418 nxt_int_t ret, i, len; in nxt_http_request_forward_client_ip() local 429 len = f[i]->value_length; in nxt_http_request_forward_client_ip() 432 for (p = start + len - 1; p > start; p--, len--) { in nxt_http_request_forward_client_ip() 445 sa = nxt_http_request_client_ip_sockaddr(r, p, len - (p - start)); in nxt_http_request_forward_client_ip() 466 len = p - 1 - start; in nxt_http_request_forward_client_ip() 468 } while (len > 0); in nxt_http_request_forward_client_ip() 475 size_t len) in nxt_http_request_client_ip_sockaddr() argument 481 addr.length = len; in nxt_http_request_client_ip_sockaddr()
|
H A D | nxt_clone.c | 73 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 D | nxt_socket.c | 79 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 D | nxt_openssl.c | 632 size_t len; local 685 len = nxt_base64_decode(buf, value.start, value.length); 689 if (len == 48) { 852 int len; local 910 len = X509_NAME_get_text_by_NID(x509_name, NID_commonName, 912 if (len <= 0) { 918 domain.start = nxt_mp_nget(mp, len + 1); 925 len + 1);
|
/unit/tools/ |
H A D | setup-unit | 872 socklen_t len; 888 len = sizeof(addr); 889 if (bind(sfd, (struct sockaddr *) &addr, len)) { 894 if (getsockname(sfd, (struct sockaddr *) &addr, &len)) {
|
/unit/src/java/nginx/unit/websocket/ |
H A D | Util.java | 510 int len = value.length(); in parseExtensionHeader() local 511 if (len > 1) { in parseExtensionHeader() 512 if (value.charAt(0) == '\"' && value.charAt(len - 1) == '\"') { in parseExtensionHeader()
|
/unit/test/unit/ |
H A D | http.py | 71 headers['Content-Length'] = len(body) 149 len_log = len(log) 243 if len(chunks) < 3: 259 while len(chunks) >= 2: 267 assert len(chunks) == 1, 'last zero size' 274 temp_body = temp_body[size + len(crlf) :]
|
H A D | control.py | 14 url = args[0] if len(args) == 1 else url_default 22 url = args[1] if len(args) == 2 else url_default
|
/unit/test/unit/applications/ |
H A D | websockets.py | 84 data += sock.recv(bytes_len - len(data)) 86 if len(data) == bytes_len: 169 data_length = len(data) if length is None else length 201 frame_len = len(frame) 211 message_len = len(message)
|