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
|
/* -*- mode: C; c-file-style: "gnu" -*- */
/* dbus-sysdeps-pthread.c Implements threads using pthreads (internal to libdbus)
*
* Copyright (C) 2002, 2003, 2006 Red Hat, Inc.
*
* Licensed under the Academic Free License version 2.1
*
* This program 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 2 of the License, or
* (at your option) any later version.
*
* This program 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 this program; if not, write to the Free Software
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
*
*/
#include "dbus-internals.h"
#include "dbus-sysdeps.h"
#include "dbus-threads.h"
#include <sys/time.h>
#include <pthread.h>
static DBusMutex*
_dbus_pthread_mutex_new (void)
{
pthread_mutex_t *retval;
retval = dbus_new (pthread_mutex_t, 1);
if (retval == NULL)
return NULL;
if (pthread_mutex_init (retval, NULL))
{
dbus_free (retval);
return NULL;
}
return (DBusMutex *) retval;
}
static void
_dbus_pthread_mutex_free (DBusMutex *mutex)
{
pthread_mutex_destroy ((pthread_mutex_t *) mutex);
dbus_free (mutex);
}
static dbus_bool_t
_dbus_pthread_mutex_lock (DBusMutex *mutex)
{
return pthread_mutex_lock ((pthread_mutex_t *) mutex) == 0;
}
static dbus_bool_t
_dbus_pthread_mutex_unlock (DBusMutex *mutex)
{
return pthread_mutex_unlock ((pthread_mutex_t *) mutex) == 0;
}
static DBusCondVar *
_dbus_pthread_condvar_new (void)
{
pthread_cond_t *retval;
retval = dbus_new (pthread_cond_t, 1);
if (retval == NULL)
return NULL;
if (pthread_cond_init (retval, NULL))
{
dbus_free (retval);
return NULL;
}
return (DBusCondVar *) retval;
}
static void
_dbus_pthread_condvar_free (DBusCondVar *cond)
{
pthread_cond_destroy ((pthread_cond_t *) cond);
dbus_free (cond);
}
static void
_dbus_pthread_condvar_wait (DBusCondVar *cond,
DBusMutex *mutex)
{
pthread_cond_wait ((pthread_cond_t *)cond,
(pthread_mutex_t *) mutex);
}
static dbus_bool_t
_dbus_pthread_condvar_wait_timeout (DBusCondVar *cond,
DBusMutex *mutex,
int timeout_milliseconds)
{
struct timeval time_now;
struct timespec end_time;
int result;
gettimeofday (&time_now, NULL);
end_time.tv_sec = time_now.tv_sec + timeout_milliseconds / 1000;
end_time.tv_nsec = (time_now.tv_usec + (timeout_milliseconds % 1000) * 1000) * 1000;
if (end_time.tv_nsec > 1000*1000*1000)
{
end_time.tv_sec += 1;
end_time.tv_nsec -= 1000*1000*1000;
}
result = pthread_cond_timedwait ((pthread_cond_t *) cond,
(pthread_mutex_t *) mutex,
&end_time);
/* return true if we did not time out */
return result != ETIMEDOUT;
}
static void
_dbus_pthread_condvar_wake_one (DBusCondVar *cond)
{
pthread_cond_signal ((pthread_cond_t *)cond);
}
static void
_dbus_pthread_condvar_wake_all (DBusCondVar *cond)
{
pthread_cond_broadcast ((pthread_cond_t *)cond);
}
static const DBusThreadFunctions pthread_functions =
{
DBUS_THREAD_FUNCTIONS_MUTEX_NEW_MASK |
DBUS_THREAD_FUNCTIONS_MUTEX_FREE_MASK |
DBUS_THREAD_FUNCTIONS_MUTEX_LOCK_MASK |
DBUS_THREAD_FUNCTIONS_MUTEX_UNLOCK_MASK |
DBUS_THREAD_FUNCTIONS_CONDVAR_NEW_MASK |
DBUS_THREAD_FUNCTIONS_CONDVAR_FREE_MASK |
DBUS_THREAD_FUNCTIONS_CONDVAR_WAIT_MASK |
DBUS_THREAD_FUNCTIONS_CONDVAR_WAIT_TIMEOUT_MASK |
DBUS_THREAD_FUNCTIONS_CONDVAR_WAKE_ONE_MASK|
DBUS_THREAD_FUNCTIONS_CONDVAR_WAKE_ALL_MASK,
_dbus_pthread_mutex_new,
_dbus_pthread_mutex_free,
_dbus_pthread_mutex_lock,
_dbus_pthread_mutex_unlock,
_dbus_pthread_condvar_new,
_dbus_pthread_condvar_free,
_dbus_pthread_condvar_wait,
_dbus_pthread_condvar_wait_timeout,
_dbus_pthread_condvar_wake_one,
_dbus_pthread_condvar_wake_all
};
dbus_bool_t
_dbus_threads_init_platform_specific (void)
{
return dbus_threads_init (&pthread_functions);
}
|
