/unit/src/ |
H A D | nxt_tstr.h | 68 p = memchr(str->start, '`', str->length); in nxt_is_tstr() 73 p = memchr(str->start, '$', str->length); in nxt_is_tstr()
|
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() 1270 size_t length; in nxt_runtime_hostname() local 1288 length = nxt_strlen(hostname); in nxt_runtime_hostname() 1289 rt->hostname.length = length; in nxt_runtime_hostname() 1459 size_t length; in nxt_current_directory() local 1466 if (nxt_fast_path(length != 0)) { in nxt_current_directory() 1484 ssize_t length; in nxt_runtime_pid_file_create() local 1504 if (nxt_file_write(&file, pid, length, 0) != length) { in nxt_runtime_pid_file_create() 1556 if (lhq->key.length == sizeof(nxt_pid_t) in nxt_runtime_lvlhsh_pid_test() [all …]
|
H A D | nxt_openssl.c | 685 len = nxt_base64_decode(buf, value.start, value.length); 875 str.length = ASN1_STRING_length(name->d.dNSName); 882 domain.start = nxt_mp_nget(mp, str.length); 887 domain.length = str.length; 988 item->name.length--; 1054 str.length = nxt_strlen(servername); 1055 if (str.length == 0) { 1068 str.start = nxt_mp_nget(c->mem_pool, str.length); 1081 for (i = 1; i < str.length; i++) { 1084 str.length -= i; [all …]
|
H A D | nxt_java.c | 259 opt = nxt_malloc(str.length + 1); in nxt_java_start() 265 memcpy(opt, str.start, str.length); in nxt_java_start() 266 opt[str.length] = '\0'; in nxt_java_start() 284 opt_len = str.length + 1; in nxt_java_start() 286 char *sc = memchr(str.start, ':', str.length); in nxt_java_start() 298 nxt_memcpy(opt, str.start, str.length); in nxt_java_start() 299 opt[str.length] = '\0'; in nxt_java_start() 321 real_path_len = str.length; in nxt_java_start()
|
H A D | nxt_port_hash.c | 26 if (lhq->key.length == sizeof(nxt_pid_port_id_t) in nxt_port_hash_test() 55 lhq->key.length = sizeof(nxt_pid_port_id_t); in nxt_port_hash_lhq()
|
H A D | nxt_regex.h | 37 size_t length, nxt_regex_match_t *match);
|
H A D | nxt_listen_socket.c | 101 sa = nxt_sockaddr_alloc(mp, sa->socklen + 4, sa->length + 4); in nxt_listen_socket_create() 175 ts, (size_t) orig_sa->length, in nxt_listen_socket_create() 183 ts, (size_t) orig_sa->length, in nxt_listen_socket_create() 393 (size_t) sa->length, nxt_sockaddr_start(sa)); in nxt_listen_socket_log_handler()
|
H A D | nxt_status.c | 75 name.length = app->name.length; in nxt_status_get()
|
H A D | nxt_h1proto.c | 895 tmp_name.length = tmp_path->length + tmp_name_pattern.length; in nxt_h1p_request_body_read() 904 tmp_name.length = 0; in nxt_h1p_request_body_read() 921 tmp_name_pattern.length); in nxt_h1p_request_body_read() 1274 size = status->length; in nxt_h1p_request_header_send() 1314 size += connection[conn].length; in nxt_h1p_request_header_send() 2275 size = r->method->length + sizeof(" ") + r->target.length in nxt_h1p_peer_header_send() 2595 size_t length; in nxt_h1p_peer_header_parse() local 2620 length -= 12; in nxt_h1p_peer_header_parse() 2622 p = memchr(p, '\n', length); in nxt_h1p_peer_header_parse() 2689 size_t length; in nxt_h1p_peer_body_process() local [all …]
|
H A D | nxt_buf.c | 181 size_t length; in nxt_buf_chain_length() local 183 length = 0; in nxt_buf_chain_length() 187 length += b->mem.free - b->mem.pos; in nxt_buf_chain_length() 193 return length; in nxt_buf_chain_length()
|
H A D | nxt_isolation.c | 118 if (app_conf->group.length > 0 in nxt_isolation_main_prefork() 242 str.length + 1); in nxt_isolation_set_cgroup() 243 nxt_memcpy(process->isolation.cgroup.path, str.start, str.length); in nxt_isolation_set_cgroup() 244 process->isolation.cgroup.path[str.length] = '\0'; in nxt_isolation_set_cgroup() 505 if (nxt_slow_path(str.length <= 1 || str.start[0] != '/')) { in nxt_isolation_set_rootfs() 512 if (str.start[str.length - 1] == '/') { in nxt_isolation_set_rootfs() 513 str.length--; in nxt_isolation_set_rootfs() 517 str.length + 1); in nxt_isolation_set_rootfs() 523 nxt_memcpy(process->isolation.rootfs, str.start, str.length); in nxt_isolation_set_rootfs() 525 process->isolation.rootfs[str.length] = '\0'; in nxt_isolation_set_rootfs()
|
/unit/test/ruby/input_read_empty/ |
H A D | config.ru | 3 ['200', {'Content-Length' => body.length.to_s}, [body]]
|
/unit/test/ruby/mirror/ |
H A D | config.ru | 4 'Content-Length' => body.length.to_s
|
/unit/src/java/nginx/unit/websocket/ |
H A D | AsyncChannelWrapperNonSecure.java | 61 public <B,A extends B> void write(ByteBuffer[] srcs, int offset, int length, in write() argument 65 srcs, offset, length, timeout, unit, attachment, handler); in write()
|
H A D | AsyncChannelWrapperSecure.java | 130 public <B,A extends B> void write(ByteBuffer[] srcs, int offset, int length, in write() argument 142 WriteTask writeTask = new WriteTask(srcs, offset, length, future); in write() 173 private final int length; field in AsyncChannelWrapperSecure.WriteTask 176 public WriteTask(ByteBuffer[] srcs, int offset, int length, in WriteTask() argument 181 this.length = length; in WriteTask() 189 for (int i = offset; i < offset + length; i++) { in run()
|
H A D | PerMessageDeflate.java | 55 private final byte[] EOM_BUFFER = new byte[EOM_BYTES.length + 1]; 377 compressedPayload.limit(compressedPayload.limit() - EOM_BYTES.length); in sendMessagePart() 404 … int eomBufferWritten = deflater.deflate(EOM_BUFFER, 0, EOM_BUFFER.length, Deflater.SYNC_FLUSH); in sendMessagePart() 405 if (eomBufferWritten < EOM_BUFFER.length) { in sendMessagePart() 407 … compressedPayload.limit(compressedPayload.limit() - EOM_BYTES.length + eomBufferWritten); in sendMessagePart()
|
/unit/test/ruby/input_read_buffer/ |
H A D | config.ru | 5 'Content-Length' => body.length.to_s
|
/unit/test/ruby/input_read_buffer_not_empty/ |
H A D | config.ru | 5 'Content-Length' => body.length.to_s
|
/unit/test/ruby/input_gets/ |
H A D | config.ru | 5 'Content-Length' => body.length.to_s
|
/unit/test/ruby/empty/ |
H A D | config.ru | 5 'Content-Length' => body.length.to_s
|
/unit/test/ruby/input_each/ |
H A D | config.ru | 7 'Content-Length' => body.length.to_s
|
/unit/test/ruby/input_read_parts/ |
H A D | config.ru | 6 'Content-Length' => body.length.to_s
|
/unit/test/ruby/input_gets_all/ |
H A D | config.ru | 10 'Content-Length' => body.length.to_s
|
/unit/src/test/ |
H A D | nxt_lvlhsh_test.c | 46 lhq.key.length = sizeof(uintptr_t); in nxt_lvlhsh_test_add() 74 lhq.key.length = sizeof(uintptr_t); in nxt_lvlhsh_test_get() 100 lhq.key.length = sizeof(uintptr_t); in nxt_lvlhsh_test_delete()
|
/unit/src/java/nginx/unit/ |
H A D | Context.java | 215 url.length() == pattern.length() in match() 216 || url.charAt(pattern.length()) == '/'); in match() 222 return p.pattern.length() - pattern.length(); in compareTo() 587 trace(0, s, s.length()); in getResource() 779 if (p.pattern.length() == path.length()) { in findServlet() 945 || (path.length() > context_path_.length() in service() 1470 int max_len = varr1.length > varr2.length ? varr1.length : varr2.length; in compareVersion() 2270 pattern_ = p.substring(1, p.length()); 2315 url.length() == pattern_.length() 3003 log(0, msg, msg.length()); [all …]
|