Searched refs:recv_q (Results 1 – 5 of 5) sorted by relevance
| /Zephyr-latest/subsys/net/lib/sockets/ |
| D | sockets_packet.c | 79 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()
|
| D | sockets_can.c | 76 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()
|
| D | socketpair.c | 50 struct ring_buf recv_q; member
109 return ring_buf_space_get(&remote->recv_q); in spair_write_avail()
120 return ring_buf_size_get(&spair->recv_q); in spair_read_avail()
253 ring_buf_init(&spair->recv_q, sizeof(spair->buf), spair->buf); in spair_new()
553 bytes_written = ring_buf_put(&remote->recv_q, (void *)buffer, count); in spair_write()
724 bytes_read = ring_buf_get(&spair->recv_q, (void *)buffer, count); in spair_read()
|
| D | sockets_inet.c | 63 while ((p = k_fifo_get(&ctx->recv_q, K_NO_WAIT)) != NULL) { in zsock_flush_queue()
79 k_fifo_cancel_wait(&ctx->recv_q); in zsock_flush_queue()
119 k_fifo_init(&ctx->recv_q); in zsock_socket_internal()
196 k_fifo_init(&new_ctx->recv_q); in zsock_accepted_cb()
236 struct net_pkt *last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zsock_received_cb()
244 k_fifo_cancel_wait(&ctx->recv_q); in zsock_received_cb()
259 k_fifo_put(&ctx->recv_q, pkt); in zsock_received_cb()
471 last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zsock_accept_ctx()
913 if (k_fifo_is_empty(&ctx->recv_q)) { in zsock_wait_data()
1086 res = fifo_wait_non_empty(&ctx->recv_q, timeout); in zsock_recv_dgram()
[all …]
|
| /Zephyr-latest/include/zephyr/net/ |
| D | net_context.h | 280 struct k_fifo recv_q; member
|
