Lines Matching refs:callbacks

353     nxt_unit_callbacks_t     callbacks;  member
591 if (nxt_slow_path(init->callbacks.request_handler == NULL)) { in nxt_unit_create()
613 lib->callbacks = init->callbacks; in nxt_unit_create()
1260 if (&lib->main_ctx == ctx_impl && lib->callbacks.ready_handler != NULL) { in nxt_unit_ctx_ready()
1261 return lib->callbacks.ready_handler(ctx); in nxt_unit_ctx_ready()
1274 if (lib->callbacks.add_port != NULL) { in nxt_unit_ctx_ready()
1275 lib->callbacks.add_port(ctx, lib->shared_port); in nxt_unit_ctx_ready()
1396 if (lib->callbacks.data_handler == NULL) { in nxt_unit_process_req_headers()
1402 lib->callbacks.request_handler(req); in nxt_unit_process_req_headers()
1452 if (lib->callbacks.data_handler != NULL) { in nxt_unit_process_req_body()
1453 lib->callbacks.data_handler(req); in nxt_unit_process_req_body()
1459 lib->callbacks.request_handler(req); in nxt_unit_process_req_body()
1639 cb = &lib->callbacks; in nxt_unit_process_websocket()
1733 cb = &lib->callbacks; in nxt_unit_process_shm_ack()
4839 if (lib->callbacks.data_handler == NULL) { in nxt_unit_process_ready_req()
4844 lib->callbacks.request_handler(&req_impl->req); in nxt_unit_process_ready_req()
5494 if (lib->callbacks.add_port == NULL && ready) { in nxt_unit_add_port()
5505 if (lib->callbacks.add_port != NULL && ready) { in nxt_unit_add_port()
5506 lib->callbacks.add_port(ctx, old_port); in nxt_unit_add_port()
5577 if (lib->callbacks.add_port == NULL) { in nxt_unit_add_port()
5594 if (lib->callbacks.add_port != NULL && new_port != NULL && ready) { in nxt_unit_add_port()
5595 lib->callbacks.add_port(ctx, &new_port->port); in nxt_unit_add_port()
5665 if (lib->callbacks.remove_port != NULL && port != NULL) { in nxt_unit_remove_port()
5666 lib->callbacks.remove_port(&lib->unit, ctx, port); in nxt_unit_remove_port()
5714 if (lib->callbacks.remove_pid != NULL) { in nxt_unit_remove_pid()
5715 lib->callbacks.remove_pid(&lib->unit, pid); in nxt_unit_remove_pid()
5742 if (lib->callbacks.remove_port != NULL) { in nxt_unit_remove_process()
5743 lib->callbacks.remove_port(&lib->unit, NULL, &port->port); in nxt_unit_remove_process()
5782 cb = &lib->callbacks; in nxt_unit_quit()
5936 if (lib->callbacks.port_send == NULL) { in nxt_unit_port_send()
5945 ret = lib->callbacks.port_send(ctx, port, &msg, in nxt_unit_port_send()
5973 if (lib->callbacks.port_send != NULL) { in nxt_unit_port_send()
5974 ret = lib->callbacks.port_send(ctx, port, buf, buf_size, in nxt_unit_port_send()
6201 if (lib->callbacks.port_recv != NULL) { in nxt_unit_port_recv()
6204 rbuf->size = lib->callbacks.port_recv(ctx, port, in nxt_unit_port_recv()