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.h177 } nxt_port_msg_t; typedef
185 nxt_port_msg_t port_msg;
198 nxt_port_msg_t port_msg;
H A Dnxt_unit.c932 nxt_port_msg_t msg; in nxt_unit_ready()
2618 nxt_port_msg_t msg; in nxt_unit_mmap_buf_send()
3606 nxt_port_msg_t msg; in nxt_unit_send_oosm()
3889 nxt_port_msg_t msg; in nxt_unit_send_mmap()
4077 nxt_port_msg_t msg; in nxt_unit_awake_ctx()
4374 nxt_port_msg_t msg; in nxt_unit_send_shm_ack()
4884 nxt_port_msg_t *port_msg; in nxt_unit_is_read_queue()
4910 nxt_port_msg_t *port_msg; in nxt_unit_is_shm_ack()
4925 nxt_port_msg_t *port_msg; in nxt_unit_is_quit()
5894 nxt_port_msg_t msg; in nxt_unit_port_send()
[all …]
H A Dnxt_router.c5376 nxt_port_msg_t pm; in nxt_router_app_prepare_request()