Home
last modified time | relevance | path

Searched refs:last (Results 1 – 25 of 43) sorted by relevance

12

/unit/src/test/
H A Dnxt_malloc_test.c71 last--; in nxt_malloc_run_test()
74 last++; in nxt_malloc_run_test()
76 last->size = size; in nxt_malloc_run_test()
80 return last; in nxt_malloc_run_test()
93 last = &sizes[0]; in nxt_malloc_test()
96 last = nxt_malloc_run_test(thr, last, size, TIMES); in nxt_malloc_test()
97 if (last == NULL) { in nxt_malloc_test()
103 last = nxt_malloc_run_test(thr, last, size, TIMES / 4); in nxt_malloc_test()
104 if (last == NULL) { in nxt_malloc_test()
110 last = nxt_malloc_run_test(thr, last, size, TIMES / 16); in nxt_malloc_test()
[all …]
/unit/src/
H A Dnxt_list.c18 list->last = &list->part; in nxt_list_create()
34 nxt_list_part_t *last; in nxt_list_add() local
36 last = list->last; in nxt_list_add()
38 if (last->nelts == list->nalloc) { in nxt_list_add()
42 last = nxt_mp_get(list->mem_pool, in nxt_list_add()
49 last->next = NULL; in nxt_list_add()
50 last->nelts = 0; in nxt_list_add()
52 list->last->next = last; in nxt_list_add()
53 list->last = last; in nxt_list_add()
56 elt = nxt_pointer_to(nxt_list_data(last), last->nelts * list->size); in nxt_list_add()
[all …]
H A Dnxt_sendbuf.c20 u_char *last; in nxt_sendbuf_mem_coalesce0() local
26 last = NULL; in nxt_sendbuf_mem_coalesce0()
51 if (b->mem.pos != last) { in nxt_sendbuf_mem_coalesce0()
68 last = b->mem.pos + size; in nxt_sendbuf_mem_coalesce0()
90 u_char *last; in nxt_sendbuf_mem_coalesce() local
96 last = NULL; in nxt_sendbuf_mem_coalesce()
168 nxt_off_t size, last; in nxt_sendbuf_file_coalesce() local
188 last = b->file_pos + size; in nxt_sendbuf_file_coalesce()
414 last = &start->next; in nxt_sendbuf_coalesce_completion()
433 *last = b; in nxt_sendbuf_coalesce_completion()
[all …]
H A Dnxt_recvbuf.c13 u_char *last; in nxt_recvbuf_mem_coalesce() local
19 last = NULL; in nxt_recvbuf_mem_coalesce()
28 if (b->mem.free != last) { in nxt_recvbuf_mem_coalesce()
45 last = b->mem.end; in nxt_recvbuf_mem_coalesce()
H A Dnxt_port_rpc.c309 uint8_t last; in nxt_port_rpc_handler() local
319 last = msg->port_msg.last; in nxt_port_rpc_handler()
325 if (last != 0) { in nxt_port_rpc_handler()
350 if (last == 0) { in nxt_port_rpc_handler()
369 uint8_t last; in nxt_port_rpc_remove_peer() local
401 last = 0; in nxt_port_rpc_remove_peer()
403 while (last == 0) { in nxt_port_rpc_remove_peer()
414 msg.port_msg.last = 1; in nxt_port_rpc_remove_peer()
419 last = 1; in nxt_port_rpc_remove_peer()
436 if (msg.port_msg.last == 0) { in nxt_port_rpc_remove_peer()
[all …]
H A Dnxt_log_moderation.c32 if (now != mod->last) { in nxt_log_moderate_allow()
35 mod->last = now; in nxt_log_moderate_allow()
86 mod->last = nxt_thread_time(task->thread); in nxt_log_moderate_timer_handler()
H A Dnxt_array.c102 void *last; in nxt_array_remove() local
104 last = nxt_array_last(array); in nxt_array_remove()
106 if (elt != last) { in nxt_array_remove()
107 nxt_memcpy(elt, last, array->size); in nxt_array_remove()
H A Dnxt_vector.c142 u_char *next, *last, *end; in nxt_vector_remove() local
147 last = end - item_size; in nxt_vector_remove()
149 if (item != last) { in nxt_vector_remove()
H A Dnxt_var.c502 size_t length, last, next; in nxt_var_interpreter() local
550 last = 0; in nxt_var_interpreter()
555 if (next != last) { in nxt_var_interpreter()
556 p = nxt_cpymem(p, &src[last], next - last); in nxt_var_interpreter()
565 last = next + subs[i].length; in nxt_var_interpreter()
568 if (last != var->length) { in nxt_var_interpreter()
569 p = nxt_cpymem(p, &src[last], var->length - last); in nxt_var_interpreter()
H A Dnxt_sendbuf.h50 uint8_t last; /* 1 bit */ member
61 uint8_t last; /* 1 bit */ member
H A Dnxt_http_request.c249 nxt_buf_t *last; in nxt_http_request_create() local
267 last = nxt_mp_zget(mp, NXT_BUF_SYNC_SIZE); in nxt_http_request_create()
268 if (nxt_slow_path(last == NULL)) { in nxt_http_request_create()
272 nxt_buf_set_sync(last); in nxt_http_request_create()
273 nxt_buf_set_last(last); in nxt_http_request_create()
275 last->parent = r; in nxt_http_request_create()
276 r->last = last; in nxt_http_request_create()
777 nxt_buf_t *last; in nxt_http_buf_last() local
779 last = r->last; in nxt_http_buf_last()
780 r->last = NULL; in nxt_http_buf_last()
[all …]
H A Dnxt_log_moderation.h18 nxt_time_t last; member
H A Dnxt_thread_time.h32 nxt_time_t last; member
H A Dnxt_http_chunk_parse.c136 hcp->last = 1; in nxt_http_chunk_parse()
154 if (!hcp->last) { in nxt_http_chunk_parse()
H A Dnxt_tls.h41 nxt_bool_t last);
H A Dnxt_thread_time.c256 update = (s != tsc->last); in nxt_thread_time_string()
343 tsc->last = s; in nxt_thread_time_string()
424 tsc[i].last = -1; in nxt_thread_time_string_cache()
H A Dnxt_list.h21 nxt_list_part_t *last; member
H A Dnxt_conf.c98 nxt_bool_t last; member
470 parse.last = 0; in nxt_conf_get_path()
480 if (parse.last) { in nxt_conf_get_path()
511 } while (parse.last == 0); in nxt_conf_get_path()
833 parse.last = 0; in nxt_conf_op_compile()
873 if (parse.last) { in nxt_conf_op_compile()
1832 u_char *p, ch, *last, *s; in nxt_conf_json_parse_string() local
1948 last = p; in nxt_conf_json_parse_string()
1984 return last + 1; in nxt_conf_json_parse_string()
2076 } while (p != last); in nxt_conf_json_parse_string()
[all …]
/unit/src/java/nginx/unit/websocket/
H A DWsSession.java841 if (last) { in processFrame()
878 onMessage(buf, last); in processFrame()
904 } else if (cr.isUnderflow() && !last) { in processFrame()
905 updateRawFragments(buf, last); in processFrame()
914 if (last) { in processFrame()
918 updateRawFragments(buf, last); in processFrame()
920 onMessage(messageBufferText, last); in processFrame()
933 onMessage(buf.toString(), last); in onMessage() local
943 if (!last && buf.remaining() > 0) { in updateRawFragments()
961 public void onMessage(String text, boolean last) { in onMessage() argument
[all …]
H A DWsRemoteEndpointImplBase.java166 stateMachine.complete(last); in sendPartialBytes()
256 stateMachine.complete(last); in sendMessageBlock()
290 if (!last && opCode != Constants.OPCODE_CONTINUATION) { in sendMessageBlock()
294 if (last && opCode == Constants.OPCODE_CONTINUATION) { in sendMessageBlock()
1007 private void doWrite(boolean last) throws IOException { in doWrite() argument
1012 endpoint.stateMachine.complete(last); in doWrite()
1084 private void doWrite(boolean last) throws IOException { in doWrite() argument
1087 endpoint.sendMessageBlock(buffer, last); in doWrite()
1090 endpoint.stateMachine.complete(last); in doWrite()
1162 public synchronized void complete(boolean last) { in complete() argument
[all …]
H A DWsFrameBase.java376 protected void sendMessageText(boolean last) throws WsIOException { in sendMessageText() argument
390 .onMessage(messageBufferText.toString(), last); in sendMessageText() local
451 boolean last = false; in processDataText()
456 last); in processDataText()
472 } else if (cr.isUnderflow() && !last) { in processDataText()
489 last = true; in processDataText()
566 protected void sendMessageBinary(ByteBuffer msg, boolean last) throws WsIOException { in sendMessageBinary() argument
578 ((MessageHandler.Partial<ByteBuffer>) binaryMsgHandler).onMessage(msg, last); in sendMessageBinary()
/unit/src/java/nginx/unit/websocket/pojo/
H A DPojoMessageHandlerPartialBase.java51 public final void onMessage(T message, boolean last) { in onMessage() argument
59 parameters[indexBoolean] = Boolean.valueOf(last); in onMessage()
/unit/src/java/javax/websocket/
H A DMessageHandler.java30 void onMessage(T messagePart, boolean last); in onMessage() argument
/unit/src/java/
H A Dnxt_jni_Request.c72 jlong req_info_ptr, jobject buf, jint pos, jint len, jbyte opCode, jboolean last);
74 jlong req_info_ptr, jarray arr, jint pos, jint len, jbyte opCode, jboolean last);
754 jlong req_info_ptr, jobject buf, jint pos, jint len, jbyte opCode, jboolean last) in nxt_java_Request_sendWsFrameBuf() argument
762 nxt_unit_websocket_send(req, opCode, last, b + pos, len); in nxt_java_Request_sendWsFrameBuf()
772 jlong req_info_ptr, jarray arr, jint pos, jint len, jbyte opCode, jboolean last) in nxt_java_Request_sendWsFrameArr() argument
784 nxt_unit_websocket_send(req, opCode, last, b + pos, len); in nxt_java_Request_sendWsFrameArr()
/unit/src/java/nginx/unit/
H A DRequest.java1284 private void processWsFrame(ByteBuffer buf, byte opCode, boolean last) in processWsFrame() argument
1289 wsSession.processFrame(buf, opCode, last); in processWsFrame()
1303 public void sendWsFrame(ByteBuffer payload, byte opCode, boolean last, in sendWsFrame() argument
1311 payload.limit() - payload.position(), opCode, last); in sendWsFrame()
1314 payload.limit() - payload.position(), opCode, last); in sendWsFrame()
1319 ByteBuffer buf, int pos, int len, byte opCode, boolean last); in sendWsFrame() argument
1322 byte[] arr, int pos, int len, byte opCode, boolean last); in sendWsFrame() argument

12