Home
last modified time | relevance | path

Searched refs:current_thread (Results 1 – 25 of 60) sorted by relevance

123

/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/
Drx-currentthread.hpp131 struct current_thread : public scheduler_interface struct
134 typedef current_thread this_type; argument
135 current_thread(const this_type&);
142 typedef current_thread this_type;
168 typedef current_thread this_type;
240 current_thread() in current_thread() function
244 virtual ~current_thread() in ~current_thread() argument
264 static scheduler instance = make_scheduler<current_thread>(); in make_current_thread()
/external/webrtc/webrtc/base/
Dthread_checker_impl.cc26 const PlatformThreadRef current_thread = CurrentThreadRef(); in CalledOnValidThread() local
29 valid_thread_ = current_thread; in CalledOnValidThread()
30 return IsThreadRefEqual(valid_thread_, current_thread); in CalledOnValidThread()
Dthread.cc339 Thread *current_thread = Thread::Current(); in Send() local
340 ASSERT(current_thread != NULL); // AutoThread ensures this in Send()
346 smsg.thread = current_thread; in Send()
362 current_thread->ReceiveSendsFromThread(this); in Send()
363 current_thread->socketserver()->Wait(kForever, false); in Send()
381 current_thread->socketserver()->WakeUp(); in Send()
Dthread_unittest.cc255 Thread* current_thread = Thread::Current(); in TEST() local
256 current_thread->UnwrapCurrent(); in TEST()
264 current_thread->WrapCurrent(); in TEST()
290 Thread* current_thread = Thread::Current(); in TEST() local
291 ASSERT_TRUE(current_thread != NULL); in TEST()
305 Bind(&LocalFuncs::InvokeSet, current_thread, &called)); in TEST()
/external/python/cpython2/Lib/
D_threading_local.py161 current_thread().__dict__[key] = dict
167 d = current_thread().__dict__.get(key)
170 current_thread().__dict__[key] = d
247 from threading import current_thread, RLock
/external/webrtc/talk/app/webrtc/java/jni/
Dandroidmediacodeccommon.h87 rtc::Thread* current_thread = rtc::Thread::Current(); in AllowBlockingCalls() local
88 if (current_thread != NULL) in AllowBlockingCalls()
89 current_thread->SetAllowBlockingCalls(true); in AllowBlockingCalls()
/external/chromium-trace/catapult/devil/devil/utils/
Dreraiser_thread.py213 current_thread = threading.current_thread()
214 if isinstance(current_thread, ReraiserThread):
215 return current_thread._thread_group # pylint: disable=no-member
/external/python/cpython3/Lib/
D_threading_local.py161 thread = current_thread()
168 thread = current_thread()
242 from threading import current_thread, RLock
Dthreading.py791 self._daemonic = current_thread().daemon
1028 if self is current_thread():
1214 def current_thread(): function
1226 currentThread = current_thread
1318 current = current_thread()
/external/v8/tools/
Dlldb_commands.py14 def current_thread(debugger): function
18 return current_thread(debugger).GetSelectedFrame()
81 thread = current_thread(debugger)
/external/chromium-trace/catapult/common/py_trace_event/py_trace_event/trace_event_impl/
Dlog.py87 tid = threading.current_thread().ident
91 "pid": os.getpid(), "tid": threading.current_thread().ident,
155 tid = threading.current_thread().ident
/external/python/cpython2/Lib/multiprocessing/
Dsynchronize.py153 if threading.current_thread().name != 'MainThread':
154 name += '|' + threading.current_thread().name
178 if threading.current_thread().name != 'MainThread':
179 name += '|' + threading.current_thread().name
Dpool.py323 thread = threading.current_thread()
336 thread = threading.current_thread()
388 thread = threading.current_thread()
510 if threading.current_thread() is not worker_handler:
521 if threading.current_thread() is not task_handler:
525 if threading.current_thread() is not result_handler:
Dmanagers.py230 threading.current_thread().name)
280 threading.current_thread().name)
293 threading.current_thread().name)
421 threading.current_thread().name = name
740 if threading.current_thread().name != 'MainThread':
741 name += '|' + threading.current_thread().name
754 threading.current_thread().name)
819 threading.current_thread().name)
/external/toolchain-utils/crb/
Dmachine_manager_singleton.py94 m.autotest_run = threading.current_thread()
99 m.autotest_run = threading.current_thread()
104 m.autotest_run = threading.current_thread()
/external/python/cpython3/Lib/idlelib/
Drpc.py114 print('Thread: %s' % threading.current_thread().name, file=erf)
134 self.sockthread = threading.current_thread()
157 s = self.location + " " + str(threading.current_thread().name)
230 if threading.current_thread() != self.sockthread:
240 if threading.current_thread() != self.sockthread:
309 if threading.current_thread() is self.sockthread:
/external/Reactive-Extensions/RxCpp/Rx/v2/test/sources/
Dinterval.cpp35 rxsc::current_thread::clock_type::duration initial,
36 rxsc::current_thread::clock_type::duration period,
/external/python/cpython3/Lib/multiprocessing/
Dsynchronize.py168 if threading.current_thread().name != 'MainThread':
169 name += '|' + threading.current_thread().name
193 if threading.current_thread().name != 'MainThread':
194 name += '|' + threading.current_thread().name
Dpool.py407 thread = threading.current_thread()
420 thread = threading.current_thread()
466 thread = threading.current_thread()
593 if threading.current_thread() is not worker_handler:
604 if threading.current_thread() is not task_handler:
608 if threading.current_thread() is not result_handler:
Dmanagers.py224 threading.current_thread().name)
281 threading.current_thread().name)
294 threading.current_thread().name)
400 threading.current_thread().name = name
777 if threading.current_thread().name != 'MainThread':
778 name += '|' + threading.current_thread().name
791 threading.current_thread().name)
860 threading.current_thread().name)
/external/autotest/server/cros/
Dlockfile.py61 threading.current_thread = threading.currentThread
141 name = threading.current_thread().get_name()
/external/python/cpython3/Lib/test/
Dtest_threading.py163 threading.current_thread()
491 self.assertEqual(main.ident, threading.current_thread().ident)
496 threading.current_thread().ident)
958 current_thread = threading.current_thread()
959 self.assertRaises(RuntimeError, current_thread.join);
/external/python/cpython2/Lib/test/
Dtest_threading.py152 threading.current_thread()
777 current_thread = threading.current_thread()
778 self.assertRaises(RuntimeError, current_thread.join);
/external/libvpx/libvpx/third_party/googletest/src/src/
Dgtest-port.cc456 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local
461 thread_to_thread_locals->find(current_thread); in GetValueOnCurrentThread()
464 std::make_pair(current_thread, ThreadLocalValues())).first; in GetValueOnCurrentThread()
465 StartWatcherThreadFor(current_thread); in GetValueOnCurrentThread()
/external/mesa3d/src/gtest/src/
Dgtest-port.cc400 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local
405 thread_to_thread_locals->find(current_thread); in GetValueOnCurrentThread()
408 std::make_pair(current_thread, ThreadLocalValues())).first; in GetValueOnCurrentThread()
409 StartWatcherThreadFor(current_thread); in GetValueOnCurrentThread()

123