OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/threading/platform_thread.h" | 5 #include "base/threading/platform_thread.h" |
6 | 6 |
7 #import <Foundation/Foundation.h> | 7 #import <Foundation/Foundation.h> |
8 #include <dlfcn.h> | 8 #include <dlfcn.h> |
9 #include <mach/mach.h> | 9 #include <mach/mach.h> |
10 #include <mach/mach_time.h> | 10 #include <mach/mach_time.h> |
11 #include <mach/thread_policy.h> | 11 #include <mach/thread_policy.h> |
12 | 12 |
13 #include "base/lazy_instance.h" | 13 #include "base/lazy_instance.h" |
14 #include "base/logging.h" | 14 #include "base/logging.h" |
15 #include "base/threading/thread_local.h" | 15 #include "base/threading/thread_id_name_manager.h" |
16 #include "base/tracked_objects.h" | 16 #include "base/tracked_objects.h" |
17 | 17 |
18 namespace base { | 18 namespace base { |
19 | 19 |
20 namespace { | |
21 | |
22 LazyInstance<ThreadLocalPointer<char> >::Leaky | |
23 current_thread_name = LAZY_INSTANCE_INITIALIZER; | |
24 | |
25 } // namespace | |
26 | |
27 // If Cocoa is to be used on more than one thread, it must know that the | 20 // If Cocoa is to be used on more than one thread, it must know that the |
28 // application is multithreaded. Since it's possible to enter Cocoa code | 21 // application is multithreaded. Since it's possible to enter Cocoa code |
29 // from threads created by pthread_thread_create, Cocoa won't necessarily | 22 // from threads created by pthread_thread_create, Cocoa won't necessarily |
30 // be aware that the application is multithreaded. Spawning an NSThread is | 23 // be aware that the application is multithreaded. Spawning an NSThread is |
31 // enough to get Cocoa to set up for multithreaded operation, so this is done | 24 // enough to get Cocoa to set up for multithreaded operation, so this is done |
32 // if necessary before pthread_thread_create spawns any threads. | 25 // if necessary before pthread_thread_create spawns any threads. |
33 // | 26 // |
34 // http://developer.apple.com/documentation/Cocoa/Conceptual/Multithreading/Crea
tingThreads/chapter_4_section_4.html | 27 // http://developer.apple.com/documentation/Cocoa/Conceptual/Multithreading/Crea
tingThreads/chapter_4_section_4.html |
35 void InitThreading() { | 28 void InitThreading() { |
36 static BOOL multithreaded = [NSThread isMultiThreaded]; | 29 static BOOL multithreaded = [NSThread isMultiThreaded]; |
37 if (!multithreaded) { | 30 if (!multithreaded) { |
38 // +[NSObject class] is idempotent. | 31 // +[NSObject class] is idempotent. |
39 [NSThread detachNewThreadSelector:@selector(class) | 32 [NSThread detachNewThreadSelector:@selector(class) |
40 toTarget:[NSObject class] | 33 toTarget:[NSObject class] |
41 withObject:nil]; | 34 withObject:nil]; |
42 multithreaded = YES; | 35 multithreaded = YES; |
43 | 36 |
44 DCHECK([NSThread isMultiThreaded]); | 37 DCHECK([NSThread isMultiThreaded]); |
45 } | 38 } |
46 } | 39 } |
47 | 40 |
48 // static | 41 // static |
49 void PlatformThread::SetName(const char* name) { | 42 void PlatformThread::SetName(const char* name) { |
50 current_thread_name.Pointer()->Set(const_cast<char*>(name)); | 43 ThreadIdNameManager::GetInstance()->SetName(CurrentId(), name); |
51 tracked_objects::ThreadData::InitializeThreadContext(name); | 44 tracked_objects::ThreadData::InitializeThreadContext(name); |
52 | 45 |
53 // pthread_setname_np is only available in 10.6 or later, so test | 46 // pthread_setname_np is only available in 10.6 or later, so test |
54 // for it at runtime. | 47 // for it at runtime. |
55 int (*dynamic_pthread_setname_np)(const char*); | 48 int (*dynamic_pthread_setname_np)(const char*); |
56 *reinterpret_cast<void**>(&dynamic_pthread_setname_np) = | 49 *reinterpret_cast<void**>(&dynamic_pthread_setname_np) = |
57 dlsym(RTLD_DEFAULT, "pthread_setname_np"); | 50 dlsym(RTLD_DEFAULT, "pthread_setname_np"); |
58 if (!dynamic_pthread_setname_np) | 51 if (!dynamic_pthread_setname_np) |
59 return; | 52 return; |
60 | 53 |
61 // Mac OS X does not expose the length limit of the name, so | 54 // Mac OS X does not expose the length limit of the name, so |
62 // hardcode it. | 55 // hardcode it. |
63 const int kMaxNameLength = 63; | 56 const int kMaxNameLength = 63; |
64 std::string shortened_name = std::string(name).substr(0, kMaxNameLength); | 57 std::string shortened_name = std::string(name).substr(0, kMaxNameLength); |
65 // pthread_setname() fails (harmlessly) in the sandbox, ignore when it does. | 58 // pthread_setname() fails (harmlessly) in the sandbox, ignore when it does. |
66 // See http://crbug.com/47058 | 59 // See http://crbug.com/47058 |
67 dynamic_pthread_setname_np(shortened_name.c_str()); | 60 dynamic_pthread_setname_np(shortened_name.c_str()); |
68 } | 61 } |
69 | 62 |
70 // static | |
71 const char* PlatformThread::GetName() { | |
72 return current_thread_name.Pointer()->Get(); | |
73 } | |
74 | |
75 namespace { | 63 namespace { |
76 | 64 |
77 void SetPriorityNormal(mach_port_t mach_thread_id) { | 65 void SetPriorityNormal(mach_port_t mach_thread_id) { |
78 // Make thread standard policy. | 66 // Make thread standard policy. |
79 // Please note that this call could fail in rare cases depending | 67 // Please note that this call could fail in rare cases depending |
80 // on runtime conditions. | 68 // on runtime conditions. |
81 thread_standard_policy policy; | 69 thread_standard_policy policy; |
82 kern_return_t result = thread_policy_set(mach_thread_id, | 70 kern_return_t result = thread_policy_set(mach_thread_id, |
83 THREAD_STANDARD_POLICY, | 71 THREAD_STANDARD_POLICY, |
84 (thread_policy_t)&policy, | 72 (thread_policy_t)&policy, |
(...skipping 96 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
181 case kThreadPriority_Normal: | 169 case kThreadPriority_Normal: |
182 SetPriorityNormal(mach_thread_id); | 170 SetPriorityNormal(mach_thread_id); |
183 break; | 171 break; |
184 case kThreadPriority_RealtimeAudio: | 172 case kThreadPriority_RealtimeAudio: |
185 SetPriorityRealtimeAudio(mach_thread_id); | 173 SetPriorityRealtimeAudio(mach_thread_id); |
186 break; | 174 break; |
187 } | 175 } |
188 } | 176 } |
189 | 177 |
190 } // namespace base | 178 } // namespace base |
OLD | NEW |