Home
last modified time | relevance | path

Searched refs:ready (Results 1 – 19 of 19) sorted by relevance

/unit/src/
H A Dnxt_tstr.c45 nxt_work_handler_t ready; member
309 nxt_work_handler_t ready, nxt_work_handler_t error) in nxt_tstr_query_resolve() argument
312 query->ready = ready; in nxt_tstr_query_resolve()
317 query->failed ? query->error : query->ready, in nxt_tstr_query_resolve()
331 query->failed ? query->error : query->ready, in nxt_tstr_query_handle()
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_conn_write.c54 sb.ready = 1; in nxt_conn_io_write()
60 c->socket.write_ready = sb.ready; in nxt_conn_io_write()
212 sb->ready = 0; in nxt_conn_io_sendfile()
230 sb->ready = 0; in nxt_conn_io_sendfile()
331 sb->ready = 0; in nxt_conn_io_writev()
373 sb->ready = 0; in nxt_conn_io_send()
H A Dnxt_thread_pool.h15 nxt_atomic_t ready; member
H A Dnxt_upstream.h24 nxt_upstream_peer_ready_t ready; member
H A Dnxt_tstr.h57 void *data, nxt_work_handler_t ready, nxt_work_handler_t error);
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_sendbuf.h47 uint8_t ready; /* 1 bit */ member
H A Dnxt_unit.c696 ctx_impl->ready = 0; in nxt_unit_ctx_init()
1255 ctx_impl->ready = 1; in nxt_unit_ctx_ready()
1573 port_impl->ready = 0; in nxt_unit_request_check_response_port()
4730 return (ctx_impl->ready in nxt_unit_chk_ready()
4774 if (!ctx_impl->ready) { in nxt_unit_process_pending_rbuf()
5495 old_port_impl->ready = ready; in nxt_unit_add_port()
5510 old_port_impl->ready = ready; in nxt_unit_add_port()
5526 ready = 0; in nxt_unit_add_port()
5578 new_port->ready = ready; in nxt_unit_add_port()
5581 new_port->ready = 0; in nxt_unit_add_port()
[all …]
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_upstream_round_robin.c204 us->state->ready(task, us); in nxt_upstream_round_robin_server_get()
H A Dnxt_kqueue_engine.c923 lev->ready = nxt_min(lev->batch, (uint32_t) lev->socket.kq_available); in nxt_kqueue_listen_handler()
941 lev->ready--; in nxt_kqueue_conn_io_accept()
942 lev->socket.read_ready = (lev->ready != 0); in nxt_kqueue_conn_io_accept()
H A Dnxt_conn.h101 uint32_t ready; member
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_var.c39 nxt_work_handler_t ready; member
H A Dnxt_openssl.c1406 c->socket.write_ready = sb->ready;
1410 sb->ready = c->socket.write_ready;
H A Dnxt_h1proto.c884 goto ready; in nxt_h1p_request_body_read()
996 ready: in nxt_h1p_request_body_read()
/unit/src/java/nginx/unit/websocket/server/
H A DLocalStrings.properties34 wsFrameServer.bytesRead=Read [{0}] bytes into input buffer ready for processing
/unit/
H A DCONTRIBUTING.md58 submit a PR when your changes are tested and ready for review. Again, if you'd