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.c | 41 nxt_work_handler_t ready; member
655 nxt_work_handler_t ready, nxt_work_handler_t error) in nxt_var_query_resolve() argument
658 query->ready = ready; in nxt_var_query_resolve()
663 query->failed ? query->error : query->ready, in nxt_var_query_resolve()
677 query->failed ? query->error : query->ready, in nxt_var_query_handle()
|
| H A D | nxt_var.h | 65 nxt_work_handler_t ready, nxt_work_handler_t error);
|
| 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 | 696 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()
4729 return (ctx_impl->ready in nxt_unit_chk_ready()
4773 if (!ctx_impl->ready) { in nxt_unit_process_pending_rbuf()
5494 old_port_impl->ready = ready; in nxt_unit_add_port()
5509 old_port_impl->ready = ready; in nxt_unit_add_port()
5525 ready = 0; in nxt_unit_add_port()
5577 new_port->ready = ready; in nxt_unit_add_port()
5580 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
|