1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
|
/* -*- c++ -*- */
/*
* Copyright 2006 Free Software Foundation, Inc.
*
* This file is part of GNU Radio.
*
* Primary Author: Michael Dickens, NCIP Lab, University of Notre Dame
*
* GNU Radio is free software; you can redistribute it and/or modify
* it under the terms of the GNU General Public License as published by
* the Free Software Foundation; either version 3, or (at your option)
* any later version.
*
* GNU Radio is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU General Public License for more details.
*
* You should have received a copy of the GNU General Public License
* along with GNU Radio; see the file COPYING. If not, write to
* the Free Software Foundation, Inc., 51 Franklin Street,
* Boston, MA 02110-1301, USA.
*/
#ifndef _INCLUDED_MLD_THREADS_H_
#define _INCLUDED_MLD_THREADS_H_
/* classes which allow for either pthreads or omni_threads */
#define __macos__
#ifdef _USE_OMNI_THREADS_
#include <omnithread.h>
#else
#include <pthread.h>
#endif
#include <stdexcept>
#define __INLINE__ inline
class mld_condition_t;
class mld_mutex_t {
#ifdef _USE_OMNI_THREADS_
typedef omni_mutex l_mutex, *l_mutex_ptr;
#else
typedef pthread_mutex_t l_mutex, *l_mutex_ptr;
#endif
friend class mld_condition_t;
private:
l_mutex_ptr d_mutex;
protected:
inline l_mutex_ptr mutex () { return (d_mutex); };
public:
__INLINE__ mld_mutex_t () {
#ifdef _USE_OMNI_THREADS_
d_mutex = new omni_mutex ();
#else
d_mutex = (l_mutex_ptr) new l_mutex;
int l_ret = pthread_mutex_init (d_mutex, NULL);
if (l_ret != 0) {
fprintf (stderr, "Error %d creating mutex.\n", l_ret);
throw std::runtime_error ("mld_mutex_t::mld_mutex_t()\n");
}
#endif
};
__INLINE__ ~mld_mutex_t () {
unlock ();
#ifndef _USE_OMNI_THREADS_
int l_ret = pthread_mutex_destroy (d_mutex);
if (l_ret != 0) {
fprintf (stderr, "mld_mutex_t::~mld_mutex_t(): "
"Error %d destroying mutex.\n", l_ret);
}
#endif
delete d_mutex;
d_mutex = NULL;
};
__INLINE__ void lock () {
#ifdef _USE_OMNI_THREADS_
d_mutex->lock ();
#else
int l_ret = pthread_mutex_lock (d_mutex);
if (l_ret != 0) {
fprintf (stderr, "mld_mutex_t::lock(): "
"Error %d locking mutex.\n", l_ret);
}
#endif
};
__INLINE__ void unlock () {
#ifdef _USE_OMNI_THREADS_
d_mutex->unlock ();
#else
int l_ret = pthread_mutex_unlock (d_mutex);
if (l_ret != 0) {
fprintf (stderr, "mld_mutex_t::unlock(): "
"Error %d locking mutex.\n", l_ret);
}
#endif
};
__INLINE__ bool trylock () {
#ifdef _USE_OMNI_THREADS_
int l_ret = d_mutex->trylock ();
#else
int l_ret = pthread_mutex_unlock (d_mutex);
#endif
return (l_ret == 0 ? true : false);
};
inline void acquire () { lock(); };
inline void release () { unlock(); };
inline void wait () { lock(); };
inline void post () { unlock(); };
};
typedef mld_mutex_t mld_mutex, *mld_mutex_ptr;
class mld_condition_t {
#ifdef _USE_OMNI_THREADS_
typedef omni_condition l_condition, *l_condition_ptr;
#else
typedef pthread_cond_t l_condition, *l_condition_ptr;
#endif
private:
l_condition_ptr d_condition;
mld_mutex_ptr d_mutex;
bool d_waiting;
public:
__INLINE__ mld_condition_t () {
d_waiting = false;
d_mutex = new mld_mutex ();
#ifdef _USE_OMNI_THREADS_
d_condition = new omni_condition (d_mutex->mutex ());
#else
d_condition = (l_condition_ptr) new l_condition;
int l_ret = pthread_cond_init (d_condition, NULL);
if (l_ret != 0) {
fprintf (stderr, "Error %d creating condition.\n", l_ret);
throw std::runtime_error ("mld_condition_t::mld_condition_t()\n");
}
#endif
};
__INLINE__ ~mld_condition_t () {
signal ();
#ifndef _USE_OMNI_THREADS_
int l_ret = pthread_cond_destroy (d_condition);
if (l_ret != 0) {
fprintf (stderr, "mld_condition_t::mld_condition_t(): "
"Error %d destroying condition.\n", l_ret);
}
#endif
delete d_condition;
d_condition = NULL;
delete d_mutex;
d_mutex = NULL;
};
__INLINE__ void signal () {
if (d_waiting == true) {
#ifdef _USE_OMNI_THREADS_
d_condition->signal ();
#else
int l_ret = pthread_cond_signal (d_condition);
if (l_ret != 0) {
fprintf (stderr, "mld_condition_t::signal(): "
"Error %d.\n", l_ret);
}
#endif
d_waiting = false;
}
};
__INLINE__ void wait () {
if (d_waiting == false) {
d_waiting = true;
#ifdef _USE_OMNI_THREADS_
d_condition->wait ();
#else
int l_ret = pthread_cond_wait (d_condition, d_mutex->mutex ());
if (l_ret != 0) {
fprintf (stderr, "mld_condition_t::wait(): "
"Error %d.\n", l_ret);
}
#endif
}
};
};
typedef mld_condition_t mld_condition, *mld_condition_ptr;
class mld_thread_t {
#ifdef _USE_OMNI_THREADS_
typedef omni_thread l_thread, *l_thread_ptr;
#else
typedef pthread_t l_thread, *l_thread_ptr;
#endif
private:
#ifndef _USE_OMNI_THREADS_
l_thread d_thread;
void (*d_start_routine)(void*);
void *d_arg;
#else
l_thread_ptr d_thread;
#endif
#ifndef _USE_OMNI_THREADS_
static void* local_start_routine (void *arg) {
mld_thread_t* This = (mld_thread_t*) arg;
(*(This->d_start_routine))(This->d_arg);
return (NULL);
};
#endif
public:
__INLINE__ mld_thread_t (void (*start_routine)(void *), void *arg) {
#ifdef _USE_OMNI_THREADS_
d_thread = new omni_thread (start_routine, arg);
d_thread->start ();
#else
d_start_routine = start_routine;
d_arg = arg;
int l_ret = pthread_create (&d_thread, NULL, local_start_routine, this);
if (l_ret != 0) {
fprintf (stderr, "Error %d creating thread.\n", l_ret);
throw std::runtime_error ("mld_thread_t::mld_thread_t()\n");
}
#endif
};
__INLINE__ ~mld_thread_t () {
#ifdef _USE_OMNI_THREADS_
// delete d_thread;
d_thread = NULL;
#else
int l_ret = pthread_detach (d_thread);
if (l_ret != 0) {
fprintf (stderr, "Error %d detaching thread.\n", l_ret);
throw std::runtime_error ("mld_thread_t::~mld_thread_t()\n");
}
#endif
};
};
typedef mld_thread_t mld_thread, *mld_thread_ptr;
#endif /* _INCLUDED_MLD_THREADS_H_ */
|
