22     struct pkt_queue *queue = calloc(1, sizeof(struct pkt_queue));  in pkt_queue_create()  local
23     if (queue == NULL) {  in pkt_queue_create()
26     if (osi_mutex_new(&queue->lock) != 0) {  in pkt_queue_create()
27         osi_free(queue);  in pkt_queue_create()
29     struct pkt_queue_header *p = &queue->header;  in pkt_queue_create()
32     return queue;  in pkt_queue_create()
35 static void pkt_queue_cleanup(struct pkt_queue *queue, pkt_queue_free_cb free_cb)  in pkt_queue_cleanup()  argument
37     if (queue == NULL) {  in pkt_queue_cleanup()
41     struct pkt_queue_header *header = &queue->header;  in pkt_queue_cleanup()
51         queue->length--;  in pkt_queue_cleanup()
54     queue->length = 0;  in pkt_queue_cleanup()
57 void pkt_queue_flush(struct pkt_queue *queue, pkt_queue_free_cb free_cb)  in pkt_queue_flush()  argument
59     if (queue == NULL) {  in pkt_queue_flush()
62     osi_mutex_lock(&queue->lock, OSI_MUTEX_MAX_TIMEOUT);  in pkt_queue_flush()
63     pkt_queue_cleanup(queue, free_cb);  in pkt_queue_flush()
64     osi_mutex_unlock(&queue->lock);  in pkt_queue_flush()
67 void pkt_queue_destroy(struct pkt_queue *queue, pkt_queue_free_cb free_cb)  in pkt_queue_destroy()  argument
69     if (queue == NULL) {  in pkt_queue_destroy()
72     osi_mutex_lock(&queue->lock, OSI_MUTEX_MAX_TIMEOUT);  in pkt_queue_destroy()
73     pkt_queue_cleanup(queue, free_cb);  in pkt_queue_destroy()
74     osi_mutex_unlock(&queue->lock);  in pkt_queue_destroy()
76     osi_mutex_free(&queue->lock);  in pkt_queue_destroy()
77     osi_free(queue);  in pkt_queue_destroy()
80 pkt_linked_item_t *pkt_queue_dequeue(struct pkt_queue *queue)  in pkt_queue_dequeue()  argument
82     if (queue == NULL || queue->length == 0) {  in pkt_queue_dequeue()
88     osi_mutex_lock(&queue->lock, OSI_MUTEX_MAX_TIMEOUT);  in pkt_queue_dequeue()
89     header = &queue->header;  in pkt_queue_dequeue()
93         if (queue->length > 0) {  in pkt_queue_dequeue()
94             queue->length--;  in pkt_queue_dequeue()
97     osi_mutex_unlock(&queue->lock);  in pkt_queue_dequeue()
102 bool pkt_queue_enqueue(struct pkt_queue *queue, pkt_linked_item_t *item)  in pkt_queue_enqueue()  argument
104     if (queue == NULL || item == NULL) {  in pkt_queue_enqueue()
109     osi_mutex_lock(&queue->lock, OSI_MUTEX_MAX_TIMEOUT);  in pkt_queue_enqueue()
110     header = &queue->header;  in pkt_queue_enqueue()
112     queue->length++;  in pkt_queue_enqueue()
113     osi_mutex_unlock(&queue->lock);  in pkt_queue_enqueue()
118 size_t pkt_queue_length(const struct pkt_queue *queue)  in pkt_queue_length()  argument
120     if (queue == NULL) {  in pkt_queue_length()
123     return queue->length;  in pkt_queue_length()
126 bool pkt_queue_is_empty(const struct pkt_queue *queue)  in pkt_queue_is_empty()  argument
128     return pkt_queue_length(queue) == 0;  in pkt_queue_is_empty()
131 pkt_linked_item_t *pkt_queue_try_peek_first(struct pkt_queue *queue)  in pkt_queue_try_peek_first()  argument
133     if (queue == NULL) {  in pkt_queue_try_peek_first()
137     struct pkt_queue_header *header = &queue->header;  in pkt_queue_try_peek_first()
139     osi_mutex_lock(&queue->lock, OSI_MUTEX_MAX_TIMEOUT);  in pkt_queue_try_peek_first()
141     osi_mutex_unlock(&queue->lock);  in pkt_queue_try_peek_first()