1 /*-------------------------------------------------------------------------
2 * drawElements Thread Library
3 * ---------------------------
4 *
5 * Copyright 2014 The Android Open Source Project
6 *
7 * Licensed under the Apache License, Version 2.0 (the "License");
8 * you may not use this file except in compliance with the License.
9 * You may obtain a copy of the License at
10 *
11 * http://www.apache.org/licenses/LICENSE-2.0
12 *
13 * Unless required by applicable law or agreed to in writing, software
14 * distributed under the License is distributed on an "AS IS" BASIS,
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
16 * See the License for the specific language governing permissions and
17 * limitations under the License.
18 *
19 *//*!
20 * \file
21 * \brief Unix implementation of thread management.
22 *//*--------------------------------------------------------------------*/
23
24 #include "deThread.h"
25
26 #if (DE_OS == DE_OS_UNIX || DE_OS == DE_OS_OSX || DE_OS == DE_OS_ANDROID || DE_OS == DE_OS_SYMBIAN || DE_OS == DE_OS_IOS)
27
28 #include "deMemory.h"
29
30 #if !defined(_XOPEN_SOURCE) || (_XOPEN_SOURCE < 500)
31 # error You are using too old posix API!
32 #endif
33
34 #include <unistd.h>
35 #include <pthread.h>
36 #include <sched.h>
37
38 typedef struct Thread_s
39 {
40 pthread_t thread;
41 deThreadFunc func;
42 void* arg;
43 } Thread;
44
45 DE_STATIC_ASSERT(sizeof(deThread) >= sizeof(Thread*));
46
startThread(void * entryPtr)47 static void* startThread (void* entryPtr)
48 {
49 Thread* thread = (Thread*)entryPtr;
50 deThreadFunc func = thread->func;
51 void* arg = thread->arg;
52
53 /* Start actual thread. */
54 func(arg);
55
56 return DE_NULL;
57 }
58
deThread_create(deThreadFunc func,void * arg,const deThreadAttributes * attributes)59 deThread deThread_create (deThreadFunc func, void* arg, const deThreadAttributes* attributes)
60 {
61 pthread_attr_t attr;
62 Thread* thread = (Thread*)deCalloc(sizeof(Thread));
63
64 if (!thread)
65 return 0;
66
67 thread->func = func;
68 thread->arg = arg;
69
70 if (pthread_attr_init(&attr) != 0)
71 {
72 deFree(thread);
73 return 0;
74 }
75
76 /* \todo [2009-11-12 pyry] Map attributes. */
77 DE_UNREF(attributes);
78
79 if (pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE) != 0)
80 {
81 pthread_attr_destroy(&attr);
82 deFree(thread);
83 return 0;
84 }
85
86 if (pthread_create(&thread->thread, &attr, startThread, thread) != 0)
87 {
88 pthread_attr_destroy(&attr);
89 deFree(thread);
90 return 0;
91 }
92 DE_ASSERT(thread->thread);
93
94 pthread_attr_destroy(&attr);
95
96 return (deThread)thread;
97 }
98
deThread_join(deThread threadptr)99 deBool deThread_join (deThread threadptr)
100 {
101 Thread* thread = (Thread*)threadptr;
102 int ret;
103
104 DE_ASSERT(thread->thread);
105 ret = pthread_join(thread->thread, DE_NULL);
106
107 /* If join fails for some reason, at least mark as detached. */
108 if (ret != 0)
109 pthread_detach(thread->thread);
110
111 /* Thread is no longer valid as far as we are concerned. */
112 thread->thread = 0;
113
114 return (ret == 0);
115 }
116
deThread_destroy(deThread threadptr)117 void deThread_destroy (deThread threadptr)
118 {
119 Thread* thread = (Thread*)threadptr;
120
121 if (thread->thread)
122 {
123 /* Not joined, detach. */
124 int ret = pthread_detach(thread->thread);
125 DE_ASSERT(ret == 0);
126 DE_UNREF(ret);
127 }
128
129 deFree(thread);
130 }
131
deSleep(deUint32 milliseconds)132 void deSleep (deUint32 milliseconds)
133 {
134 /* Maximum value for usleep is 10^6. */
135 deUint32 seconds = milliseconds / 1000;
136
137 milliseconds = milliseconds - seconds * 1000;
138
139 if (seconds > 0)
140 sleep(seconds);
141
142 usleep((useconds_t)milliseconds * (useconds_t)1000);
143 }
144
deYield(void)145 void deYield (void)
146 {
147 sched_yield();
148 }
149
150 #endif /* DE_OS */
151