| /external/webrtc/webrtc/base/ |
| platform_thread.cc | 102 thread_(NULL) {
105 thread_(0) {
114 RTC_DCHECK(!thread_);
132 RTC_DCHECK(!thread_) << "Thread already started?";
140 thread_ = ::CreateThread(NULL, 1024 * 1024, &StartThread, this,
142 RTC_CHECK(thread_) << "CreateThread failed";
147 RTC_CHECK_EQ(0, pthread_create(&thread_, &attr, &StartThread, this));
154 return thread_ != nullptr;
156 return thread_ != 0;
167 QueueUserAPC(&RaiseFlag, thread_, reinterpret_cast<ULONG_PTR>(&stop_))
[all...] |
| criticalsection.cc | 26 CS_DEBUG_CODE(thread_ = 0);
46 RTC_DCHECK(!thread_);
47 thread_ = pthread_self();
64 RTC_DCHECK(!thread_);
65 thread_ = pthread_self();
83 thread_ = 0;
99 return pthread_equal(thread_, pthread_self());
111 return thread_ != 0;
|
| signalthread_unittest.cc | 75 thread_ = new SlowSignalThread(this);
76 thread_->SignalWorkDone.connect(this, &SignalThreadTest::OnWorkComplete);
89 SlowSignalThread* thread_; member in class:SignalThreadTest
160 thread_->Start();
169 thread_->Start();
171 thread_->Release();
181 thread_->Start();
183 thread_->Destroy(true);
190 thread_->Start();
192 thread_->Destroy(false)
[all...] |
| thread.cc | 132 : thread_(Thread::Current()),
133 previous_state_(thread_->SetAllowBlockingCalls(false)) {
137 ASSERT(thread_->IsCurrent());
138 thread_->SetAllowBlockingCalls(previous_state_);
145 thread_(NULL),
206 thread_ = CreateThread(NULL, 0, (LPTHREAD_START_ROUTINE)PreRun, init, 0,
208 if (thread_) {
217 int error_code = pthread_create(&thread_, &attr, PreRun, init);
235 if (thread_ != NULL) {
236 if (!CloseHandle(thread_)) {
[all...] |
| asyncinvoker.h | 168 if (thread_ == nullptr)
170 invoker_.AsyncInvoke<ReturnT, FunctorT>(thread_, functor, id);
181 if (thread_ == nullptr)
183 invoker_.AsyncInvokeDelayed<ReturnT, FunctorT>(thread_, functor, delay_ms,
196 if (thread_ == nullptr)
198 invoker_.AsyncInvoke<ReturnT, FunctorT, HostT>(thread_, functor, callback,
211 if (thread_ == nullptr)
213 invoker_.AsyncInvoke<ReturnT, FunctorT, HostT>(thread_, functor, callback,
219 // Callback when |thread_| is destroyed.
223 Thread* thread_ GUARDED_BY(crit_)
[all...] |
| asyncinvoker.cc | 80 GuardedAsyncInvoker::GuardedAsyncInvoker() : thread_(Thread::Current()) {
81 thread_->SignalQueueDestroyed.connect(this,
90 if (thread_ == nullptr)
92 invoker_.Flush(thread_, id);
99 RTC_DCHECK(thread_ != nullptr);
100 thread_ = nullptr;
|
| networkmonitor.cc | 29 NetworkMonitorBase::NetworkMonitorBase() : thread_(Thread::Current()) {}
34 thread_->Post(this, UPDATE_NETWORKS_MESSAGE);
|
| platform_thread.h | 87 HANDLE thread_; member in class:rtc::PlatformThread
93 pthread_t thread_; member in class:rtc::PlatformThread
|
| networkmonitor.h | 66 Thread* thread_; member in class:rtc::NetworkMonitorBase
|
| /external/webrtc/webrtc/modules/utility/source/ |
| process_thread_impl.cc | 51 RTC_DCHECK(!thread_.get());
62 RTC_DCHECK(!thread_.get());
63 if (thread_.get())
78 thread_.reset(
80 thread_->Start();
85 if(!thread_.get())
95 thread_->Stop();
101 // Since DeRegisterModule also checks thread_, we also need to hold the
105 thread_.reset();
147 if (thread_.get()
[all...] |
| /external/libmojo/base/android/ |
| application_status_listener_unittest.cc | 48 thread_("ApplicationStatusTest thread"),
53 thread_.Start();
54 thread_.task_runner()->PostTask(
76 EXPECT_EQ(thread_.message_loop(), base::MessageLoop::current());
95 base::Thread thread_; member in class:base::android::__anon23633::MultiThreadedTest
|
| /external/webrtc/webrtc/test/ |
| frame_generator_capturer.cc | 68 thread_(FrameGeneratorCapturer::Run, this, "FrameGeneratorCapturer"),
80 thread_.Stop();
91 thread_.Start();
92 thread_.SetPriority(rtc::kHighPriority);
|
| direct_transport.cc | 27 thread_(NetworkProcess, this, "NetworkProcess"),
31 thread_.Start();
47 thread_.Stop();
|
| fake_audio_device.cc | 33 thread_(FakeAudioDevice::Run, this, "FakeAudioDevice"),
46 thread_.Stop();
56 thread_.Start();
57 thread_.SetPriority(rtc::kHighPriority);
|
| /system/bt/service/test/ |
| stub_ipc_handler_linux.cc | 29 thread_("IPCHandlerLinux"),
|
| /external/gemmlowp/test/ |
| test_blocking_counter.cc | 30 pthread_create(&thread_, nullptr, ThreadFunc, this);
36 pthread_join(thread_, nullptr);
57 pthread_t thread_; member in class:gemmlowp::Thread
|
| /external/protobuf/src/google/protobuf/stubs/ |
| once_unittest.cc | 79 thread_ = CreateThread(NULL, 0, &Start, this, 0, NULL);
81 pthread_create(&thread_, NULL, &Start, this);
95 WaitForSingleObject(thread_, INFINITE);
96 CloseHandle(thread_);
98 pthread_join(thread_, NULL);
104 HANDLE thread_; member in class:google::protobuf::__anon29934::OnceInitTest::TestThread
106 pthread_t thread_; member in class:google::protobuf::__anon29934::OnceInitTest::TestThread
|
| /art/runtime/jdwp/ |
| jdwp_main.cc | 220 thread_(nullptr),
459 thread_ = Thread::Current();
463 MutexLock locker(thread_, thread_start_lock_);
465 thread_start_cond_.Broadcast(thread_);
469 CHECK_EQ(thread_->GetState(), kNative);
470 Locks::mutator_lock_->AssertNotHeld(thread_);
471 thread_->SetState(kWaitingInMainDebuggerLoop);
499 MutexLock mu(thread_, attach_lock_);
501 attach_cond_.Broadcast(thread_);
513 CHECK_EQ(thread_->GetState(), kWaitingInMainDebuggerLoop)
[all...] |
| /external/webrtc/webrtc/p2p/base/ |
| basicpacketsocketfactory.cc | 28 : thread_(Thread::Current()),
33 : thread_(thread),
39 : thread_(NULL),
201 if (thread_) {
202 ASSERT(thread_ == Thread::Current());
203 return thread_->socketserver();
|
| /external/webrtc/webrtc/examples/peerconnection/client/linux/ |
| main.cc | 24 : thread_(thread), wnd_(wnd), conductor_(NULL), client_(NULL) {}
42 thread_->Quit();
49 rtc::Thread* thread_; member in class:CustomSocketServer
|
| /device/linaro/hikey/bluetooth/ |
| async_fd_watcher.cc | 79 thread_ = std::thread([this]() { ThreadRoutine(); });
80 if (!thread_.joinable()) return -1;
89 if (std::this_thread::get_id() != thread_.get_id()) {
90 thread_.join();
|
| /external/drm_hwcomposer/ |
| worker.h | 76 std::unique_ptr<std::thread> thread_; member in class:android::Worker
|
| /external/libchrome/base/ |
| sync_socket_unittest.cc | 19 thread_(this, "HangingReceiveThread") {
20 thread_.Start();
36 thread_.Join();
41 base::DelegateSimpleThread thread_; member in class:__anon22856::HangingReceiveThread
|
| /external/parameter-framework/asio-1.10.6/include/asio/detail/ |
| posix_thread.hpp | 87 ::pthread_t thread_; member in class:asio::detail::posix_thread
|
| /external/webrtc/webrtc/system_wrappers/source/ |
| condition_variable_unittest.cc | 147 CondVarTest() : thread_(&WaitingRunFunction, &baton_, "CondVarTest") {}
150 thread_.Start();
161 thread_.Stop();
168 rtc::PlatformThread thread_; member in class:webrtc::__anon39249::CondVarTest
|
