Searched refs:recv_q (Results 1 – 5 of 5) sorted by relevance
| /Zephyr-Core-2.7.6/subsys/net/lib/sockets/ |
| D | sockets_packet.c | 71 k_fifo_init(&ctx->recv_q); in zpacket_socket()
90 struct net_pkt *last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zpacket_received_cb()
98 k_fifo_cancel_wait(&ctx->recv_q); in zpacket_received_cb()
111 k_fifo_put(&ctx->recv_q, pkt); in zpacket_received_cb()
216 res = k_fifo_wait_non_empty(&ctx->recv_q, timeout); in zpacket_recvfrom_ctx()
223 pkt = k_fifo_peek_head(&ctx->recv_q); in zpacket_recvfrom_ctx()
225 pkt = k_fifo_get(&ctx->recv_q, timeout); in zpacket_recvfrom_ctx()
|
| D | sockets_can.c | 73 k_fifo_init(&ctx->recv_q); in zcan_socket()
139 k_fifo_peek_tail(&ctx->recv_q); in zcan_received_cb()
147 k_fifo_cancel_wait(&ctx->recv_q); in zcan_received_cb()
161 k_fifo_put(&ctx->recv_q, clone); in zcan_received_cb()
275 ret = k_fifo_wait_non_empty(&ctx->recv_q, timeout); in zcan_recvfrom_ctx()
282 pkt = k_fifo_peek_head(&ctx->recv_q); in zcan_recvfrom_ctx()
284 pkt = k_fifo_get(&ctx->recv_q, timeout); in zcan_recvfrom_ctx()
|
| D | sockets.c | 136 while ((p = k_fifo_get(&ctx->recv_q, K_NO_WAIT)) != NULL) { in zsock_flush_queue()
147 k_fifo_cancel_wait(&ctx->recv_q); in zsock_flush_queue()
184 k_fifo_init(&ctx->recv_q); in zsock_socket_internal()
332 k_fifo_init(&new_ctx->recv_q); in zsock_accepted_cb()
364 struct net_pkt *last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zsock_received_cb()
372 k_fifo_cancel_wait(&ctx->recv_q); in zsock_received_cb()
391 k_fifo_put(&ctx->recv_q, pkt); in zsock_received_cb()
539 last_pkt = k_fifo_peek_tail(&ctx->recv_q); in zsock_accept_ctx()
1006 if (k_fifo_is_empty(&ctx->recv_q)) { in wait_data()
1045 res = fifo_wait_non_empty(&ctx->recv_q, timeout); in zsock_recv_dgram()
[all …]
|
| D | socketpair.c | 55 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()
244 k_pipe_init(&spair->recv_q, spair->buf, sizeof(spair->buf)); in spair_new()
541 res = k_pipe_put(&remote->recv_q, (void *)buffer, count, in spair_write()
718 res = k_pipe_get(&spair->recv_q, (void *)buffer, count, &bytes_read, in spair_read()
|
| /Zephyr-Core-2.7.6/include/net/ |
| D | net_context.h | 274 struct k_fifo recv_q; member
|
