Searched refs:recv_q (Results 1 – 5 of 5) sorted by relevance
| /Zephyr-Core-3.5.0/subsys/net/lib/sockets/ |
| D | sockets_packet.c | 75 k_fifo_init(&ctx->recv_q); in zpacket_socket()
94 struct net_pkt *last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zpacket_received_cb()
102 k_fifo_cancel_wait(&ctx->recv_q); in zpacket_received_cb()
115 k_fifo_put(&ctx->recv_q, pkt); in zpacket_received_cb()
306 res = k_fifo_wait_non_empty(&ctx->recv_q, timeout); in zpacket_recvfrom_ctx()
313 pkt = k_fifo_peek_head(&ctx->recv_q); in zpacket_recvfrom_ctx()
315 pkt = k_fifo_get(&ctx->recv_q, timeout); in zpacket_recvfrom_ctx()
|
| D | sockets_can.c | 80 k_fifo_init(&ctx->recv_q); in zcan_socket()
158 k_fifo_peek_tail(&ctx->recv_q); in zcan_received_cb()
166 k_fifo_cancel_wait(&ctx->recv_q); in zcan_received_cb()
178 k_fifo_put(&ctx->recv_q, clone); in zcan_received_cb()
298 ret = k_fifo_wait_non_empty(&ctx->recv_q, timeout); in zcan_recvfrom_ctx()
305 pkt = k_fifo_peek_head(&ctx->recv_q); in zcan_recvfrom_ctx()
319 pkt = k_fifo_get(&ctx->recv_q, timeout); in zcan_recvfrom_ctx()
|
| D | socketpair.c | 50 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()
547 res = k_pipe_put(&remote->recv_q, (void *)buffer, count, in spair_write()
721 res = k_pipe_get(&spair->recv_q, (void *)buffer, count, &bytes_read, in spair_read()
|
| D | sockets.c | 139 while ((p = k_fifo_get(&ctx->recv_q, K_NO_WAIT)) != NULL) { in zsock_flush_queue()
150 k_fifo_cancel_wait(&ctx->recv_q); in zsock_flush_queue()
191 k_fifo_init(&ctx->recv_q); in zsock_socket_internal()
354 k_fifo_init(&new_ctx->recv_q); in zsock_accepted_cb()
394 struct net_pkt *last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zsock_received_cb()
402 k_fifo_cancel_wait(&ctx->recv_q); in zsock_received_cb()
417 k_fifo_put(&ctx->recv_q, pkt); in zsock_received_cb()
619 last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zsock_accept_ctx()
1153 if (k_fifo_is_empty(&ctx->recv_q)) { in zsock_wait_data()
1199 res = fifo_wait_non_empty(&ctx->recv_q, timeout); in zsock_recv_dgram()
[all …]
|
| /Zephyr-Core-3.5.0/include/zephyr/net/ |
| D | net_context.h | 274 struct k_fifo recv_q; member
|
