/unit/src/test/ |
H A D | nxt_malloc_test.c | 71 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 D | nxt_list.c | 18 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 D | nxt_sendbuf.c | 20 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 D | nxt_recvbuf.c | 13 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 D | nxt_port_rpc.c | 309 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 D | nxt_log_moderation.c | 32 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 D | nxt_array.c | 102 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 D | nxt_vector.c | 142 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 D | nxt_var.c | 502 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 D | nxt_sendbuf.h | 50 uint8_t last; /* 1 bit */ member 61 uint8_t last; /* 1 bit */ member
|
H A D | nxt_http_request.c | 249 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 D | nxt_log_moderation.h | 18 nxt_time_t last; member
|
H A D | nxt_thread_time.h | 32 nxt_time_t last; member
|
H A D | nxt_http_chunk_parse.c | 136 hcp->last = 1; in nxt_http_chunk_parse() 154 if (!hcp->last) { in nxt_http_chunk_parse()
|
H A D | nxt_tls.h | 41 nxt_bool_t last);
|
H A D | nxt_thread_time.c | 256 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 D | nxt_list.h | 21 nxt_list_part_t *last; member
|
H A D | nxt_conf.c | 98 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 D | WsSession.java | 841 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 D | WsRemoteEndpointImplBase.java | 166 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 D | WsFrameBase.java | 376 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 D | PojoMessageHandlerPartialBase.java | 51 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 D | MessageHandler.java | 30 void onMessage(T messagePart, boolean last); in onMessage() argument
|
/unit/src/java/ |
H A D | nxt_jni_Request.c | 72 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 D | Request.java | 1284 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
|