Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(14)

Side by Side Diff: base/threading/platform_thread_posix.cc

Issue 6001010: Move platform_thread to base/threading and put in the base namespace. I left ... (Closed) Base URL: svn://chrome-svn/chrome/trunk/src/
Patch Set: Created 9 years, 11 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « base/threading/platform_thread_mac.mm ('k') | base/threading/platform_thread_unittest.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. 1 // Copyright (c) 2010 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #include "base/platform_thread.h" 5 #include "base/threading/platform_thread.h"
6 6
7 #include <errno.h> 7 #include <errno.h>
8 #include <sched.h> 8 #include <sched.h>
9 9
10 #include "base/logging.h" 10 #include "base/logging.h"
11 #include "base/safe_strerror_posix.h" 11 #include "base/safe_strerror_posix.h"
12 #include "base/scoped_ptr.h" 12 #include "base/scoped_ptr.h"
13 #include "base/thread_restrictions.h" 13 #include "base/thread_restrictions.h"
14 14
15 #if defined(OS_MACOSX) 15 #if defined(OS_MACOSX)
16 #include <mach/mach.h> 16 #include <mach/mach.h>
17 #include <sys/resource.h> 17 #include <sys/resource.h>
18 #include <algorithm> 18 #include <algorithm>
19 #endif 19 #endif
20 20
21 #if defined(OS_LINUX) 21 #if defined(OS_LINUX)
22 #include <dlfcn.h> 22 #include <dlfcn.h>
23 #include <sys/prctl.h> 23 #include <sys/prctl.h>
24 #include <sys/syscall.h> 24 #include <sys/syscall.h>
25 #include <unistd.h> 25 #include <unistd.h>
26 #endif 26 #endif
27 27
28 #if defined(OS_NACL) 28 #if defined(OS_NACL)
29 #include <sys/nacl_syscalls.h> 29 #include <sys/nacl_syscalls.h>
30 #endif 30 #endif
31 31
32 namespace base {
33
32 #if defined(OS_MACOSX) 34 #if defined(OS_MACOSX)
33 namespace base {
34 void InitThreading(); 35 void InitThreading();
35 } // namespace base
36 #endif 36 #endif
37 37
38 namespace { 38 namespace {
39 39
40 struct ThreadParams { 40 struct ThreadParams {
41 PlatformThread::Delegate* delegate; 41 PlatformThread::Delegate* delegate;
42 bool joinable; 42 bool joinable;
43 }; 43 };
44 44
45 } // namespace 45 void* ThreadFunc(void* params) {
46
47 static void* ThreadFunc(void* params) {
48 ThreadParams* thread_params = static_cast<ThreadParams*>(params); 46 ThreadParams* thread_params = static_cast<ThreadParams*>(params);
49 PlatformThread::Delegate* delegate = thread_params->delegate; 47 PlatformThread::Delegate* delegate = thread_params->delegate;
50 if (!thread_params->joinable) 48 if (!thread_params->joinable)
51 base::ThreadRestrictions::SetSingletonAllowed(false); 49 base::ThreadRestrictions::SetSingletonAllowed(false);
52 delete thread_params; 50 delete thread_params;
53 delegate->ThreadMain(); 51 delegate->ThreadMain();
54 return NULL; 52 return NULL;
55 } 53 }
56 54
55 bool CreateThread(size_t stack_size, bool joinable,
56 PlatformThread::Delegate* delegate,
57 PlatformThreadHandle* thread_handle) {
58 #if defined(OS_MACOSX)
59 base::InitThreading();
60 #endif // OS_MACOSX
61
62 bool success = false;
63 pthread_attr_t attributes;
64 pthread_attr_init(&attributes);
65
66 // Pthreads are joinable by default, so only specify the detached attribute if
67 // the thread should be non-joinable.
68 if (!joinable) {
69 pthread_attr_setdetachstate(&attributes, PTHREAD_CREATE_DETACHED);
70 }
71
72 #if defined(OS_MACOSX)
73 // The Mac OS X default for a pthread stack size is 512kB.
74 // Libc-594.1.4/pthreads/pthread.c's pthread_attr_init uses
75 // DEFAULT_STACK_SIZE for this purpose.
76 //
77 // 512kB isn't quite generous enough for some deeply recursive threads that
78 // otherwise request the default stack size by specifying 0. Here, adopt
79 // glibc's behavior as on Linux, which is to use the current stack size
80 // limit (ulimit -s) as the default stack size. See
81 // glibc-2.11.1/nptl/nptl-init.c's __pthread_initialize_minimal_internal. To
82 // avoid setting the limit below the Mac OS X default or the minimum usable
83 // stack size, these values are also considered. If any of these values
84 // can't be determined, or if stack size is unlimited (ulimit -s unlimited),
85 // stack_size is left at 0 to get the system default.
86 //
87 // Mac OS X normally only applies ulimit -s to the main thread stack. On
88 // contemporary OS X and Linux systems alike, this value is generally 8MB
89 // or in that neighborhood.
90 if (stack_size == 0) {
91 size_t default_stack_size;
92 struct rlimit stack_rlimit;
93 if (pthread_attr_getstacksize(&attributes, &default_stack_size) == 0 &&
94 getrlimit(RLIMIT_STACK, &stack_rlimit) == 0 &&
95 stack_rlimit.rlim_cur != RLIM_INFINITY) {
96 stack_size = std::max(std::max(default_stack_size,
97 static_cast<size_t>(PTHREAD_STACK_MIN)),
98 static_cast<size_t>(stack_rlimit.rlim_cur));
99 }
100 }
101 #endif // OS_MACOSX
102
103 if (stack_size > 0)
104 pthread_attr_setstacksize(&attributes, stack_size);
105
106 ThreadParams* params = new ThreadParams;
107 params->delegate = delegate;
108 params->joinable = joinable;
109 success = !pthread_create(thread_handle, &attributes, ThreadFunc, params);
110
111 pthread_attr_destroy(&attributes);
112 if (!success)
113 delete params;
114 return success;
115 }
116
117 } // namespace
118
57 // static 119 // static
58 PlatformThreadId PlatformThread::CurrentId() { 120 PlatformThreadId PlatformThread::CurrentId() {
59 // Pthreads doesn't have the concept of a thread ID, so we have to reach down 121 // Pthreads doesn't have the concept of a thread ID, so we have to reach down
60 // into the kernel. 122 // into the kernel.
61 #if defined(OS_MACOSX) 123 #if defined(OS_MACOSX)
62 return mach_thread_self(); 124 return mach_thread_self();
63 #elif defined(OS_LINUX) 125 #elif defined(OS_LINUX)
64 return syscall(__NR_gettid); 126 return syscall(__NR_gettid);
65 #elif defined(OS_FREEBSD) 127 #elif defined(OS_FREEBSD)
66 // TODO(BSD): find a better thread ID 128 // TODO(BSD): find a better thread ID
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after
128 #else 190 #else
129 // static 191 // static
130 void PlatformThread::SetName(const char* name) { 192 void PlatformThread::SetName(const char* name) {
131 // Leave it unimplemented. 193 // Leave it unimplemented.
132 194
133 // (This should be relatively simple to implement for the BSDs; I 195 // (This should be relatively simple to implement for the BSDs; I
134 // just don't have one handy to test the code on.) 196 // just don't have one handy to test the code on.)
135 } 197 }
136 #endif // defined(OS_LINUX) 198 #endif // defined(OS_LINUX)
137 199
138 namespace {
139
140 bool CreateThread(size_t stack_size, bool joinable,
141 PlatformThread::Delegate* delegate,
142 PlatformThreadHandle* thread_handle) {
143 #if defined(OS_MACOSX)
144 base::InitThreading();
145 #endif // OS_MACOSX
146
147 bool success = false;
148 pthread_attr_t attributes;
149 pthread_attr_init(&attributes);
150
151 // Pthreads are joinable by default, so only specify the detached attribute if
152 // the thread should be non-joinable.
153 if (!joinable) {
154 pthread_attr_setdetachstate(&attributes, PTHREAD_CREATE_DETACHED);
155 }
156
157 #if defined(OS_MACOSX)
158 // The Mac OS X default for a pthread stack size is 512kB.
159 // Libc-594.1.4/pthreads/pthread.c's pthread_attr_init uses
160 // DEFAULT_STACK_SIZE for this purpose.
161 //
162 // 512kB isn't quite generous enough for some deeply recursive threads that
163 // otherwise request the default stack size by specifying 0. Here, adopt
164 // glibc's behavior as on Linux, which is to use the current stack size
165 // limit (ulimit -s) as the default stack size. See
166 // glibc-2.11.1/nptl/nptl-init.c's __pthread_initialize_minimal_internal. To
167 // avoid setting the limit below the Mac OS X default or the minimum usable
168 // stack size, these values are also considered. If any of these values
169 // can't be determined, or if stack size is unlimited (ulimit -s unlimited),
170 // stack_size is left at 0 to get the system default.
171 //
172 // Mac OS X normally only applies ulimit -s to the main thread stack. On
173 // contemporary OS X and Linux systems alike, this value is generally 8MB
174 // or in that neighborhood.
175 if (stack_size == 0) {
176 size_t default_stack_size;
177 struct rlimit stack_rlimit;
178 if (pthread_attr_getstacksize(&attributes, &default_stack_size) == 0 &&
179 getrlimit(RLIMIT_STACK, &stack_rlimit) == 0 &&
180 stack_rlimit.rlim_cur != RLIM_INFINITY) {
181 stack_size = std::max(std::max(default_stack_size,
182 static_cast<size_t>(PTHREAD_STACK_MIN)),
183 static_cast<size_t>(stack_rlimit.rlim_cur));
184 }
185 }
186 #endif // OS_MACOSX
187
188 if (stack_size > 0)
189 pthread_attr_setstacksize(&attributes, stack_size);
190
191 ThreadParams* params = new ThreadParams;
192 params->delegate = delegate;
193 params->joinable = joinable;
194 success = !pthread_create(thread_handle, &attributes, ThreadFunc, params);
195
196 pthread_attr_destroy(&attributes);
197 if (!success)
198 delete params;
199 return success;
200 }
201
202 } // anonymous namespace
203
204 // static 200 // static
205 bool PlatformThread::Create(size_t stack_size, Delegate* delegate, 201 bool PlatformThread::Create(size_t stack_size, Delegate* delegate,
206 PlatformThreadHandle* thread_handle) { 202 PlatformThreadHandle* thread_handle) {
207 return CreateThread(stack_size, true /* joinable thread */, 203 return CreateThread(stack_size, true /* joinable thread */,
208 delegate, thread_handle); 204 delegate, thread_handle);
209 } 205 }
210 206
211 // static 207 // static
212 bool PlatformThread::CreateNonJoinable(size_t stack_size, Delegate* delegate) { 208 bool PlatformThread::CreateNonJoinable(size_t stack_size, Delegate* delegate) {
213 PlatformThreadHandle unused; 209 PlatformThreadHandle unused;
214 210
215 bool result = CreateThread(stack_size, false /* non-joinable thread */, 211 bool result = CreateThread(stack_size, false /* non-joinable thread */,
216 delegate, &unused); 212 delegate, &unused);
217 return result; 213 return result;
218 } 214 }
219 215
220 // static 216 // static
221 void PlatformThread::Join(PlatformThreadHandle thread_handle) { 217 void PlatformThread::Join(PlatformThreadHandle thread_handle) {
222 // Joining another thread may block the current thread for a long time, since 218 // Joining another thread may block the current thread for a long time, since
223 // the thread referred to by |thread_handle| may still be running long-lived / 219 // the thread referred to by |thread_handle| may still be running long-lived /
224 // blocking tasks. 220 // blocking tasks.
225 base::ThreadRestrictions::AssertIOAllowed(); 221 base::ThreadRestrictions::AssertIOAllowed();
226 pthread_join(thread_handle, NULL); 222 pthread_join(thread_handle, NULL);
227 } 223 }
224
225 } // namespace base
OLDNEW
« no previous file with comments | « base/threading/platform_thread_mac.mm ('k') | base/threading/platform_thread_unittest.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698