Home
last modified time | relevance | path

Searched refs:ready (Results 1 – 18 of 18) sorted by path

/unit/
H A DCONTRIBUTING.md58 submit a PR when your changes are tested and ready for review. Again, if you'd
/unit/src/java/nginx/unit/websocket/server/
H A DLocalStrings.properties34 wsFrameServer.bytesRead=Read [{0}] bytes into input buffer ready for processing
/unit/src/
H A Dnxt_conn.h101 uint32_t ready; member
H A Dnxt_conn_accept.c129 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 Dnxt_conn_write.c54 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 Dnxt_epoll_engine.c1019 lev->ready--; in nxt_epoll_conn_io_accept4()
1020 lev->socket.read_ready = (lev->ready != 0); in nxt_epoll_conn_io_accept4()
H A Dnxt_h1proto.c874 goto ready; in nxt_h1p_request_body_read()
986 ready: in nxt_h1p_request_body_read()
H A Dnxt_http_proxy.c47 .ready = nxt_http_proxy_upstream_ready,
162 us->state->ready(task, us); in nxt_http_proxy_server_get()
H A Dnxt_kqueue_engine.c922 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 Dnxt_openssl.c1406 c->socket.write_ready = sb->ready;
1410 sb->ready = c->socket.write_ready;
H A Dnxt_sendbuf.h47 uint8_t ready; /* 1 bit */ member
H A Dnxt_thread_pool.c65 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 Dnxt_thread_pool.h15 nxt_atomic_t ready; member
H A Dnxt_unit.c682 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 Dnxt_upstream.h24 nxt_upstream_peer_ready_t ready; member
H A Dnxt_upstream_round_robin.c204 us->state->ready(task, us); in nxt_upstream_round_robin_server_get()
H A Dnxt_var.c41 nxt_work_handler_t ready; member
666 nxt_work_handler_t ready, nxt_work_handler_t error) in nxt_var_query_resolve() argument
669 query->ready = ready; in nxt_var_query_resolve()
674 query->failed ? query->error : query->ready, in nxt_var_query_resolve()
688 query->failed ? query->error : query->ready, in nxt_var_query_handle()
H A Dnxt_var.h65 nxt_work_handler_t ready, nxt_work_handler_t error);