5 Author: Pekka Riikonen <priikone@silcnet.org>
7 Copyright (C) 2001 - 2007 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))
100 void silc_thread_yield(void)
103 #ifdef HAVE_SCHED_YIELD
105 #endif /* HAVE_SCHED_YIELD */
106 #endif /* SILC_THREADS */
109 /***************************** SILC Mutex API *******************************/
111 /* SILC Mutex structure */
112 struct SilcMutexStruct {
114 pthread_mutex_t mutex;
115 #endif /* SILC_THREADS */
116 unsigned int locked : 1;
119 SilcBool silc_mutex_alloc(SilcMutex *mutex)
122 *mutex = silc_calloc(1, sizeof(**mutex));
125 pthread_mutex_init(&(*mutex)->mutex, NULL);
126 (*mutex)->locked = FALSE;
130 #endif /* SILC_THREADS */
133 void silc_mutex_free(SilcMutex mutex)
137 pthread_mutex_destroy(&mutex->mutex);
140 #endif /* SILC_THREADS */
143 void silc_mutex_lock(SilcMutex mutex)
147 SILC_VERIFY(pthread_mutex_lock(&mutex->mutex) == 0);
148 mutex->locked = TRUE;
150 #endif /* SILC_THREADS */
153 void silc_mutex_unlock(SilcMutex mutex)
157 mutex->locked = FALSE;
158 SILC_VERIFY(pthread_mutex_unlock(&mutex->mutex) == 0);
160 #endif /* SILC_THREADS */
163 void silc_mutex_assert_locked(SilcMutex mutex)
167 SILC_VERIFY(mutex->locked);
168 #endif /* SILC_THREADS */
171 /***************************** SILC Rwlock API ******************************/
173 /* SILC read/write lock structure */
174 struct SilcRwLockStruct {
176 pthread_rwlock_t rwlock;
179 #endif /* SILC_THREADS */
182 SilcBool silc_rwlock_alloc(SilcRwLock *rwlock)
185 *rwlock = silc_calloc(1, sizeof(**rwlock));
188 pthread_rwlock_init(&(*rwlock)->rwlock, NULL);
192 #endif /* SILC_THREADS */
195 void silc_rwlock_free(SilcRwLock rwlock)
199 pthread_rwlock_destroy(&rwlock->rwlock);
202 #endif /* SILC_THREADS */
205 void silc_rwlock_rdlock(SilcRwLock rwlock)
209 pthread_rwlock_rdlock(&rwlock->rwlock);
210 #endif /* SILC_THREADS */
213 void silc_rwlock_wrlock(SilcRwLock rwlock)
217 SILC_VERIFY(pthread_rwlock_wrlock(&rwlock->rwlock) == 0);
218 #endif /* SILC_THREADS */
221 void silc_rwlock_unlock(SilcRwLock rwlock)
225 SILC_VERIFY(pthread_rwlock_unlock(&rwlock->rwlock) == 0);
226 #endif /* SILC_THREADS */
229 /****************************** SILC Cond API *******************************/
231 /* SILC Conditional Variable context */
232 struct SilcCondStruct {
237 #endif /* SILC_THREADS*/
240 SilcBool silc_cond_alloc(SilcCond *cond)
243 *cond = silc_calloc(1, sizeof(**cond));
246 pthread_cond_init(&(*cond)->cond, NULL);
250 #endif /* SILC_THREADS*/
253 void silc_cond_free(SilcCond cond)
256 pthread_cond_destroy(&cond->cond);
258 #endif /* SILC_THREADS*/
261 void silc_cond_signal(SilcCond cond)
264 pthread_cond_signal(&cond->cond);
265 #endif /* SILC_THREADS*/
268 void silc_cond_broadcast(SilcCond cond)
271 pthread_cond_broadcast(&cond->cond);
272 #endif /* SILC_THREADS*/
275 void silc_cond_wait(SilcCond cond, SilcMutex mutex)
278 pthread_cond_wait(&cond->cond, &mutex->mutex);
279 #endif /* SILC_THREADS*/
282 SilcBool silc_cond_timedwait(SilcCond cond, SilcMutex mutex,
288 t.tv_sec = timeout / 1000;
289 t.tv_nsec = (timeout % 1000) * 1000;
290 return pthread_cond_timedwait(&cond->cond, &mutex->mutex, &t) == 0;
293 return pthread_cond_wait(&cond->cond, &mutex->mutex) == 0;
296 #endif /* SILC_THREADS*/