| /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 __anon906219b10111::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/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()
173 worker_->env()->compute_pool->Schedule(std::move(f)); in Schedule()
191 Status s = worker_->method(&call->request, &call->response); \
215 worker_->GetStepSequenceAsync( in GetStepSequenceHandler()
247 worker_->RunGraphAsync(call_opts, wrapped_request, wrapped_response, in RunGraphHandler()
278 worker_->GrpcRecvTensorAsync(call_opts, &call->request, &call->response, in RecvTensorHandlerRaw()
297 worker_->RecvBufAsync(call_opts, &call->request, &call->response, in RecvBufHandler()
315 worker_->CompleteGroupAsync( in CompleteGroupHandler()
334 worker_->CompleteInstanceAsync( in CompleteInstanceHandler()
[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 | 69 DCHECK(!worker_) << "Worker thread already exists!"; in AnnotateRequest()
74 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/v8/src/ |
| D | d8.h | 258 worker_(worker) {} in WorkerThread()
260 virtual void Run() { worker_->ExecuteInThread(); } in Run()
263 Worker* worker_;
|
| /external/webp/src/dec/ |
| D | vp8_dec.c | 61 WebPGetWorkerInterface()->Init(&dec->worker_); in VP8New()
662 if (!WebPGetWorkerInterface()->Sync(&dec->worker_)) return 0; in ParseFrame()
712 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 | 478 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::__anon60820dc30111::TestSyncMessageFilter
|