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;
107 #endif /* SILC_THREADS */
108 unsigned int locked : 1;
111 SilcBool silc_mutex_alloc(SilcMutex *mutex)
114 *mutex = silc_calloc(1, sizeof(**mutex));
117 pthread_mutex_init(&(*mutex)->mutex, NULL);
118 (*mutex)->locked = FALSE;
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))
141 mutex->locked = TRUE;
143 #endif /* SILC_THREADS */
146 void silc_mutex_unlock(SilcMutex mutex)
150 if (pthread_mutex_unlock(&mutex->mutex))
152 mutex->locked = FALSE;
154 #endif /* SILC_THREADS */
157 void silc_mutex_assert_locked(SilcMutex mutex)
161 SILC_ASSERT(mutex->locked);
162 #endif /* SILC_THREADS */
166 /****************************** SILC Cond API *******************************/
168 /* SILC Conditional Variable context */
169 struct SilcCondStruct {
174 #endif /* SILC_THREADS*/
177 SilcBool silc_cond_alloc(SilcCond *cond)
180 *cond = silc_calloc(1, sizeof(**cond));
183 pthread_cond_init(&(*cond)->cond, NULL);
187 #endif /* SILC_THREADS*/
190 void silc_cond_free(SilcCond cond)
193 pthread_cond_destroy(&cond->cond);
195 #endif /* SILC_THREADS*/
198 void silc_cond_signal(SilcCond cond)
201 pthread_cond_signal(&cond->cond);
202 #endif /* SILC_THREADS*/
205 void silc_cond_broadcast(SilcCond cond)
208 pthread_cond_broadcast(&cond->cond);
209 #endif /* SILC_THREADS*/
212 void silc_cond_wait(SilcCond cond, SilcMutex mutex)
215 pthread_cond_wait(&cond->cond, &mutex->mutex);
216 #endif /* SILC_THREADS*/
219 SilcBool silc_cond_timedwait(SilcCond cond, SilcMutex mutex,
225 t.tv_sec = timeout / 1000;
226 t.tv_nsec = (timeout % 1000) * 1000;
227 return pthread_cond_timedwait(&cond->cond, &mutex->mutex, &t) == 0;
230 return pthread_cond_wait(&cond->cond, &mutex->mutex) == 0;
233 #endif /* SILC_THREADS*/