3 * This file is part of the libCEC(R) library.
5 * libCEC(R) is Copyright (C) 2011-2012 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)
51 struct timespec abstime
;
53 gettimeofday(&now
, NULL
);
54 iIncreaseBy
+= now
.tv_usec
/ 1000;
55 abstime
.tv_sec
= now
.tv_sec
+ (time_t)(iIncreaseBy
/ 1000);
56 abstime
.tv_nsec
= (int32_t)((iIncreaseBy
% (uint32_t)1000) * (uint32_t)1000000);
60 typedef pthread_t thread_t
;
62 #define ThreadsCreate(thread, func, arg) (pthread_create(&thread, NULL, (void *(*) (void *))func, (void *)arg) == 0)
63 #define ThreadsWait(thread, retval) (pthread_join(thread, retval) == 0)
65 typedef pthread_mutex_t mutex_t
;
66 #define MutexCreate(mutex) pthread_mutex_init(&mutex, GetRecursiveMutexAttribute());
67 #define MutexDelete(mutex) pthread_mutex_destroy(&mutex);
68 #define MutexLock(mutex) (pthread_mutex_lock(&mutex) == 0)
69 #define MutexTryLock(mutex) (pthread_mutex_trylock(&mutex) == 0)
70 #define MutexUnlock(mutex) pthread_mutex_unlock(&mutex)
77 pthread_cond_init(&m_condition
, NULL
);
80 virtual ~CConditionImpl(void)
82 pthread_cond_destroy(&m_condition
);
87 pthread_cond_signal(&m_condition
);
92 pthread_cond_broadcast(&m_condition
);
95 bool Wait(mutex_t
&mutex
, uint32_t iTimeoutMs
)
100 struct timespec timeout
= GetAbsTime(iTimeout
);
101 return (pthread_cond_timedwait(&cond
, &mutex
, &timeout
) == 0);
103 return (pthread_cond_wait(&cond
, &mutex
) == 0);
106 pthread_cond_t m_condition
;