Home
last modified time | relevance | path

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

123

/external/webrtc/rtc_base/synchronization/
Dsequence_checker.cc49 const rtc::PlatformThreadRef current_thread = rtc::CurrentThreadRef(); in IsCurrent() local
54 valid_thread_ = current_thread; in IsCurrent()
65 return rtc::IsThreadRefEqual(valid_thread_, current_thread); in IsCurrent()
78 const rtc::PlatformThreadRef current_thread = rtc::CurrentThreadRef(); in ExpectationToString() local
97 current_system_queue, reinterpret_cast<const void*>(current_thread)); in ExpectationToString()
104 } else if (!rtc::IsThreadRefEqual(valid_thread_, current_thread)) { in ExpectationToString()
/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/rtc_base/
Drace_checker.cc26 const PlatformThreadRef current_thread = CurrentThreadRef(); in Acquire() local
29 accessing_thread_ = current_thread; in Acquire()
34 return IsThreadRefEqual(accessing_thread, current_thread); in Acquire()
Dthread.cc894 Thread* current_thread = Thread::Current(); in PreRun() local
895 RTC_DCHECK(current_thread != nullptr); // AutoThread ensures this in PreRun()
896 RTC_DCHECK(current_thread->IsInvokeToThreadAllowed(this)); in PreRun()
898 ThreadManager::Instance()->RegisterSendAndCheckForCycles(current_thread, in PreRun()
904 [this, &ready, current_thread] { in PreRun()
907 current_thread->socketserver()->WakeUp(); in PreRun()
914 current_thread->socketserver()->Wait(kForever, false); in PreRun()
932 current_thread->socketserver()->WakeUp(); in PreRun()
Doperations_chain_unittest.cc82 Thread* current_thread = Thread::Current(); in StartAsynchronousOperation() local
84 RTC_FROM_HERE, [this, current_thread, unblock_operation_event, in StartAsynchronousOperation()
87 current_thread->PostTask( in StartAsynchronousOperation()
/external/webrtc/sdk/android/src/jni/
Dandroid_media_codec_common.h67 rtc::Thread* current_thread = rtc::Thread::Current(); in AllowBlockingCalls() local
68 if (current_thread != NULL) in AllowBlockingCalls()
69 current_thread->DEPRECATED_AllowBlockingCalls(); in AllowBlockingCalls()
/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/chromium-trace/catapult/devil/devil/utils/
Dreraiser_thread.py223 current_thread = threading.current_thread()
224 if isinstance(current_thread, ReraiserThread):
225 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
/external/llvm-project/lldb/test/API/functionalities/gdb_remote_client/
DTestRecognizeBreakpoint.py25 self.current_thread = 0
63 if self.after_cont and self.current_thread == 1:
87 self.current_thread = thread
/external/chromium-trace/catapult/common/py_trace_event/py_trace_event/trace_event_impl/
Dlog.py112 tid = threading.current_thread().ident
145 "tid": threading.current_thread().ident,
226 tid=threading.current_thread().ident,
286 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/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/idlelib/
Drpc.py113 print('Thread: %s' % threading.current_thread().name, file=erf)
133 self.sockthread = threading.current_thread()
156 s = self.location + " " + str(threading.current_thread().name)
229 if threading.current_thread() != self.sockthread:
239 if threading.current_thread() != self.sockthread:
308 if threading.current_thread() is self.sockthread:
/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.py508 thread = threading.current_thread()
526 thread = threading.current_thread()
572 thread = threading.current_thread()
705 if threading.current_thread() is not worker_handler:
716 if threading.current_thread() is not task_handler:
720 if threading.current_thread() is not result_handler:
Dmanagers.py234 threading.current_thread().name)
291 threading.current_thread().name)
304 threading.current_thread().name)
410 threading.current_thread().name = name
790 if threading.current_thread().name != 'MainThread':
791 name += '|' + threading.current_thread().name
804 threading.current_thread().name)
873 threading.current_thread().name)
/external/rust/crates/rayon-core/src/thread_pool/
Dmod.rs151 let curr = self.registry.current_thread()?; in current_thread_index()
178 let curr = self.registry.current_thread()?; in current_thread_has_pending_tasks()
/external/autotest/server/cros/
Dlockfile.py65 threading.current_thread = threading.currentThread
145 name = threading.current_thread().get_name()
/external/llvm-project/openmp/runtime/src/thirdparty/ittnotify/
Dittnotify_static.cpp1029 static volatile TIDT current_thread = 0; in _N_() local
1036 if (current_thread == 0) in _N_()
1038 if (PTHREAD_SYMBOLS) current_thread = __itt_thread_id(); in _N_()
1056 current_thread = 0; in _N_()
1070 static volatile TIDT current_thread = 0; in _N_() local
1080 if (current_thread == 0) in _N_()
1082 if (PTHREAD_SYMBOLS) current_thread = __itt_thread_id(); in _N_()
1169 current_thread = 0; in _N_()
1171 if (__itt_fini_ittlib_ptr == _N_(fini_ittlib)) current_thread = 0; in _N_()
/external/rust/crates/rayon-core/src/
Dregistry.rs297 pub(super) fn current_thread(&self) -> Option<&WorkerThread> { in current_thread() method
484 unsafe fn in_worker_cross<OP, R>(&self, current_thread: &WorkerThread, op: OP) -> R in in_worker_cross()
491 debug_assert!(current_thread.registry().id() != self.id()); in in_worker_cross()
492 let latch = SpinLatch::cross(current_thread); in in_worker_cross()
502 current_thread.wait_until(&job.latch); in in_worker_cross()
/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/tensorflow/tensorflow/python/debug/lib/
Dcheck_numerics_callback.py443 threading.current_thread().name)
467 threading.current_thread().name)

123