| /external/libchrome/base/synchronization/ |
| D | lock_unittest.cc | 19 class BasicLockTestThread : public PlatformThread::Delegate {
32 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); in ThreadMain()
38 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); in ThreadMain()
58 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle)); in TEST()
69 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); in TEST()
75 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); in TEST()
82 PlatformThread::Sleep(TimeDelta::FromMilliseconds(rand() % 20)); in TEST()
86 PlatformThread::Join(handle); in TEST()
94 class TryLockTestThread : public PlatformThread::Delegate {
124 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle)); in TEST()
[all …]
|
| D | waitable_event_unittest.cc | 151 class WaitableEventSignaler : public PlatformThread::Delegate {
159 PlatformThread::Sleep(delay_); in ThreadMain()
177 PlatformThread::Create(0, &signaler, &thread); in TEST()
182 PlatformThread::Join(thread); in TEST()
196 PlatformThread::Create(0, &signaler, &thread); in TEST()
203 PlatformThread::Join(thread); in TEST()
218 PlatformThread::Create(0, &signaler, &thread); in TEST()
224 PlatformThread::Join(thread); in TEST()
266 PlatformThread::Create(0, &signaler, &thread); in TEST()
271 PlatformThread::Join(thread); in TEST()
|
| D | atomic_flag_unittest.cc | 33 PlatformThread::YieldCurrentThread(); in BusyWaitUntilFlagIsSet()
78 PlatformThread::Sleep(TimeDelta::FromMilliseconds(20)); in TEST()
88 PlatformThread::Sleep(TimeDelta::FromMilliseconds(20)); in TEST()
93 PlatformThread::YieldCurrentThread(); in TEST()
107 PlatformThread::Sleep(TimeDelta::FromMilliseconds(20)); in TEST()
|
| D | lock.cc | 23 DCHECK(owning_thread_ref_ == PlatformThread::CurrentRef()); in AssertAcquired()
27 DCHECK(owning_thread_ref_ == PlatformThread::CurrentRef()); in CheckHeldAndUnmark()
33 owning_thread_ref_ = PlatformThread::CurrentRef(); in CheckUnheldAndMark()
|
| /external/libchrome/base/threading/ |
| D | platform_thread_posix.cc | 48 PlatformThread::Delegate* delegate;
54 PlatformThread::Delegate* delegate = nullptr; in ThreadFunc()
68 PlatformThread::SetCurrentThreadPriority(thread_params->priority); in ThreadFunc()
73 PlatformThread::CurrentHandle().platform_handle(), in ThreadFunc()
74 PlatformThread::CurrentId()); in ThreadFunc()
79 PlatformThread::CurrentHandle().platform_handle(), in ThreadFunc()
80 PlatformThread::CurrentId()); in ThreadFunc()
88 PlatformThread::Delegate* delegate, in CreateThread()
136 PlatformThreadId PlatformThread::CurrentId() { in CurrentId()
162 PlatformThreadRef PlatformThread::CurrentRef() { in CurrentRef()
[all …]
|
| D | platform_thread_unittest.cc | 26 class TrivialThread : public PlatformThread::Delegate {
48 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle)); in TEST()
49 PlatformThread::Join(handle); in TEST()
60 ASSERT_TRUE(PlatformThread::Create(0, &thread[n], &handle[n])); in TEST()
62 PlatformThread::Join(handle[n]); in TEST()
75 ASSERT_TRUE(PlatformThread::Create(0, &thread, &handle)); in TEST()
76 PlatformThread::Detach(handle); in TEST()
87 ASSERT_TRUE(PlatformThread::Create(0, &thread[n], &handle[n])); in TEST()
88 PlatformThread::Detach(handle[n]); in TEST()
98 class FunctionTestThread : public PlatformThread::Delegate {
[all …]
|
| D | thread_id_name_manager_unittest.cc | 68 base::PlatformThreadId a_id = base::PlatformThread::CurrentId(); in TEST_F()
69 base::PlatformThread::SetName("First Name"); in TEST_F()
72 base::PlatformThread::SetName("New name"); in TEST_F()
74 base::PlatformThread::SetName(""); in TEST_F()
80 base::PlatformThreadId a_id = base::PlatformThread::CurrentId(); in TEST_F()
81 base::PlatformThread::SetName("Test Name"); in TEST_F()
84 base::PlatformThread::SetName("New name"); in TEST_F()
87 base::PlatformThread::SetName("Test Name"); in TEST_F()
90 base::PlatformThread::SetName(""); in TEST_F()
|
| D | simple_thread.cc | 41 PlatformThread::Join(thread_); in Join()
52 ? PlatformThread::CreateWithPriority(options_.stack_size, this, in StartAsync()
54 : PlatformThread::CreateNonJoinableWithPriority( in StartAsync()
70 tid_ = PlatformThread::CurrentId(); in ThreadMain()
75 PlatformThread::SetName(name); in ThreadMain()
|
| D | thread.cc | 112 ? PlatformThread::CreateWithPriority(options.stack_size, this, in StartWithOptions()
114 : PlatformThread::CreateNonJoinableWithPriority( in StartWithOptions()
183 PlatformThread::Join(thread_); in Stop()
253 DCHECK_EQ(id_, PlatformThread::CurrentId()); in Run()
293 id_ = PlatformThread::CurrentId(); in ThreadMain()
298 PlatformThread::SetName(name_.c_str()); in ThreadMain()
|
| D | platform_thread_linux.cc | 102 SetThreadCgroupsForThreadPriority(PlatformThread::CurrentId(), priority); in SetCurrentThreadPriorityForPlatform()
128 void PlatformThread::SetName(const std::string& name) { in SetName()
136 if (PlatformThread::CurrentId() == getpid()) in SetName()
153 void PlatformThread::SetThreadPriority(PlatformThreadId thread_id, in SetThreadPriority()
|
| D | thread_unittest.cc | 52 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(500)); in Init()
203 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(20)); in TEST_F()
222 &base::PlatformThread::Sleep), in TEST_F()
249 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(20)); in TEST_F()
294 base::PlatformThread::Sleep(base::TimeDelta::Max()); in TEST_F()
375 base::PlatformThread::YieldCurrentThread(); in TEST_F()
377 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(20)); in TEST_F()
512 base::BindOnce(&base::PlatformThread::Sleep, kSleepPerTestTask)); in TEST_F()
|
| D | thread_checker_impl.cc | 37 return thread_id_ == PlatformThread::CurrentRef(); in CalledOnValidThread()
52 thread_id_ = PlatformThread::CurrentRef(); in EnsureAssigned()
|
| /external/sfntly/cpp/src/test/ |
| D | lock_test.cc | 27 class BasicLockTestThread : public PlatformThread::Delegate {
40 PlatformThread::Sleep(rand() % 20); in ThreadMain()
46 PlatformThread::Sleep(rand() % 20); in ThreadMain()
66 EXPECT_TRUE(PlatformThread::Create(&thread, &handle)); in BasicLockTest()
77 PlatformThread::Sleep(rand() % 20); in BasicLockTest()
83 PlatformThread::Sleep(rand() % 20); in BasicLockTest()
90 PlatformThread::Sleep(rand() % 20); in BasicLockTest()
94 PlatformThread::Join(handle); in BasicLockTest()
104 class TryLockTestThread : public PlatformThread::Delegate {
134 EXPECT_TRUE(PlatformThread::Create(&thread, &handle)); in TryLockTest()
[all …]
|
| D | platform_thread.cc | 24 PlatformThread::Delegate* delegate = in ThreadFunc()
25 static_cast<PlatformThread::Delegate*>(params); in ThreadFunc()
31 bool PlatformThread::Create(Delegate* delegate, in Create()
43 void PlatformThread::Join(PlatformThreadHandle thread_handle) { in Join()
51 void PlatformThread::Sleep(int32_t duration_ms) { in Sleep()
58 PlatformThread::Delegate* delegate =
59 static_cast<PlatformThread::Delegate*>(params);
65 bool PlatformThread::Create(Delegate* delegate,
79 void PlatformThread::Join(PlatformThreadHandle thread_handle) {
85 void PlatformThread::Sleep(int32_t duration_ms) {
|
| D | platform_thread.h | 43 class PlatformThread {
69 PlatformThread() {} in PlatformThread() function
70 NO_COPY_AND_ASSIGN(PlatformThread);
|
| /external/webrtc/webrtc/base/ |
| D | platform_thread.cc | 94 PlatformThread::PlatformThread(ThreadRunFunction func, in PlatformThread() function in rtc::PlatformThread
111 PlatformThread::~PlatformThread() { in PlatformThread()
119 DWORD WINAPI PlatformThread::StartThread(void* param) { in PlatformThread()
120 static_cast<PlatformThread*>(param)->Run(); in PlatformThread()
124 void* PlatformThread::StartThread(void* param) { in PlatformThread()
125 static_cast<PlatformThread*>(param)->Run(); in PlatformThread()
130 void PlatformThread::Start() { in PlatformThread()
151 bool PlatformThread::IsRunning() const { in PlatformThread()
160 void PlatformThread::Stop() { in PlatformThread()
178 void PlatformThread::Run() { in PlatformThread()
[all …]
|
| D | platform_thread.h | 57 class PlatformThread {
59 PlatformThread(ThreadRunFunction func, void* obj, const char* thread_name);
60 virtual ~PlatformThread();
95 RTC_DISALLOW_COPY_AND_ASSIGN(PlatformThread);
|
| D | platform_thread_unittest.cc | 26 rtc::PlatformThread thread(&NullRunFunction, nullptr, "PlatformThreadTest"); in TEST()
41 rtc::PlatformThread thread(&SetFlagRunFunction, &flag, "RunFunctionIsCalled"); in TEST()
|
| /external/libchrome/base/process/ |
| D | kill_posix.cc | 118 PlatformThread::Sleep(TimeDelta::FromMilliseconds(100)); in WaitForProcessesToExit()
138 class BackgroundReaper : public PlatformThread::Delegate {
166 PlatformThread::CreateNonJoinable( in EnsureProcessTerminated()
178 PlatformThread::CreateNonJoinable( in EnsureProcessGetsReaped()
|
| /external/libchrome/dbus/ |
| D | dbus_statistics.cc | 47 origin_thread_id_(base::PlatformThread::CurrentId()) { in DBusStatistics()
51 DCHECK_EQ(origin_thread_id_, base::PlatformThread::CurrentId()); in ~DBusStatistics()
66 if (base::PlatformThread::CurrentId() != origin_thread_id_) { in AddStat()
68 << base::PlatformThread::CurrentId(); in AddStat()
89 DCHECK_EQ(origin_thread_id_, base::PlatformThread::CurrentId()); in GetStats()
|
| /external/libchrome/mojo/public/cpp/system/tests/ |
| D | wait_unittest.cc | 131 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(200)); in TEST_F()
151 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(200)); in TEST_F()
169 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(200)); in TEST_F()
239 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(200)); in TEST_F()
257 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(200)); in TEST_F()
284 base::PlatformThread::Sleep(base::TimeDelta::FromMilliseconds(200)); in TEST_F()
|
| /external/libchrome/base/ |
| D | lazy_instance_helpers.cc | 40 PlatformThread::YieldCurrentThread(); in NeedsLazyInstance()
42 PlatformThread::Sleep(TimeDelta::FromMilliseconds(1)); in NeedsLazyInstance()
|
| /external/libchrome/base/message_loop/ |
| D | message_loop_task_runner.cc | 24 valid_thread_id_ = PlatformThread::CurrentId(); in BindToCurrentThread()
46 return valid_thread_id_ == PlatformThread::CurrentId(); in RunsTasksInCurrentSequence()
|
| D | message_loop_perftest.cc | 64 PlatformThread::Join(thread_handle_); in Join()
69 class Delegate final : public PlatformThread::Delegate {
102 PlatformThread::Create(0, &delegate_, &thread_handle_); in Start()
|
| /external/libchrome/base/task/sequence_manager/test/ |
| D | lazy_thread_controller_for_test.cc | 17 thread_ref_(PlatformThread::CurrentRef()) { in LazyThreadControllerForTest()
93 return thread_ref_ == PlatformThread::CurrentRef(); in RunsTasksInCurrentSequence()
|