Home
last modified time | relevance | path

Searched refs:nxt_port_msg_t (Results 1 – 4 of 4) sorted by relevance

/unit/src/
H A Dnxt_port_socket.c14 (int) (NXT_PORT_QUEUE_MSG_SIZE - sizeof(nxt_port_msg_t))
169 nxt_port_msg_t pm; in nxt_port_socket_write2()
405 iov[0].iov_len = sizeof(nxt_port_msg_t); in nxt_port_write_handler()
753 iov[0].iov_len = sizeof(nxt_port_msg_t); in nxt_port_read_handler()
895 if (n >= (ssize_t) sizeof(nxt_port_msg_t)) { in nxt_port_queue_read_handler()
898 if (n > (ssize_t) sizeof(nxt_port_msg_t)) { in nxt_port_queue_read_handler()
900 n - sizeof(nxt_port_msg_t)); in nxt_port_queue_read_handler()
905 iov[0].iov_len = sizeof(nxt_port_msg_t); in nxt_port_queue_read_handler()
928 if (n == (ssize_t) sizeof(nxt_port_msg_t) in nxt_port_queue_read_handler()
1177 if (nxt_slow_path(msg->size < sizeof(nxt_port_msg_t))) { in nxt_port_read_msg_process()
[all …]
H A Dnxt_port.h191 } nxt_port_msg_t; typedef
199 nxt_port_msg_t port_msg;
212 nxt_port_msg_t port_msg;
H A Dnxt_unit.c946 nxt_port_msg_t msg; in nxt_unit_ready()
2633 nxt_port_msg_t msg; in nxt_unit_mmap_buf_send()
3621 nxt_port_msg_t msg; in nxt_unit_send_oosm()
3904 nxt_port_msg_t msg; in nxt_unit_send_mmap()
4092 nxt_port_msg_t msg; in nxt_unit_awake_ctx()
4389 nxt_port_msg_t msg; in nxt_unit_send_shm_ack()
4899 nxt_port_msg_t *port_msg; in nxt_unit_is_read_queue()
4925 nxt_port_msg_t *port_msg; in nxt_unit_is_shm_ack()
4940 nxt_port_msg_t *port_msg; in nxt_unit_is_quit()
5909 nxt_port_msg_t msg; in nxt_unit_port_send()
[all …]
H A Dnxt_router.c5245 nxt_port_msg_t pm; in nxt_router_app_prepare_request()