Lines Matching full:queue
32 * to resend the last sent PDU, which sits separately outside of the queue.
87 buf = net_buf_slist_get(&frnd->queue); in discard_buffer()
178 while (!net_buf_slist_is_empty(&frnd->queue)) { in friend_clear()
179 net_buf_unref(net_buf_slist_get(&frnd->queue)); in friend_clear()
185 while (!net_buf_slist_is_empty(&seg->queue)) { in friend_clear()
186 net_buf_unref(net_buf_slist_get(&seg->queue)); in friend_clear()
540 net_buf_slist_put(&frnd->queue, buf); in enqueue_buf()
604 if (net_buf_slist_is_empty(&frnd->queue)) { in bt_mesh_friend_poll()
606 BT_DBG("Enqueued Friend Update to empty queue"); in bt_mesh_friend_poll()
835 BT_WARN("Prohibited Minimum Queue Size in Friend Request"); in bt_mesh_friend_req()
840 BT_WARN("We have a too small Friend Queue size (%u < %u)", in bt_mesh_friend_req()
909 struct os_mbuf *buf = (void *)net_buf_slist_peek_head(&seg->queue); in get_seg()
951 net_buf_slist_put(&seg->queue, buf); in enqueue_friend_pdu()
958 /* Only acks should have a valid SeqAuth in the Friend queue in enqueue_friend_pdu()
964 NET_BUF_SLIST_FOR_EACH_NODE(&seg->queue, pkthdr) { in enqueue_friend_pdu()
970 net_buf_slist_merge_slist(&frnd->queue, &seg->queue); in enqueue_friend_pdu()
1035 frnd->last = net_buf_slist_get(&frnd->queue); in friend_timeout()
1042 BT_DBG("Sending buf %p from Friend Queue of LPN 0x%04x", in friend_timeout()
1073 net_buf_slist_init(&frnd->queue); in bt_mesh_friend_init()
1081 net_buf_slist_init(&frnd->seg[j].queue); in bt_mesh_friend_init()
1095 for (cur = net_buf_slist_peek_head(&frnd->queue); in friend_purge_old_ack()
1101 BT_DBG("Removing old ack from Friend Queue"); in friend_purge_old_ack()
1103 net_buf_slist_remove(&frnd->queue, prev, cur); in friend_purge_old_ack()
1323 buf = (void *)net_buf_slist_peek_head(&seg->queue); in bt_mesh_friend_clear_incomplete()
1338 while (!net_buf_slist_is_empty(&seg->queue)) { in bt_mesh_friend_clear_incomplete()
1339 net_buf_unref(net_buf_slist_get(&seg->queue)); in bt_mesh_friend_clear_incomplete()