| /Zephyr-latest/tests/net/ieee802154/custom_l2/src/ |
| D | main.c | 20 struct net_pkt *rx_pkt; member
26 test_data.rx_pkt = pkt; in custom_l2_recv()
98 struct net_pkt *rx_pkt; in ZTEST() local
105 rx_pkt = net_pkt_rx_alloc_with_buffer(iface, sizeof(TEST_PAYLOAD), in ZTEST()
107 zassert_not_null(rx_pkt, "Failed to allocate packet"); in ZTEST()
109 ret = net_pkt_write(rx_pkt, TEST_PAYLOAD, sizeof(TEST_PAYLOAD)); in ZTEST()
112 ret = net_recv_data(iface, rx_pkt); in ZTEST()
114 zassert_equal(rx_pkt, test_data.rx_pkt, "RX packet did not reach L2"); in ZTEST()
116 net_pkt_unref(rx_pkt); in ZTEST()
|
| /Zephyr-latest/subsys/modem/ |
| D | modem_ppp.c | 234 ppp->rx_pkt = net_pkt_rx_alloc_with_buffer(ppp->iface, in modem_ppp_process_received_byte()
237 if (ppp->rx_pkt == NULL) { in modem_ppp_process_received_byte()
245 net_pkt_cursor_init(ppp->rx_pkt); in modem_ppp_process_received_byte()
254 LOG_DBG("Received PPP frame (len %zu)", net_pkt_get_len(ppp->rx_pkt)); in modem_ppp_process_received_byte()
257 net_pkt_remove_tail(ppp->rx_pkt, MODEM_PPP_FRAME_TAIL_SIZE); in modem_ppp_process_received_byte()
258 net_pkt_set_ppp(ppp->rx_pkt, true); in modem_ppp_process_received_byte()
260 if (net_recv_data(ppp->iface, ppp->rx_pkt) < 0) { in modem_ppp_process_received_byte()
262 net_pkt_unref(ppp->rx_pkt); in modem_ppp_process_received_byte()
265 ppp->rx_pkt = NULL; in modem_ppp_process_received_byte()
271 if (net_pkt_available_buffer(ppp->rx_pkt) == 1) { in modem_ppp_process_received_byte()
[all …]
|
| /Zephyr-latest/include/zephyr/mctp/ |
| D | mctp_uart.h | 27 struct mctp_pktbuf *rx_pkt; member
81 .rx_pkt = NULL, \
|
| /Zephyr-latest/subsys/mctp/ |
| D | mctp_uart.c | 50 struct mctp_pktbuf *pkt = uart->rx_pkt; in mctp_uart_finish_pkt()
59 uart->rx_pkt = NULL; in mctp_uart_finish_pkt()
64 __ASSERT_NO_MSG(uart->rx_pkt == NULL); in mctp_uart_start_pkt()
66 uart->rx_pkt = mctp_pktbuf_alloc(&uart->binding, len); in mctp_uart_start_pkt()
68 __ASSERT_NO_MSG(uart->rx_pkt); in mctp_uart_start_pkt()
107 struct mctp_pktbuf *pkt = uart->rx_pkt; in mctp_uart_consume()
154 pkt = uart->rx_pkt; in mctp_uart_consume()
|
| /Zephyr-latest/drivers/ethernet/ |
| D | eth_dwmac.c | 286 if (p->rx_pkt) { in dwmac_receive()
289 net_pkt_unref(p->rx_pkt); in dwmac_receive()
291 p->rx_pkt = net_pkt_rx_alloc_on_iface(p->iface, K_NO_WAIT); in dwmac_receive()
292 if (!p->rx_pkt) { in dwmac_receive()
298 if (!p->rx_pkt) { in dwmac_receive()
309 net_pkt_frag_add(p->rx_pkt, frag); in dwmac_receive()
316 net_pkt_get_len(p->rx_pkt), in dwmac_receive()
317 net_pkt_get_nbfrags(p->rx_pkt)); in dwmac_receive()
318 net_recv_data(p->iface, p->rx_pkt); in dwmac_receive()
322 net_pkt_unref(p->rx_pkt); in dwmac_receive()
[all …]
|
| D | eth_sensry_sy1xx_mac.c | 535 struct net_pkt *rx_pkt; in sy1xx_mac_receive_data() local
538 rx_pkt = net_pkt_alloc_with_buffer(data->iface, len, AF_UNSPEC, 0, K_FOREVER); in sy1xx_mac_receive_data()
539 if (rx_pkt == NULL) { in sy1xx_mac_receive_data()
545 if (net_pkt_write(rx_pkt, rx, len)) { in sy1xx_mac_receive_data()
547 net_pkt_unref(rx_pkt); in sy1xx_mac_receive_data()
552 ret = net_recv_data(data->iface, rx_pkt); in sy1xx_mac_receive_data()
|
| D | eth_dwmac_priv.h | 65 struct net_pkt *rx_pkt; member
|
| /Zephyr-latest/drivers/wifi/winc1500/ |
| D | wifi_winc1500.c | 142 struct net_pkt *rx_pkt; member
530 sock_data->rx_pkt = net_pkt_rx_alloc_on_iface(w1500_data.iface, in prepare_pkt()
532 if (!sock_data->rx_pkt) { in prepare_pkt()
541 net_pkt_unref(sock_data->rx_pkt); in prepare_pkt()
545 net_pkt_append_buffer(sock_data->rx_pkt, sock_data->pkt_buf); in prepare_pkt()
599 net_pkt_unref(sd->rx_pkt); in winc1500_put()
809 net_pkt_cursor_init(sd->rx_pkt); in handle_socket_msg_recv()
813 sd->rx_pkt, in handle_socket_msg_recv()
822 net_pkt_unref(sd->rx_pkt); in handle_socket_msg_recv()
|
| /Zephyr-latest/drivers/ethernet/dwc_xgmac/ |
| D | eth_dwc_xgmac.c | 295 rx_desc_meta->rx_pkt = (struct net_pkt *)NULL; in dwxgmac_dma_chnl_init()
537 static inline void add_buffs_to_pkt(struct net_pkt *rx_pkt, struct net_buf *buff1, in add_buffs_to_pkt() argument
543 net_pkt_frag_add(rx_pkt, buff1); in add_buffs_to_pkt()
547 net_pkt_frag_add(rx_pkt, buff2); in add_buffs_to_pkt()
647 if (rx_desc_meta->rx_pkt) { in eth_dwc_xgmac_rx_irq_work()
648 net_pkt_frag_unref(rx_desc_meta->rx_pkt->frags); in eth_dwc_xgmac_rx_irq_work()
649 net_pkt_unref(rx_desc_meta->rx_pkt); in eth_dwc_xgmac_rx_irq_work()
651 rx_desc_meta->rx_pkt = net_pkt_rx_alloc_on_iface(data->iface, K_NO_WAIT); in eth_dwc_xgmac_rx_irq_work()
652 if (!rx_desc_meta->rx_pkt) { in eth_dwc_xgmac_rx_irq_work()
660 if (rx_desc_meta->rx_pkt != NULL) { in eth_dwc_xgmac_rx_irq_work()
[all …]
|
| D | eth_dwc_xgmac_priv.h | 449 struct net_pkt *rx_pkt; member
|
| /Zephyr-latest/include/zephyr/modem/ |
| D | ppp.h | 96 struct net_pkt *rx_pkt; member
|
| /Zephyr-latest/tests/net/ieee802154/l2/src/ |
| D | ieee802154_test.c | 1111 struct net_pkt *rx_pkt; in test_recv_and_send_ack_reply() local
1139 rx_pkt = get_data_pkt_with_ar(); in test_recv_and_send_ack_reply()
1140 if (!rx_pkt) { in test_recv_and_send_ack_reply()
1144 if (net_recv_data(net_iface, rx_pkt) < 0) { in test_recv_and_send_ack_reply()
1210 net_pkt_unref(rx_pkt); in test_recv_and_send_ack_reply()
|
| /Zephyr-latest/modules/openthread/platform/ |
| D | radio.c | 654 struct net_pkt *rx_pkt; in platformRadioProcess() local
657 while ((rx_pkt = (struct net_pkt *) k_fifo_get(&rx_pkt_fifo, K_NO_WAIT)) != NULL) { in platformRadioProcess()
658 openthread_handle_received_frame(aInstance, rx_pkt); in platformRadioProcess()
|
