Home
last modified time | relevance | path

Searched refs:recv_q (Results 1 – 5 of 5) sorted by relevance

/Zephyr-latest/subsys/net/lib/sockets/
Dsockets_packet.c79 k_fifo_init(&ctx->recv_q); in zpacket_socket()
98 struct net_pkt *last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zpacket_received_cb()
106 k_fifo_cancel_wait(&ctx->recv_q); in zpacket_received_cb()
119 k_fifo_put(&ctx->recv_q, pkt); in zpacket_received_cb()
314 res = k_fifo_wait_non_empty(&ctx->recv_q, timeout); in zpacket_recvfrom_ctx()
321 pkt = k_fifo_peek_head(&ctx->recv_q); in zpacket_recvfrom_ctx()
323 pkt = k_fifo_get(&ctx->recv_q, timeout); in zpacket_recvfrom_ctx()
Dsockets_can.c76 k_fifo_init(&ctx->recv_q); in zcan_socket()
154 k_fifo_peek_tail(&ctx->recv_q); in zcan_received_cb()
162 k_fifo_cancel_wait(&ctx->recv_q); in zcan_received_cb()
174 k_fifo_put(&ctx->recv_q, clone); in zcan_received_cb()
294 ret = k_fifo_wait_non_empty(&ctx->recv_q, timeout); in zcan_recvfrom_ctx()
301 pkt = k_fifo_peek_head(&ctx->recv_q); in zcan_recvfrom_ctx()
315 pkt = k_fifo_get(&ctx->recv_q, timeout); in zcan_recvfrom_ctx()
Dsockets_inet.c63 while ((p = k_fifo_get(&ctx->recv_q, K_NO_WAIT)) != NULL) { in zsock_flush_queue()
74 k_fifo_cancel_wait(&ctx->recv_q); in zsock_flush_queue()
114 k_fifo_init(&ctx->recv_q); in zsock_socket_internal()
191 k_fifo_init(&new_ctx->recv_q); in zsock_accepted_cb()
231 struct net_pkt *last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zsock_received_cb()
239 k_fifo_cancel_wait(&ctx->recv_q); in zsock_received_cb()
254 k_fifo_put(&ctx->recv_q, pkt); in zsock_received_cb()
466 last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zsock_accept_ctx()
908 if (k_fifo_is_empty(&ctx->recv_q)) { in zsock_wait_data()
1081 res = fifo_wait_non_empty(&ctx->recv_q, timeout); in zsock_recv_dgram()
[all …]
Dsocketpair.c50 struct k_pipe recv_q; /**< receive queue of local endpoint */ member
109 return k_pipe_write_avail(&remote->recv_q); in spair_write_avail()
120 return k_pipe_read_avail(&spair->recv_q); in spair_read_avail()
253 k_pipe_init(&spair->recv_q, spair->buf, sizeof(spair->buf)); in spair_new()
553 res = k_pipe_put(&remote->recv_q, (void *)buffer, count, in spair_write()
727 res = k_pipe_get(&spair->recv_q, (void *)buffer, count, &bytes_read, in spair_read()
/Zephyr-latest/include/zephyr/net/
Dnet_context.h280 struct k_fifo recv_q; member