Searched refs:ready (Results 1 – 18 of 18) sorted by relevance
/unit/src/ |
H A D | nxt_thread_pool.c | 65 if (nxt_fast_path(tp->ready)) { in nxt_thread_pool_init() 78 if (!tp->ready) { in nxt_thread_pool_init() 93 tp->ready = 1; in nxt_thread_pool_init() 236 nxt_log_debug(thr->log, "thread pool destroy: %A", tp->ready); in nxt_thread_pool_destroy() 238 if (!tp->ready) { in nxt_thread_pool_destroy()
|
H A D | nxt_conn_write.c | 54 sb.ready = 1; in nxt_conn_io_write() 60 c->socket.write_ready = sb.ready; in nxt_conn_io_write() 205 sb->ready = 0; in nxt_conn_io_sendfile() 223 sb->ready = 0; in nxt_conn_io_sendfile() 324 sb->ready = 0; in nxt_conn_io_writev() 366 sb->ready = 0; in nxt_conn_io_send()
|
H A D | nxt_thread_pool.h | 15 nxt_atomic_t ready; member
|
H A D | nxt_upstream.h | 24 nxt_upstream_peer_ready_t ready; member
|
H A D | nxt_var.h | 45 nxt_work_handler_t ready, nxt_work_handler_t error);
|
H A D | nxt_var.c | 48 nxt_work_handler_t ready; member 525 nxt_work_handler_t ready, nxt_work_handler_t error) in nxt_var_query_resolve() argument 528 query->ready = ready; in nxt_var_query_resolve() 632 query->failed ? query->error : query->ready, in nxt_var_query_finish()
|
H A D | nxt_conn_accept.c | 129 lev->ready = lev->batch; in nxt_conn_listen_handler() 147 lev->ready--; in nxt_conn_io_accept() 148 lev->socket.read_ready = (lev->ready != 0); in nxt_conn_io_accept()
|
H A D | nxt_sendbuf.h | 47 uint8_t ready; /* 1 bit */ member
|
H A D | nxt_unit.c | 682 ctx_impl->ready = 0; in nxt_unit_ctx_init() 1241 ctx_impl->ready = 1; in nxt_unit_ctx_ready() 1559 port_impl->ready = 0; in nxt_unit_request_check_response_port() 4715 return (ctx_impl->ready in nxt_unit_chk_ready() 4759 if (!ctx_impl->ready) { in nxt_unit_process_pending_rbuf() 5480 old_port_impl->ready = ready; in nxt_unit_add_port() 5495 old_port_impl->ready = ready; in nxt_unit_add_port() 5511 ready = 0; in nxt_unit_add_port() 5563 new_port->ready = ready; in nxt_unit_add_port() 5566 new_port->ready = 0; in nxt_unit_add_port() [all …]
|
H A D | nxt_http_proxy.c | 47 .ready = nxt_http_proxy_upstream_ready, 162 us->state->ready(task, us); in nxt_http_proxy_server_get()
|
H A D | nxt_upstream_round_robin.c | 204 us->state->ready(task, us); in nxt_upstream_round_robin_server_get()
|
H A D | nxt_kqueue_engine.c | 922 lev->ready = nxt_min(lev->batch, (uint32_t) lev->socket.kq_available); in nxt_kqueue_listen_handler() 940 lev->ready--; in nxt_kqueue_conn_io_accept() 941 lev->socket.read_ready = (lev->ready != 0); in nxt_kqueue_conn_io_accept()
|
H A D | nxt_conn.h | 101 uint32_t ready; member
|
H A D | nxt_epoll_engine.c | 1019 lev->ready--; in nxt_epoll_conn_io_accept4() 1020 lev->socket.read_ready = (lev->ready != 0); in nxt_epoll_conn_io_accept4()
|
H A D | nxt_openssl.c | 1406 c->socket.write_ready = sb->ready; 1410 sb->ready = c->socket.write_ready;
|
H A D | nxt_h1proto.c | 874 goto ready; in nxt_h1p_request_body_read() 986 ready: in nxt_h1p_request_body_read()
|
/unit/src/java/nginx/unit/websocket/server/ |
H A D | LocalStrings.properties | 34 wsFrameServer.bytesRead=Read [{0}] bytes into input buffer ready for processing
|
/unit/ |
H A D | CONTRIBUTING.md | 58 submit a PR when your changes are tested and ready for review. Again, if you'd
|