| /third_party/cef/patch/patches/ |
| D | message_loop.patch | 9 +#include "base/task/current_thread.h" 32 diff --git base/task/current_thread.cc base/task/current_thread.cc 34 --- base/task/current_thread.cc 35 +++ base/task/current_thread.cc 45 diff --git base/task/current_thread.h base/task/current_thread.h 47 --- base/task/current_thread.h 48 +++ base/task/current_thread.h
|
| /third_party/cef/tests/cefclient/browser/ |
| D | util_gtk.cc | 17 base::PlatformThreadId current_thread = base::PlatformThread::CurrentId(); in ScopedGdkThreadsEnter() local 18 take_lock_ = current_thread != locked_thread_; in ScopedGdkThreadsEnter() 22 locked_thread_ = current_thread; in ScopedGdkThreadsEnter()
|
| D | main_message_loop_multithreaded_gtk.cc | 24 base::PlatformThreadId current_thread = base::PlatformThread::CurrentId(); in lock_enter() local 25 CHECK(current_thread != g_global_lock_thread); in lock_enter() 28 g_global_lock_thread = current_thread; in lock_enter()
|
| /third_party/rust/crates/tracing/tracing-futures/src/executor/ |
| D | futures_01.rs | 49 runtime::{current_thread, Runtime, TaskExecutor}, 134 impl Instrumented<current_thread::Runtime> { 191 pub fn handle(&self) -> Instrumented<current_thread::Handle> { in handle() 281 impl WithDispatch<current_thread::Runtime> { 339 pub fn handle(&self) -> WithDispatch<current_thread::Handle> { in handle()
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | thread-posix.c | 64 PA_STATIC_TLS_DECLARE(current_thread, thread_free_cb); 78 PA_STATIC_TLS_SET(current_thread, t); in internal_thread_func() 149 if ((t = PA_STATIC_TLS_GET(current_thread))) in pa_thread_self() 160 PA_STATIC_TLS_SET(current_thread, t); in pa_thread_self()
|
| /third_party/python/Lib/ |
| D | _threading_local.py | 161 thread = current_thread() 168 thread = current_thread() 242 from threading import current_thread, RLock
|
| D | threading.py | 864 self._daemonic = current_thread().daemon 1085 if self is current_thread(): 1423 def current_thread(): function 1444 return current_thread()
|
| /third_party/python/Lib/idlelib/ |
| D | rpc.py | 113 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:
|
| /third_party/python/Lib/multiprocessing/ |
| D | synchronize.py | 168 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
|
| D | managers.py | 243 threading.current_thread().name) 300 threading.current_thread().name) 313 threading.current_thread().name) 419 threading.current_thread().name = name 799 if threading.current_thread().name != 'MainThread': 800 name += '|' + threading.current_thread().name 813 threading.current_thread().name) 882 threading.current_thread().name)
|
| D | pool.py | 508 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:
|
| /third_party/python/Lib/test/ |
| D | test_threading.py | 172 self.assertIsNotNone(threading.current_thread().ident) 174 ident.append(threading.current_thread().ident) 214 threading.current_thread() 587 self.assertEqual(main.ident, threading.current_thread().ident) 592 threading.current_thread().ident) 1244 current_thread = threading.current_thread() 1245 self.assertRaises(RuntimeError, current_thread.join);
|
| /third_party/googletest/googletest/src/ |
| D | gtest-port.cc | 544 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local 549 thread_to_thread_locals->find(current_thread); in GetValueOnCurrentThread() 552 std::make_pair(current_thread, ThreadLocalValues())).first; in GetValueOnCurrentThread() 553 StartWatcherThreadFor(current_thread); in GetValueOnCurrentThread()
|
| /third_party/mesa3d/src/gtest/src/ |
| D | gtest-port.cc | 539 DWORD current_thread = ::GetCurrentThreadId(); in GetValueOnCurrentThread() local 544 thread_to_thread_locals->find(current_thread); in GetValueOnCurrentThread() 547 std::make_pair(current_thread, ThreadLocalValues())).first; in GetValueOnCurrentThread() 548 StartWatcherThreadFor(current_thread); in GetValueOnCurrentThread()
|
| /third_party/python/Lib/multiprocessing/dummy/ |
| D | __init__.py | 65 current_process = threading.current_thread
|
| /third_party/rust/crates/tracing/tracing-subscriber/src/fmt/format/ |
| D | mod.rs | 928 let current_thread = std::thread::current(); in format_event() localVariable 929 match current_thread.name() { in format_event() 935 write!(writer, "{:0>2?} ", current_thread.id())?; in format_event() 1056 let current_thread = std::thread::current(); in format_event() localVariable 1057 match current_thread.name() { in format_event() 1063 write!(writer, "{:0>2?} ", current_thread.id())?; in format_event()
|
| D | json.rs | 305 let current_thread = std::thread::current(); in format_event() localVariable 306 match current_thread.name() { in format_event() 313 .serialize_entry("threadName", &format!("{:?}", current_thread.id()))?; in format_event()
|
| /third_party/python/Lib/asyncio/ |
| D | events.py | 652 threading.current_thread() is threading.main_thread()): 657 % threading.current_thread().name)
|
| D | proactor_events.py | 632 if threading.current_thread() is threading.main_thread(): 680 if threading.current_thread() is threading.main_thread():
|
| D | unix_events.py | 1427 if threading.current_thread() is threading.main_thread(): 1441 threading.current_thread() is threading.main_thread()):
|
| /third_party/cef/libcef/browser/native/ |
| D | menu_runner_mac.mm | 11 #include "base/task/current_thread.h"
|
| /third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/ |
| D | sctp_bsd_addr.c | 169 thread_terminate(current_thread());
|
| /third_party/rust/crates/tracing/ |
| D | CONTRIBUTING.md | 173 /// # tokio::runtime::current_thread::block_on_all( 201 /// # tokio::runtime::current_thread::block_on_all(
|
| /third_party/python/Misc/NEWS.d/ |
| D | 3.7.0a2.rst | 456 ``threading.current_thread()`` should not return a dummy thread at shutdown.
|
| /third_party/python/Doc/faq/ |
| D | library.rst | 319 print('Worker', threading.current_thread(), end=' ') 323 print('Worker', threading.current_thread(), end=' ')
|