| /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 __anondd1ec57c0111::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/webrtc/base/ |
| D | signalthread.cc | 23 worker_(this), in SignalThread()
28 worker_.SetName("SignalThread", this); in SignalThread()
39 return worker_.SetName(name, obj); in SetName()
48 worker_.Start(); in Start()
63 worker_.Quit(); in Destroy()
68 worker_.Stop(); in Destroy()
92 ASSERT(worker_.IsCurrent()); in ContinueWork()
93 return worker_.ProcessMessages(0); in ContinueWork()
118 worker_.Stop(); in OnMessage()
|
| D | signalthread.h | 71 Thread* worker() { return &worker_; } in worker()
142 Worker worker_; variable
|
| /external/webrtc/talk/session/media/ |
| D | channelmanager_unittest.cc | 82 rtc::Thread worker_; member in cricket::ChannelManagerTest
104 worker_.Start(); in TEST_F()
107 EXPECT_TRUE(cm_->set_worker_thread(&worker_)); in TEST_F()
108 EXPECT_EQ(&worker_, cm_->worker_thread()); in TEST_F()
139 worker_.Start(); in TEST_F()
140 EXPECT_TRUE(cm_->set_worker_thread(&worker_)); in TEST_F()
144 new cricket::FakeTransportController(&worker_, ICEROLE_CONTROLLING); 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::__anonc062a47a0111::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 …]
|
| /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/webrtc/webrtc/p2p/base/ |
| D | stunserver_unittest.cc | 31 worker_(ss_.get()) { in StunServerTest()
39 worker_.Start(); in SetUp()
67 rtc::Thread worker_; member in StunServerTest
|
| /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_ GUARDED_BY(mu_); // After mutable vars.
|
| /external/webp/src/dec/ |
| D | vp8_dec.c | 61 WebPGetWorkerInterface()->Init(&dec->worker_); in VP8New()
665 if (!WebPGetWorkerInterface()->Sync(&dec->worker_)) return 0; in ParseFrame()
715 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/v8/src/d8/ |
| D | d8.h | 202 worker_(std::move(worker)) {} in WorkerThread()
207 std::shared_ptr<Worker> worker_;
|
| D | d8.cc | 3094 auto worker = std::move(worker_); in Run()
3095 worker_ = nullptr; in Run()
3106 worker_(worker), in ProcessMessageTask()
3109 void RunInternal() override { worker_->ProcessMessage(std::move(data_)); } in RunInternal()
3112 std::shared_ptr<Worker> worker_; member in v8::ProcessMessageTask
3132 : i::CancelableTask(task_manager), worker_(worker) {} in TerminateTask()
3137 worker_->running_.store(false); in RunInternal()
3141 std::shared_ptr<Worker> worker_; member in v8::TerminateTask
|
| /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::__anonbe68d06e0111::TestSyncMessageFilter
|