5 Author: Pekka Riikonen <priikone@silcnet.org>
7 Copyright (C) 2001 - 2006 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.
23 /**************************** SILC Thread API *******************************/
25 SilcThread silc_thread_create(SilcThreadStart start_func, void *context,
33 SILC_LOG_DEBUG(("Creating new thread"));
38 if (pthread_attr_init(&attr)) {
39 SILC_LOG_ERROR(("Thread error: %s", strerror(errno)));
43 if (pthread_attr_setdetachstate(&attr,
44 waitable ? PTHREAD_CREATE_JOINABLE :
45 PTHREAD_CREATE_DETACHED)) {
46 SILC_LOG_ERROR(("Thread error: %s", strerror(errno)));
47 pthread_attr_destroy(&attr);
51 ret = pthread_create(&thread, &attr, (void * (*)(void *))start_func,
54 SILC_LOG_ERROR(("Thread error: %s", strerror(errno)));
55 pthread_attr_destroy(&attr);
59 pthread_attr_destroy(&attr);
61 SILC_LOG_DEBUG(("Created thread %p", (SilcThread)thread));
63 return (SilcThread)thread;
65 /* Call thread callback immediately */
66 (*start_func)(context);
71 void silc_thread_exit(void *exit_value)
74 pthread_exit(exit_value);
78 SilcThread silc_thread_self(void)
81 pthread_t self = pthread_self();
82 return (SilcThread)self;
88 SilcBool silc_thread_wait(SilcThread thread, void **exit_value)
91 SILC_LOG_DEBUG(("Waiting for thread %p", thread));
92 if (!pthread_join(*(pthread_t *)thread, exit_value))
101 /***************************** SILC Mutex API *******************************/
103 /* SILC Mutex structure */
104 struct SilcMutexStruct {
106 pthread_mutex_t mutex;
109 #endif /* SILC_THREADS */
112 SilcBool silc_mutex_alloc(SilcMutex *mutex)
115 *mutex = silc_calloc(1, sizeof(**mutex));
118 pthread_mutex_init(&(*mutex)->mutex, NULL);
122 #endif /* SILC_THREADS */
125 void silc_mutex_free(SilcMutex mutex)
129 pthread_mutex_destroy(&mutex->mutex);
132 #endif /* SILC_THREADS */
135 void silc_mutex_lock(SilcMutex mutex)
139 if (pthread_mutex_lock(&mutex->mutex))
142 #endif /* SILC_THREADS */
145 void silc_mutex_unlock(SilcMutex mutex)
149 if (pthread_mutex_unlock(&mutex->mutex))
152 #endif /* SILC_THREADS */
156 /**************************** SILC Cond API ******************************/
158 /* SILC Conditional Variable context */
159 struct SilcCondStruct {
164 #endif /* SILC_THREADS*/
167 SilcBool silc_cond_alloc(SilcCond *cond)
170 *cond = silc_calloc(1, sizeof(**cond));
173 pthread_cond_init(&(*cond)->cond, NULL);
177 #endif /* SILC_THREADS*/
180 void silc_cond_free(SilcCond cond)
183 pthread_cond_destroy(&cond->cond);
185 #endif /* SILC_THREADS*/
188 void silc_cond_signal(SilcCond cond)
191 pthread_cond_signal(&cond->cond);
192 #endif /* SILC_THREADS*/
195 void silc_cond_broadcast(SilcCond cond)
198 pthread_cond_broadcast(&cond->cond);
199 #endif /* SILC_THREADS*/
202 void silc_cond_wait(SilcCond cond, SilcMutex mutex)
205 pthread_cond_wait(&cond->cond, &mutex->mutex);
206 #endif /* SILC_THREADS*/
209 SilcBool silc_cond_timedwait(SilcCond cond, SilcMutex mutex,
215 t.tv_sec = timeout / 1000;
216 t.tv_nsec = (timeout % 1000) * 1000;
217 return pthread_cond_timedwait(&cond->cond, &mutex->mutex, &t) == 0;
220 return pthread_cond_wait(&cond->cond, &mutex->mutex) == 0;
223 #endif /* SILC_THREADS*/