| /external/perf_data_converter/src/quipper/compat/cros/detail/ |
| thread.h | 16 explicit Thread(const string& name_prefix) : thread_(this, name_prefix) {}
18 void Start() override { thread_.Start(); }
20 void Join() override { thread_.Join(); }
22 pid_t tid() override { return thread_.tid(); }
28 base::DelegateSimpleThread thread_; member in class:quipper::Thread
|
| /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/perf_data_converter/src/quipper/compat/non_cros/detail/ |
| thread.h | 17 void Start() override { thread_ = std::thread(&Thread::Run, this); }
19 void Join() override { thread_.join(); }
21 pid_t tid() override { return thread_.native_handle(); }
27 std::thread thread_; member in class:quipper::Thread
|
| /external/perfetto/src/base/ |
| thread_task_runner.cc | 31 : thread_(std::move(other.thread_)), task_runner_(other.task_runner_) {
46 PERFETTO_DCHECK(thread_.joinable());
48 if (thread_.joinable())
49 thread_.join();
66 thread_ = std::thread(&ThreadTaskRunner::RunTaskThread, this,
|
| /external/adhd/cras/src/tests/ |
| audio_thread_unittest.cc | 86 thread_ = audio_thread_create();
91 audio_thread_destroy(thread_);
193 struct audio_thread *thread_; member in class:StreamDeviceSuite
221 thread_add_open_dev(thread_, &iodev);
222 adev = thread_->open_devs[CRAS_STREAM_OUTPUT];
225 thread_rm_open_dev(thread_, &iodev);
226 adev = thread_->open_devs[CRAS_STREAM_OUTPUT];
239 thread_add_open_dev(thread_, &iodev);
240 adev = thread_->open_devs[CRAS_STREAM_OUTPUT];
245 rc = thread_dev_start_ramp(thread_, &iodev, req)
[all...] |
| audio_thread_unittest_obsolete.cc | 528 thread_ = audio_thread_create();
529 ASSERT_TRUE(thread_);
530 thread_set_active_dev(thread_, &iodev_);
546 thread_add_stream(thread_, rstream_);
555 audio_thread_destroy(thread_);
660 struct audio_thread *thread_; member in class:WriteStreamSuite
683 rc = unified_io(thread_, &ts);
701 rc = unified_io(thread_, &ts);
725 rc = unified_io(thread_, &ts);
764 rc = unified_io(thread_, &ts)
1611 struct audio_thread *thread_; member in class:ActiveDevicesSuite
[all...] |
| /device/google/cuttlefish_common/common/vsoc/lib/ |
| lock_test.cpp | 42 : lock_(lock), thread_(&SimpleLocker::Work, this) {}
56 thread_.join();
63 std::thread thread_; member in class:SimpleLocker
|
| /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/perfetto/include/perfetto/base/ |
| thread_task_runner.h | 59 std::thread thread_; member in class:perfetto::base::ThreadTaskRunner
|
| /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();
|
| /external/gemmlowp/test/ |
| test_blocking_counter.cc | 31 pthread_create(&thread_, nullptr, ThreadFunc, this);
38 pthread_join(thread_, nullptr);
61 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::__anon36324::OnceInitTest::TestThread
106 pthread_t thread_; member in class:google::protobuf::__anon36324::OnceInitTest::TestThread
|
| /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();
|
| /device/google/cuttlefish_common/common/libs/threads/ |
| cuttlefish_thread.h | 153 pthread_create(&thread_, NULL, start, arg);
158 pthread_join(thread_, &value);
162 pthread_t thread_; member in class:cvd::ScopedThread
|
| /external/perfetto/test/ |
| task_runner_thread.cc | 44 thread_ = std::thread(&TaskRunnerThread::Run, this, std::move(delegate));
58 if (thread_.joinable())
59 thread_.join();
|
| /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
|
