| /external/tensorflow/tensorflow/contrib/batching/python/ops/ |
| D | batch_ops_test.py | 58 worker_thread = threading.Thread(target=worker)
59 worker_thread.start()
61 worker_thread.join()
99 worker_thread = threading.Thread(target=worker)
100 worker_thread.start()
102 worker_thread.join()
133 worker_thread = threading.Thread(target=worker)
134 worker_thread.start()
136 worker_thread.join()
184 worker_thread = threading.Thread(target=worker)
[all …]
|
| /external/webrtc/talk/session/media/ |
| D | audiomonitor.cc | 47 voice_channel_->worker_thread()->Clear(this); in ~AudioMonitor()
55 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_START); in Start()
59 voice_channel_->worker_thread()->Post(this, MSG_MONITOR_STOP); in Stop()
67 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
75 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
78 voice_channel_->worker_thread()->Clear(this); in OnMessage()
83 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in OnMessage()
101 assert(rtc::Thread::Current() == voice_channel_->worker_thread()); in PollVoiceChannel()
110 voice_channel_->worker_thread()->PostDelayed(rate_, this, MSG_MONITOR_POLL); in PollVoiceChannel()
|
| D | mediamonitor.h | 45 MediaMonitor(rtc::Thread* worker_thread,
69 MediaMonitorT(MC* media_channel, rtc::Thread* worker_thread, in MediaMonitorT() argument
71 : MediaMonitor(worker_thread, monitor_thread), in MediaMonitorT()
|
| D | channelmanager.cc | 83 rtc::Thread* worker_thread) { in ChannelManager() argument
84 Construct(me, dme, cm, worker_thread); in ChannelManager()
88 rtc::Thread* worker_thread) { in ChannelManager() argument
92 worker_thread); in ChannelManager()
98 rtc::Thread* worker_thread) { in Construct() argument
104 worker_thread_ = worker_thread; in Construct()
|
| D | channel.cc | 430 this, worker_thread(), rtc::Thread::Current())); in StartConnectionMonitor()
843 ASSERT(worker_thread() == rtc::Thread::Current()); in SignalDtlsSetupFailure_w()
1136 ASSERT(worker_thread() == rtc::Thread::Current()); in AddRecvStream_w()
1141 ASSERT(worker_thread() == rtc::Thread::Current()); in RemoveRecvStream_w()
1375 worker_thread()->PostDelayed(kEarlyMediaTimeout, this, in SetEarlyMedia()
1379 worker_thread()->Clear(this, MSG_EARLYMEDIATIMEOUT); in SetEarlyMedia()
1415 media_monitor_.reset(new VoiceMediaMonitor(media_channel(), worker_thread(), in StartMediaMonitor()
1499 ASSERT(worker_thread() == rtc::Thread::Current()); in SetLocalContent_w()
1544 ASSERT(worker_thread() == rtc::Thread::Current()); in SetRemoteContent_w()
1683 worker_thread()->Invoke<void>(Bind( in SetRenderer()
[all …]
|
| D | mediamonitor.cc | 41 MediaMonitor::MediaMonitor(rtc::Thread* worker_thread, in MediaMonitor() argument
43 : worker_thread_(worker_thread), in MediaMonitor()
|
| D | channelmanager_unittest.cc | 95 EXPECT_EQ(rtc::Thread::Current(), cm_->worker_thread()); in TEST_F()
106 EXPECT_EQ(rtc::Thread::Current(), cm_->worker_thread()); in TEST_F()
108 EXPECT_EQ(&worker_, cm_->worker_thread()); in TEST_F()
|
| /external/pdfium/third_party/libopenjpeg20/ |
| D | thread.c | 600 opj_worker_thread_t* worker_thread; member
622 opj_worker_thread_t* worker_thread,
658 opj_worker_thread_t* worker_thread; in opj_worker_thread_function() local
663 worker_thread = (opj_worker_thread_t*) user_data; in opj_worker_thread_function()
664 tp = worker_thread->tp; in opj_worker_thread_function()
668 opj_worker_thread_job_t* job = opj_thread_pool_get_next_job(tp, worker_thread, in opj_worker_thread_function()
757 opj_worker_thread_t* worker_thread, in opj_thread_pool_get_next_job() argument
790 if (!worker_thread->marked_as_waiting) { in opj_thread_pool_get_next_job()
793 worker_thread->marked_as_waiting = OPJ_TRUE; in opj_thread_pool_get_next_job()
806 item->worker_thread = worker_thread; in opj_thread_pool_get_next_job()
[all …]
|
| /external/webrtc/talk/app/webrtc/ |
| D | mediacontroller.cc | 44 MediaController(rtc::Thread* worker_thread, in MediaController() argument
46 : worker_thread_(worker_thread), channel_manager_(channel_manager) { in MediaController()
47 RTC_DCHECK(nullptr != worker_thread); in MediaController()
92 rtc::Thread* worker_thread, in Create() argument
94 return new MediaController(worker_thread, channel_manager); in Create()
|
| D | peerconnectionfactory.cc | 99 rtc::Thread* worker_thread, in CreatePeerConnectionFactory() argument
105 new rtc::RefCountedObject<PeerConnectionFactory>(worker_thread, in CreatePeerConnectionFactory()
137 rtc::Thread* worker_thread, in PeerConnectionFactory() argument
145 worker_thread_(worker_thread), in PeerConnectionFactory()
149 ASSERT(worker_thread != NULL); in PeerConnectionFactory()
318 rtc::Thread* PeerConnectionFactory::worker_thread() { in worker_thread() function in webrtc::PeerConnectionFactory
|
| D | peerconnectionfactory.h | 92 virtual rtc::Thread* worker_thread();
98 rtc::Thread* worker_thread,
|
| /external/autotest/scheduler/ |
| D | thread_lib.py | 154 worker_thread = ExceptionRememberingThread(
161 self.drone_threads[drone] = worker_thread
163 worker_thread.setName('%s.%s' %
165 worker_thread.daemon = True
166 worker_thread.start()
|
| /external/libchrome/base/task/ |
| D | cancelable_task_tracker_unittest.cc | 85 Thread worker_thread("worker thread"); in TEST_F() local
86 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
88 ignore_result(task_tracker_.PostTask(worker_thread.task_runner().get(), in TEST_F()
93 worker_thread.task_runner().get(), FROM_HERE, in TEST_F()
99 worker_thread.Stop(); in TEST_F()
165 Thread worker_thread("worker thread"); in TEST_F() local
166 ASSERT_TRUE(worker_thread.Start()); in TEST_F()
169 worker_thread.task_runner().get(), FROM_HERE, DoNothing(), in TEST_F()
175 worker_thread.Stop(); in TEST_F()
|
| /external/bcc/tools/ |
| D | offcputime_example.txt | 354 worker_thread
361 worker_thread
368 worker_thread
375 worker_thread
382 worker_thread
389 worker_thread
396 worker_thread
471 worker_thread
563 worker_thread
681 kworker/6:2;ret_from_fork;kthread;worker_thread;schedule 3940583
[all …]
|
| D | stackcount_example.txt | 472 worker_thread
538 worker_thread
547 worker_thread
584 worker_thread
600 worker_thread
616 worker_thread
665 worker_thread
687 worker_thread
830 kworker/7:0;-;ret_from_fork;kthread;worker_thread;schedule;__schedule 1
835 kworker/2:0;-;ret_from_fork;kthread;worker_thread;schedule;__schedule 1
|
| /external/webrtc/webrtc/p2p/client/ |
| D | fakeportallocator.h | 85 FakePortAllocatorSession(rtc::Thread* worker_thread, in FakePortAllocatorSession() argument
93 worker_thread_(worker_thread), in FakePortAllocatorSession()
143 FakePortAllocator(rtc::Thread* worker_thread, in FakePortAllocator() argument
145 : worker_thread_(worker_thread), factory_(factory) { in FakePortAllocator()
|
| D | socketmonitor.cc | 25 rtc::Thread* worker_thread, in ConnectionMonitor() argument
28 worker_thread_ = worker_thread; in ConnectionMonitor()
|
| /external/webrtc/webrtc/p2p/base/ |
| D | transportcontroller.cc | 41 rtc::Thread* worker_thread, in TransportController() argument
44 worker_thread_(worker_thread), in TransportController()
349 RTC_DCHECK(worker_thread()->IsCurrent()); in GetSslRole_w()
408 RTC_DCHECK(worker_thread()->IsCurrent()); in SetLocalTransportDescription_w()
427 RTC_DCHECK(worker_thread()->IsCurrent()); in SetRemoteTransportDescription_w()
451 RTC_DCHECK(worker_thread()->IsCurrent()); in AddRemoteCandidates_w()
465 RTC_DCHECK(worker_thread()->IsCurrent()); in ReadyForRemoteCandidates_w()
476 RTC_DCHECK(worker_thread()->IsCurrent()); in GetStats_w()
|
| D | faketransportcontroller.h | 481 explicit FakeTransportController(rtc::Thread* worker_thread) in FakeTransportController() argument
482 : TransportController(rtc::Thread::Current(), worker_thread, nullptr), in FakeTransportController()
485 FakeTransportController(rtc::Thread* worker_thread, IceRole role) in FakeTransportController() argument
486 : TransportController(rtc::Thread::Current(), worker_thread, nullptr), in FakeTransportController()
497 worker_thread()->Invoke<void>( in Connect()
|
| /external/webrtc/talk/media/base/ |
| D | mediaengine.h | 74 virtual bool Init(rtc::Thread* worker_thread) = 0;
143 virtual bool Init(rtc::Thread* worker_thread) { in Init() argument
144 if (!voice_.Init(worker_thread)) in Init()
|
| /external/ltp/testcases/realtime/func/pi-tests/ |
| D | sbrk_mutex.c | 78 void *worker_thread(void *arg) in worker_thread() function
136 create_fifo_thread(worker_thread, (void *)t, in main()
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/ |
| D | grpc_worker_service.cc | 404 for (auto& worker_thread : threads_) { in Shutdown() local
405 worker_thread->Shutdown(); in Shutdown()
412 for (auto& worker_thread : threads_) { in HandleRPCsLoop() local
413 worker_thread->Start(); in HandleRPCsLoop()
415 for (auto& worker_thread : threads_) { in HandleRPCsLoop() local
416 worker_thread->Join(); in HandleRPCsLoop()
|
| /external/grpc-grpc/test/core/gpr/ |
| D | cpu_test.cc | 67 static void worker_thread(void* arg) { in worker_thread() function
120 thd[i] = grpc_core::Thread("grpc_cpu_test", &worker_thread, &ct); in cpu_test()
|
| /external/ltp/testcases/realtime/func/prio-wake/ |
| D | prio-wake.c | 130 void *worker_thread(void *arg) in worker_thread() function
209 create_fifo_thread(worker_thread, (void *)(intptr_t) i, prio); in main()
|
| /external/syzkaller/pkg/report/testdata/linux/report/ |
| D | 65 | 77 [ 248.321189] ? worker_thread+0x4a3/0x1990
81 [ 248.338580] worker_thread+0x223/0x1990
203 [ 248.906283] ? worker_thread+0x4a3/0x1990
207 [ 248.923671] worker_thread+0x223/0x1990
|