| /external/libvpx/libvpx/test/ |
| D | vp9_thread_test.cc | 30 virtual void SetUp() { vpx_get_worker_interface()->init(&worker_); } in SetUp()
32 virtual void TearDown() { vpx_get_worker_interface()->end(&worker_); } in TearDown()
43 VPxWorker worker_; member in __anon9d1832d80111::VPxWorkerThreadTest
54 EXPECT_NE(vpx_get_worker_interface()->sync(&worker_), 0); in TEST_P()
57 EXPECT_NE(vpx_get_worker_interface()->reset(&worker_), 0); in TEST_P()
61 worker_.hook = ThreadHook; in TEST_P()
62 worker_.data1 = &hook_data; in TEST_P()
63 worker_.data2 = &return_value; in TEST_P()
65 Run(&worker_); in TEST_P()
66 EXPECT_NE(vpx_get_worker_interface()->sync(&worker_), 0); in TEST_P()
[all …]
|
| /external/webrtc/modules/audio_processing/test/ |
| D | fake_recording_device.cc | 141 worker_ = in FakeRecordingDevice()
145 worker_ = std::make_unique<FakeRecordingDeviceLinear>(initial_mic_level); in FakeRecordingDevice()
148 worker_ = std::make_unique<FakeRecordingDeviceAgc1>(initial_mic_level); in FakeRecordingDevice()
159 RTC_CHECK(worker_); in MicLevel()
160 return worker_->mic_level(); in MicLevel()
164 RTC_CHECK(worker_); in SetMicLevel()
165 if (level != worker_->mic_level()) in SetMicLevel()
167 worker_->set_mic_level(level); in SetMicLevel()
171 RTC_DCHECK(worker_); in SetUndoMicLevel()
176 worker_->set_undo_mic_level(level); in SetUndoMicLevel()
[all …]
|
| D | fake_recording_device.h | 68 std::unique_ptr<FakeRecordingDeviceWorker> worker_;
|
| /external/webrtc/rtc_base/deprecated/ |
| D | signal_thread.cc | 27 : main_(Thread::Current()), worker_(this), state_(kInit), refcount_(1) { in DEPRECATED_SignalThread()
30 worker_.SetName("SignalThread", this); in DEPRECATED_SignalThread()
44 return worker_.SetName(name, obj); in SetName()
54 worker_.Start(); in Start()
73 worker_.Quit(); in Destroy()
78 worker_.Stop(); in Destroy()
104 RTC_DCHECK(worker_.IsCurrent()); in ContinueWork()
105 return worker_.ProcessMessages(0); in ContinueWork()
130 worker_.Stop(); in OnMessage()
|
| D | signal_thread.h | 78 Thread* worker() { return &worker_; } in worker()
151 Worker worker_; variable
|
| /external/webrtc/pc/ |
| D | channel_manager_unittest.cc | 50 worker_(rtc::Thread::Create()), in ChannelManagerTest()
100 std::unique_ptr<rtc::Thread> worker_; member in cricket::ChannelManagerTest
124 worker_->Start(); in TEST_F()
129 EXPECT_TRUE(cm_->set_worker_thread(worker_.get())); in TEST_F()
130 EXPECT_EQ(worker_.get(), cm_->worker_thread()); in TEST_F()
187 worker_->Start(); in TEST_F()
188 EXPECT_TRUE(cm_->set_worker_thread(worker_.get())); in TEST_F()
|
| /external/libchrome/base/task_scheduler/ |
| D | scheduler_single_thread_task_runner_manager.cc | 84 DCHECK(!worker_); in set_worker()
85 worker_ = worker; in set_worker()
90 DCHECK(worker_); in OnCanScheduleSequence()
92 worker_->WakeUp(); in OnCanScheduleSequence()
163 SchedulerWorker* worker_ = nullptr; member in base::internal::__anon836862560111::SchedulerWorkerDelegate
287 worker_(worker), in SchedulerSingleThreadTaskRunner()
290 DCHECK(worker_); in SchedulerSingleThreadTaskRunner()
352 outer_->UnregisterSchedulerWorker(worker_); in ~SchedulerSingleThreadTaskRunner()
369 worker_->WakeUp(); in PostTaskNow()
375 return static_cast<SchedulerWorkerDelegate*>(worker_->delegate()); in GetDelegate()
[all …]
|
| D | scheduler_worker_unittest.cc | 85 worker_ = MakeRefCounted<SchedulerWorker>( in SetUp()
89 ASSERT_TRUE(worker_); in SetUp()
90 worker_->Start(); in SetUp()
98 worker_->JoinForTesting(); in TearDown()
99 worker_ = nullptr; in TearDown()
137 scoped_refptr<SchedulerWorker> worker_; member in base::internal::__anonce7fc1310111::TaskSchedulerWorkerTest
152 EXPECT_EQ(outer_->worker_.get(), worker); in OnMainEntry()
164 EXPECT_EQ(outer_->worker_.get(), worker); in GetWork()
316 worker_->WakeUp(); in TEST_P()
347 worker_->WakeUp(); in TEST_P()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_service.cc | 104 : worker_(worker), in GrpcWorkerServiceThread()
114 worker_->env()->env->StartThread(ThreadOptions(), "grpc_worker_service", in Start()
174 worker_->env()->compute_pool->Schedule(std::move(f)); in Schedule()
195 Status s = worker_->method(&call->request, &call->response); \
202 worker_->env()->env->SchedClosure(std::move(closure)); \
204 worker_->env()->compute_pool->Schedule(std::move(closure)); \
224 worker_->GetStepSequenceAsync( in GetStepSequenceHandler()
236 worker_->RemoveCacheEntryForId(call->request.request_id()); in MarkRecvFinishedHandler()
249 worker_->RunGraphAsync(call_opts, wrapped_request, wrapped_response, in RunGraphHandler()
272 worker_->GrpcRecvTensorAsync( in RecvTensorHandlerRaw()
[all …]
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | qps_worker.cc | 102 : acquired_(false), server_port_(server_port), worker_(worker) {} in WorkerServiceImpl()
144 worker_->MarkDone(); in QuitWorker()
268 QpsWorker* worker_; member in grpc::testing::WorkerServiceImpl
|
| /external/tensorflow/tensorflow/core/platform/cloud/ |
| D | gcs_dns_cache.cc | 71 DCHECK(!worker_) << "Worker thread already exists!"; in AnnotateRequest()
76 worker_.reset(env_->StartThread({}, "gcs_dns_worker", in AnnotateRequest()
|
| D | gcs_dns_cache.h | 68 std::unique_ptr<Thread> worker_ TF_GUARDED_BY(mu_); // After mutable vars.
|
| /external/webp/src/dec/ |
| D | vp8_dec.c | 61 WebPGetWorkerInterface()->Init(&dec->worker_); in VP8New()
663 if (!WebPGetWorkerInterface()->Sync(&dec->worker_)) return 0; in ParseFrame()
713 WebPGetWorkerInterface()->End(&dec->worker_); in VP8Clear()
|
| D | vp8i_dec.h | 197 WebPWorker worker_; member
|
| D | frame_dec.c | 514 WebPWorker* const worker = &dec->worker_; in VP8ProcessRow()
604 ok = WebPGetWorkerInterface()->Sync(&dec->worker_); in VP8ExitCritical()
644 WebPWorker* const worker = &dec->worker_; in InitThreadContext()
|
| D | idec_dec.c | 483 if (!WebPGetWorkerInterface()->Sync(&dec->worker_)) { in DecodeRemaining()
|
| /external/libchrome/ipc/ |
| D | ipc_sync_channel_unittest.cc | 1062 worker_(worker), in TestSyncMessageFilter()
1078 worker_->Done(); in SendMessageOnHelperThread()
1084 Worker* worker_; member in IPC::__anon7ae8f74a0111::TestSyncMessageFilter
|