Home
last modified time | relevance | path

Searched refs:oob (Results 1 – 9 of 9) sorted by path

/unit/go/
H A Dnxt_cgo_lib.c14 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 Dport.go144 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 Dnxt_port_socket.c737 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 Dnxt_socket.h118 nxt_iobuf_t *iob, nxt_uint_t niob, void *oob);
H A Dnxt_socket_msg.c12 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 Dnxt_socket_msg.h62 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 Dnxt_socketpair.c91 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 Dnxt_unit.c945 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 Dnxt_unit.h154 const void *oob, size_t oob_size);
158 void *buf, size_t buf_size, void *oob, size_t *oob_size);