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()
4838 if (lib->callbacks.data_handler == NULL) { in nxt_unit_process_ready_req()
4843 lib->callbacks.request_handler(&req_impl->req); in nxt_unit_process_ready_req()
5493 if (lib->callbacks.add_port == NULL && ready) { in nxt_unit_add_port()
5504 if (lib->callbacks.add_port != NULL && ready) { in nxt_unit_add_port()
5505 lib->callbacks.add_port(ctx, old_port); in nxt_unit_add_port()
5576 if (lib->callbacks.add_port == NULL) { in nxt_unit_add_port()
5593 if (lib->callbacks.add_port != NULL && new_port != NULL && ready) { in nxt_unit_add_port()
5594 lib->callbacks.add_port(ctx, &new_port->port); in nxt_unit_add_port()
5664 if (lib->callbacks.remove_port != NULL && port != NULL) { in nxt_unit_remove_port()
5665 lib->callbacks.remove_port(&lib->unit, ctx, port); in nxt_unit_remove_port()
5713 if (lib->callbacks.remove_pid != NULL) { in nxt_unit_remove_pid()
5714 lib->callbacks.remove_pid(&lib->unit, pid); in nxt_unit_remove_pid()
5741 if (lib->callbacks.remove_port != NULL) { in nxt_unit_remove_process()
5742 lib->callbacks.remove_port(&lib->unit, NULL, &port->port); in nxt_unit_remove_process()
5781 cb = &lib->callbacks; in nxt_unit_quit()
5935 if (lib->callbacks.port_send == NULL) { in nxt_unit_port_send()
5944 ret = lib->callbacks.port_send(ctx, port, &msg, in nxt_unit_port_send()
5972 if (lib->callbacks.port_send != NULL) { in nxt_unit_port_send()
5973 ret = lib->callbacks.port_send(ctx, port, buf, buf_size, in nxt_unit_port_send()
6200 if (lib->callbacks.port_recv != NULL) { in nxt_unit_port_recv()
6203 rbuf->size = lib->callbacks.port_recv(ctx, port, in nxt_unit_port_recv()