/unit/go/ |
H A D | nxt_cgo_lib.c | 14 const void *buf, size_t buf_size, const void *oob, size_t oob_size); 16 void *buf, size_t buf_size, void *oob, size_t *oob_size); 52 const void *buf, size_t buf_size, const void *oob, size_t oob_size) in nxt_cgo_port_send() argument 55 (void *) buf, buf_size, (void *) oob, oob_size); in nxt_cgo_port_send() 61 void *buf, size_t buf_size, void *oob, size_t *oob_size) in nxt_cgo_port_recv() argument 64 buf, buf_size, oob, oob_size); in nxt_cgo_port_recv()
|
H A D | port.go | 144 oob unsafe.Pointer, oob_size C.int) C.ssize_t { 159 GoBytes(oob, oob_size), nil) 172 oob unsafe.Pointer, oob_size *C.size_t) C.ssize_t { 187 GoBytes(oob, C.int(*oob_size)))
|
/unit/src/ |
H A D | nxt_port_socket.c | 737 nxt_recv_oob_t oob; in nxt_port_read_handler() local 758 n = nxt_socketpair_recv(&port->socket, iov, 2, &oob); in nxt_port_read_handler() 764 ret = nxt_socket_msg_oob_get(&oob, msg.fd, in nxt_port_read_handler() 819 nxt_recv_oob_t oob; in nxt_port_queue_read_handler() local 910 n = nxt_socketpair_recv(&port->socket, iov, 2, &oob); in nxt_port_queue_read_handler() 916 ret = nxt_socket_msg_oob_get(&oob, msg.fd, in nxt_port_queue_read_handler()
|
H A D | nxt_socket.h | 118 nxt_iobuf_t *iob, nxt_uint_t niob, void *oob);
|
H A D | nxt_socket_msg.c | 12 const nxt_send_oob_t *oob) in nxt_sendmsg() argument 23 if (oob != NULL && oob->size != 0) { in nxt_sendmsg() 24 msg.msg_control = (void *) oob->buf; in nxt_sendmsg() 25 msg.msg_controllen = oob->size; in nxt_sendmsg() 38 nxt_recv_oob_t *oob) in nxt_recvmsg() argument 47 msg.msg_control = oob->buf; in nxt_recvmsg() 48 msg.msg_controllen = sizeof(oob->buf); in nxt_recvmsg() 53 oob->size = msg.msg_controllen; in nxt_recvmsg()
|
H A D | nxt_socket_msg.h | 62 nxt_uint_t niob, const nxt_send_oob_t *oob); 87 nxt_socket_msg_oob_init(nxt_send_oob_t *oob, int *fds) in nxt_socket_msg_oob_init() argument 93 cmsg = (struct cmsghdr *) (oob->buf); in nxt_socket_msg_oob_init() 108 oob->size = 0; in nxt_socket_msg_oob_init() 117 cmsg = (struct cmsghdr *) (oob->buf + oob->size); in nxt_socket_msg_oob_init() 136 oob->size += CMSG_SPACE(nfds * sizeof(int)); in nxt_socket_msg_oob_init() 147 msg.msg_control = oob->buf; in nxt_socket_msg_oob_get_fds() 148 msg.msg_controllen = oob->size; in nxt_socket_msg_oob_get_fds() 178 if (oob->size == 0) { in nxt_socket_msg_oob_get() 186 msg.msg_control = oob->buf; in nxt_socket_msg_oob_get() [all …]
|
H A D | nxt_socketpair.c | 91 nxt_send_oob_t oob; in nxt_socketpair_send() local 93 nxt_socket_msg_oob_init(&oob, fd); in nxt_socketpair_send() 96 n = nxt_sendmsg(ev->fd, iob, niob, &oob); in nxt_socketpair_send() 142 void *oob) in nxt_socketpair_recv() argument 148 n = nxt_recvmsg(ev->fd, iob, niob, oob); in nxt_socketpair_recv() 153 ev->fd, niob, ((nxt_recv_oob_t *) oob)->size, n); in nxt_socketpair_recv()
|
H A D | nxt_unit.c | 945 nxt_send_oob_t oob; in nxt_unit_ready() local 2797 rbuf->oob.size = 0; in nxt_unit_read_buf_get() 3903 nxt_send_oob_t oob; in nxt_unit_send_mmap() local 5348 nxt_send_oob_t oob; in nxt_unit_send_port() local 5916 if (port_impl->queue != NULL && (oob == NULL || oob->size == 0) in nxt_unit_port_send() 5975 oob != NULL ? oob->buf : NULL, in nxt_unit_port_send() 5976 oob != NULL ? oob->size : 0); in nxt_unit_port_send() 6025 (oob != NULL ? (int) oob->size : 0), (int) n); in nxt_unit_sendmsg() 6137 rbuf->oob.size = 0; in nxt_unit_ctx_port_recv() 6148 dst->oob.size = src->oob.size; in nxt_unit_rbuf_cpy() [all …]
|
H A D | nxt_unit.h | 154 const void *oob, size_t oob_size); 158 void *buf, size_t buf_size, void *oob, size_t *oob_size);
|