Lines Matching refs:callbacks

353     nxt_unit_callbacks_t     callbacks;  member
608 lib->callbacks = init->callbacks; in nxt_unit_create()
633 cb = &lib->callbacks; in nxt_unit_create()
1246 if (&lib->main_ctx == ctx_impl && lib->callbacks.ready_handler != NULL) { in nxt_unit_ctx_ready()
1247 return lib->callbacks.ready_handler(ctx); in nxt_unit_ctx_ready()
1260 if (lib->callbacks.add_port != NULL) { in nxt_unit_ctx_ready()
1261 lib->callbacks.add_port(ctx, lib->shared_port); in nxt_unit_ctx_ready()
1382 if (lib->callbacks.data_handler == NULL) { in nxt_unit_process_req_headers()
1388 lib->callbacks.request_handler(req); in nxt_unit_process_req_headers()
1438 if (lib->callbacks.data_handler != NULL) { in nxt_unit_process_req_body()
1439 lib->callbacks.data_handler(req); in nxt_unit_process_req_body()
1445 lib->callbacks.request_handler(req); in nxt_unit_process_req_body()
1625 cb = &lib->callbacks; in nxt_unit_process_websocket()
1719 cb = &lib->callbacks; in nxt_unit_process_shm_ack()
4824 if (lib->callbacks.data_handler == NULL) { in nxt_unit_process_ready_req()
4829 lib->callbacks.request_handler(&req_impl->req); in nxt_unit_process_ready_req()
5479 if (lib->callbacks.add_port == NULL && ready) { in nxt_unit_add_port()
5490 if (lib->callbacks.add_port != NULL && ready) { in nxt_unit_add_port()
5491 lib->callbacks.add_port(ctx, old_port); in nxt_unit_add_port()
5562 if (lib->callbacks.add_port == NULL) { in nxt_unit_add_port()
5579 if (lib->callbacks.add_port != NULL && new_port != NULL && ready) { in nxt_unit_add_port()
5580 lib->callbacks.add_port(ctx, &new_port->port); in nxt_unit_add_port()
5650 if (lib->callbacks.remove_port != NULL && port != NULL) { in nxt_unit_remove_port()
5651 lib->callbacks.remove_port(&lib->unit, ctx, port); in nxt_unit_remove_port()
5699 if (lib->callbacks.remove_pid != NULL) { in nxt_unit_remove_pid()
5700 lib->callbacks.remove_pid(&lib->unit, pid); in nxt_unit_remove_pid()
5727 if (lib->callbacks.remove_port != NULL) { in nxt_unit_remove_process()
5728 lib->callbacks.remove_port(&lib->unit, NULL, &port->port); in nxt_unit_remove_process()
5767 cb = &lib->callbacks; in nxt_unit_quit()
5921 if (lib->callbacks.port_send == NULL) { in nxt_unit_port_send()
5930 ret = lib->callbacks.port_send(ctx, port, &msg, in nxt_unit_port_send()
5958 if (lib->callbacks.port_send != NULL) { in nxt_unit_port_send()
5959 ret = lib->callbacks.port_send(ctx, port, buf, buf_size, in nxt_unit_port_send()
6186 if (lib->callbacks.port_recv != NULL) { in nxt_unit_port_recv()
6189 rbuf->size = lib->callbacks.port_recv(ctx, port, in nxt_unit_port_recv()