Lines Matching refs:node_rx

299 static struct net_buf *process_prio_evt(struct node_rx_pdu *node_rx,  in process_prio_evt()  argument
303 if (node_rx->hdr.user_meta == HCI_CLASS_EVT_CONNECTION) { in process_prio_evt()
305 struct pdu_data *pdu_data = (void *)node_rx->pdu; in process_prio_evt()
307 handle = node_rx->hdr.handle; in process_prio_evt()
308 if (node_rx->hdr.type == NODE_RX_TYPE_TERMINATE) { in process_prio_evt()
338 struct node_rx_pdu *node_rx; in prio_recv_thread() local
347 node_rx = ll_iso_rx_get(); in prio_recv_thread()
348 if (node_rx) { in prio_recv_thread()
352 node_rx->hdr.user_meta = hci_get_class(node_rx); in prio_recv_thread()
358 k_fifo_put(&recv_fifo, node_rx); in prio_recv_thread()
365 while ((num_cmplt = ll_rx_get((void *)&node_rx, &handle))) { in prio_recv_thread()
378 if (node_rx) { in prio_recv_thread()
387 node_rx->hdr.user_meta = hci_get_class(node_rx); in prio_recv_thread()
389 buf = process_prio_evt(node_rx, &evt_flags); in prio_recv_thread()
393 node_rx->hdr.next = NULL; in prio_recv_thread()
394 ll_rx_mem_release((void **)&node_rx); in prio_recv_thread()
411 k_fifo_put(&recv_fifo, node_rx); in prio_recv_thread()
415 if (iso_received || node_rx) { in prio_recv_thread()
434 static inline struct net_buf *encode_node(struct node_rx_pdu *node_rx, in encode_node() argument
452 hci_evt_encode(node_rx, buf); in encode_node()
459 hci_acl_encode(node_rx, buf); in encode_node()
467 } else if (IS_CIS_HANDLE(node_rx->hdr.handle)) { in encode_node()
470 cis = ll_conn_iso_stream_get(node_rx->hdr.handle); in encode_node()
480 .meta = &node_rx->rx_iso_meta, in encode_node()
481 .pdu = (void *)&node_rx->pdu[0], in encode_node()
495 } else if (IS_SYNC_ISO_HANDLE(node_rx->hdr.handle)) { in encode_node()
501 stream_handle = LL_BIS_SYNC_IDX_FROM_HANDLE(node_rx->hdr.handle); in encode_node()
509 isoal_rx.meta = &node_rx->rx_iso_meta; in encode_node()
510 isoal_rx.pdu = (void *)node_rx->pdu; in encode_node()
522 node_rx->hdr.next = NULL; in encode_node()
523 ll_iso_rx_mem_release((void **)&node_rx); in encode_node()
534 node_rx->hdr.next = NULL; in encode_node()
535 ll_rx_mem_release((void **)&node_rx); in encode_node()
540 static inline struct net_buf *process_node(struct node_rx_pdu *node_rx) in process_node() argument
542 uint8_t class = node_rx->hdr.user_meta; in process_node()
562 sys_slist_append(&hbuf_pend, (void *)node_rx); in process_node()
575 buf = encode_node(node_rx, class); in process_node()
584 struct node_rx_pdu *node_rx = NULL; in process_hbuf() local
605 node_rx = (void *)sys_slist_peek_head(&hbuf_pend); in process_hbuf()
606 if (!node_rx) { in process_hbuf()
611 class = node_rx->hdr.user_meta; in process_hbuf()
635 node_rx = NULL; in process_hbuf()
645 if (node_rx) { in process_hbuf()
646 buf = encode_node(node_rx, class); in process_hbuf()
650 node_rx = (void *)sys_slist_peek_head(&hbuf_pend); in process_hbuf()
651 if (node_rx) { in process_hbuf()
652 class = node_rx->hdr.user_meta; in process_hbuf()
692 struct node_rx_pdu *node_rx = NULL; in recv_thread() local
705 node_rx = k_fifo_get(events[1].fifo, K_NO_WAIT); in recv_thread()
712 buf = process_hbuf(node_rx); in recv_thread()
715 node_rx = k_fifo_get(&recv_fifo, K_FOREVER); in recv_thread()
719 if (node_rx && !buf) { in recv_thread()
721 buf = process_node(node_rx); in recv_thread()
749 struct node_rx_pdu *node_rx = NULL; in cmd_handle() local
752 evt = hci_cmd_handle(buf, (void **) &node_rx); in cmd_handle()
757 if (node_rx) { in cmd_handle()
759 node_rx->hdr.user_meta = hci_get_class(node_rx); in cmd_handle()
760 k_fifo_put(&recv_fifo, node_rx); in cmd_handle()