1 /*
2 * Copyright 2011 Google Inc. All Rights Reserved.
3 *
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
7 *
8 * http://www.apache.org/licenses/LICENSE-2.0
9 *
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
15 */
16
17 #include "test/platform_thread.h"
18
19 namespace sfntly {
20
21 #if defined (WIN32)
22
ThreadFunc(void * params)23 DWORD __stdcall ThreadFunc(void* params) {
24 PlatformThread::Delegate* delegate =
25 static_cast<PlatformThread::Delegate*>(params);
26 delegate->ThreadMain();
27 return 0;
28 }
29
30 // static
Create(Delegate * delegate,PlatformThreadHandle * thread_handle)31 bool PlatformThread::Create(Delegate* delegate,
32 PlatformThreadHandle* thread_handle) {
33 assert(thread_handle);
34 *thread_handle = CreateThread(NULL, 0, ThreadFunc, delegate, 0, NULL);
35 if (!(*thread_handle)) {
36 return false;
37 }
38
39 return true;
40 }
41
42 // static
Join(PlatformThreadHandle thread_handle)43 void PlatformThread::Join(PlatformThreadHandle thread_handle) {
44 assert(thread_handle);
45 DWORD result = WaitForSingleObject(thread_handle, INFINITE);
46 assert(result == WAIT_OBJECT_0);
47 CloseHandle(thread_handle);
48 }
49
50 // static
Sleep(int32_t duration_ms)51 void PlatformThread::Sleep(int32_t duration_ms) {
52 ::Sleep(duration_ms);
53 }
54
55 #else
56
57 void* ThreadFunc(void* params) {
58 PlatformThread::Delegate* delegate =
59 static_cast<PlatformThread::Delegate*>(params);
60 delegate->ThreadMain();
61 return NULL;
62 }
63
64 // static
65 bool PlatformThread::Create(Delegate* delegate,
66 PlatformThreadHandle* thread_handle) {
67 assert(thread_handle);
68
69 bool success = false;
70 pthread_attr_t attributes;
71 pthread_attr_init(&attributes);
72 success = !pthread_create(thread_handle, &attributes, ThreadFunc, delegate);
73 pthread_attr_destroy(&attributes);
74
75 return success;
76 }
77
78 // static
79 void PlatformThread::Join(PlatformThreadHandle thread_handle) {
80 assert(thread_handle);
81 pthread_join(thread_handle, NULL);
82 }
83
84 // static
85 void PlatformThread::Sleep(int32_t duration_ms) {
86 struct timespec sleep_time, remaining;
87
88 // Contains the portion of duration_ms >= 1 sec.
89 sleep_time.tv_sec = duration_ms / 1000;
90 duration_ms -= sleep_time.tv_sec * 1000;
91
92 // Contains the portion of duration_ms < 1 sec.
93 sleep_time.tv_nsec = duration_ms * 1000 * 1000; // nanoseconds.
94
95 while (nanosleep(&sleep_time, &remaining) == -1 && errno == EINTR)
96 sleep_time = remaining;
97 }
98
99 #endif // WIN32
100
101 } // namespace sfntly
102