Lines Matching refs:recv_q
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()
1093 pkt = k_fifo_peek_head(&ctx->recv_q); in zsock_recv_dgram()
1095 pkt = k_fifo_get(&ctx->recv_q, timeout); in zsock_recv_dgram()
1259 pkt = k_fifo_peek_head(&ctx->recv_q); in zsock_recv_stream_immediate()
1291 pkt = k_fifo_get(&ctx->recv_q, K_NO_WAIT); in zsock_recv_stream_immediate()
1305 k_fifo_put(&ctx->recv_q, k_fifo_get(&ctx->recv_q, K_NO_WAIT)); in zsock_recv_stream_immediate()
1519 (*pev)->obj = &ctx->recv_q; in zsock_poll_prepare_ctx()