3 * This file is part of the libCEC(R) library.
5 * libCEC(R) is Copyright (C) 2011-2013 Pulse-Eight Limited. All rights reserved.
6 * libCEC(R) is an original work, containing original code.
8 * libCEC(R) is a trademark of Pulse-Eight Limited.
10 * This program is dual-licensed; you can redistribute it and/or modify
11 * it under the terms of the GNU General Public License as published by
12 * the Free Software Foundation; either version 2 of the License, or
13 * (at your option) any later version.
15 * This program is distributed in the hope that it will be useful,
16 * but WITHOUT ANY WARRANTY; without even the implied warranty of
17 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
18 * GNU General Public License for more details.
20 * You should have received a copy of the GNU General Public License
21 * along with this program; if not, write to the Free Software
22 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
25 * Alternatively, you can license this library under a commercial license,
26 * please contact Pulse-Eight Licensing for more information.
28 * For more information contact:
29 * Pulse-Eight Licensing <license@pulse-eight.com>
30 * http://www.pulse-eight.com/
31 * http://www.pulse-eight.net/
36 inline pthread_mutexattr_t
*GetRecursiveMutexAttribute(void)
38 static pthread_mutexattr_t g_mutexAttr
;
39 static bool bAttributeInitialised
= false;
40 if (!bAttributeInitialised
)
42 pthread_mutexattr_init(&g_mutexAttr
);
43 pthread_mutexattr_settype(&g_mutexAttr
, PTHREAD_MUTEX_RECURSIVE
);
44 bAttributeInitialised
= true;
49 inline struct timespec
GetAbsTime(uint64_t iIncreaseBy
= 0)
54 gettimeofday(&tv
, NULL
);
55 now
.tv_sec
= tv
.tv_sec
;
56 now
.tv_nsec
= tv
.tv_usec
* 1000;
58 clock_gettime(CLOCK_REALTIME
, &now
);
60 now
.tv_nsec
+= iIncreaseBy
% 1000 * 1000000;
61 now
.tv_sec
+= iIncreaseBy
/ 1000 + now
.tv_nsec
/ 1000000000;
62 now
.tv_nsec
%= 1000000000;
66 typedef pthread_t thread_t
;
67 #define INVALID_THREAD_VALUE 0
69 #define ThreadsCreate(thread, func, arg) (pthread_create(&thread, NULL, (void *(*) (void *))func, (void *)arg) == 0)
70 #define ThreadsWait(thread, retval) (thread ? pthread_join(thread, retval) == 0 : true)
72 typedef pthread_mutex_t mutex_t
;
73 #define MutexCreate(mutex) pthread_mutex_init(&mutex, GetRecursiveMutexAttribute());
74 #define MutexDelete(mutex) pthread_mutex_destroy(&mutex);
75 #define MutexLock(mutex) (pthread_mutex_lock(&mutex) == 0)
76 #define MutexTryLock(mutex) (pthread_mutex_trylock(&mutex) == 0)
77 #define MutexUnlock(mutex) pthread_mutex_unlock(&mutex)
84 pthread_cond_init(&m_condition
, NULL
);
87 virtual ~CConditionImpl(void)
89 pthread_cond_destroy(&m_condition
);
94 pthread_cond_signal(&m_condition
);
99 pthread_cond_broadcast(&m_condition
);
102 bool Wait(mutex_t
&mutex
)
105 return (pthread_cond_wait(&m_condition
, &mutex
) == 0);
108 bool Wait(mutex_t
&mutex
, uint32_t iTimeoutMs
)
114 struct timespec timeout
= GetAbsTime(iTimeoutMs
);
115 return (pthread_cond_timedwait(&m_condition
, &mutex
, &timeout
) == 0);
118 pthread_cond_t m_condition
;