5 Author: Pekka Riikonen <priikone@silcnet.org>
7 Copyright (C) 2008 Pekka Riikonen
9 This program is free software; you can redistribute it and/or modify
10 it under the terms of the GNU General Public License as published by
11 the Free Software Foundation; version 2 of the License.
13 This program is distributed in the hope that it will be useful,
14 but WITHOUT ANY WARRANTY; without even the implied warranty of
15 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
16 GNU General Public License for more details.
20 #include "silcruntime.h"
22 /************************** Types and definitions ***************************/
24 /* Thread queue context */
25 struct SilcThreadQueueStruct {
26 SilcDList queue; /* The queue */
27 SilcMutex lock; /* Queue lock */
28 SilcCond cond; /* Condition for waiting */
29 SilcAtomic32 connected; /* Number of connected threads */
32 /************************** SILC Thread Queue API ***************************/
34 /* Allocate thread queue */
36 SilcThreadQueue silc_thread_queue_alloc(void)
38 SilcThreadQueue queue;
40 queue = silc_calloc(1, sizeof(*queue));
44 SILC_LOG_DEBUG(("Allocated thread queue %p", queue));
46 if (!silc_mutex_alloc(&queue->lock)) {
51 if (!silc_cond_alloc(&queue->cond)) {
52 silc_mutex_free(queue->lock);
57 queue->queue = silc_dlist_init();
59 silc_cond_free(queue->cond);
60 silc_mutex_free(queue->lock);
65 silc_atomic_init32(&queue->connected, 1);
70 /* Connect current thread to queue */
72 void silc_thread_queue_connect(SilcThreadQueue queue)
74 silc_atomic_add_int32(&queue->connected, 1);
77 /* Disconnect current thread from queue */
79 void silc_thread_queue_disconnect(SilcThreadQueue queue)
81 if (silc_atomic_sub_int32(&queue->connected, 1) > 0)
85 SILC_LOG_DEBUG(("Free thread queue %p", queue));
86 silc_cond_free(queue->cond);
87 silc_mutex_free(queue->lock);
88 silc_dlist_uninit(queue->queue);
89 silc_atomic_uninit32(&queue->connected);
93 /* Push data to queue */
95 void silc_thread_queue_push(SilcThreadQueue queue, void *data)
97 if (silc_unlikely(!data))
100 SILC_LOG_DEBUG(("Push data %p to thread queue %p", data, queue));
102 silc_mutex_lock(queue->lock);
103 silc_dlist_start(queue->queue);
104 silc_dlist_insert(queue->queue, data);
105 silc_cond_broadcast(queue->cond);
106 silc_mutex_unlock(queue->lock);
109 /* Get data or wait if wanted or return NULL. */
111 void *silc_thread_queue_pop(SilcThreadQueue queue, SilcBool block)
116 return silc_thread_queue_timed_pop(queue, 0);
118 silc_mutex_lock(queue->lock);
120 silc_dlist_start(queue->queue);
121 data = silc_dlist_get(queue->queue);
123 silc_dlist_del(queue->queue, data);
125 SILC_LOG_DEBUG(("Pop data %p from thread queue %p", data, queue));
127 silc_mutex_unlock(queue->lock);
132 /* Get data or wait for a while */
134 void *silc_thread_queue_timed_pop(SilcThreadQueue queue,
139 silc_mutex_lock(queue->lock);
141 silc_dlist_start(queue->queue);
142 while ((data = silc_dlist_get(queue->queue)) == SILC_LIST_END) {
143 if (!silc_cond_timedwait(queue->cond, queue->lock, timeout_msec))
145 silc_dlist_start(queue->queue);
149 silc_dlist_del(queue->queue, data);
151 SILC_LOG_DEBUG(("Pop data %p from thread queue %p", data, queue));
153 silc_mutex_unlock(queue->lock);
158 /* Pop entire queue */
160 SilcDList silc_thread_queue_pop_list(SilcThreadQueue queue, SilcBool block)
164 silc_mutex_lock(queue->lock);
167 while (silc_dlist_count(queue->queue) == 0)
168 silc_cond_wait(queue->cond, queue->lock);
171 queue->queue = silc_dlist_init();
173 silc_mutex_unlock(queue->lock);
175 silc_dlist_start(list);