/third_party/pulseaudio/src/tests/ |
H A D | asyncmsgq-test.c | 29 #include <pulsecore/thread.h>
|
H A D | asyncq-test.c | 30 #include <pulsecore/thread.h>
|
H A D | flist-test.c | 29 #include <pulsecore/thread.h>
|
/third_party/rust/crates/rustix/src/thread/ |
H A D | setns.rs | 10 use crate::backend::thread::syscalls; 84 /// Reassociate the calling thread with the namespace associated with link referred to by `fd`. 101 /// Atomically move the calling thread into one or more of the same namespaces as the thread 104 /// `fd` must refer to a thread ID. See: `pidfd_open` and `clone`. 117 /// `unshare(flags)`—Disassociate parts of the current thread's execution
|
/third_party/rust/crates/nix/src/sys/ |
H A D | timer.rs | 20 //! use std::thread::yield_now; 180 if !std::thread::panicking() { in drop()
|
/third_party/rust/crates/nix/test/ |
H A D | test.rs | 120 if std::thread::panicking() { in drop()
|
H A D | test_unistd.rs | 618 use std::{thread, time}; in test_acct() 635 thread::sleep(time::Duration::from_millis(10)); in test_acct() 815 thread, in test_alarm() 840 thread::sleep(Duration::from_millis(100)); in test_alarm() 1198 use std::{fs, io, thread}; in test_setfsuid() 1211 // spawn a new thread where to test setfsuid in test_setfsuid() 1212 thread::spawn(move || { in test_setfsuid() 1227 // open the temporary file with the current thread filesystem UID in test_setfsuid()
|
/third_party/libunwind/libunwind/doc/ |
H A D | unw_resume.tex | 32 another thread results in undefined behavior (e.g., the program may 69 \Func{unw\_resume}() is thread-safe. If cursor \Var{cp} is in the
|
/third_party/ltp/testcases/kernel/sched/tool/ |
H A D | time-schedule.c | 110 "time-schedule [-h] [-thread] [-notest] [-pipe] [-fpu] [num_running]"; in main() 121 if (strcmp(argv[count], "-thread") == 0) { in main() 142 "\t-thread\t\tswitch threads not processes\n"); in main() 310 <use_threads> If TRUE, the yielding process is just a thread. in run_yielder() 318 pthread_t thread; in run_yielder() local 321 if (pthread_create(&thread, NULL, yielder_main, NULL) != 0) { in run_yielder() 322 fprintf(stderr, "Error creating thread\t%s\n", in run_yielder()
|
/third_party/skia/third_party/externals/swiftshader/third_party/subzero/src/ |
H A D | IceCompileServer.cpp | 45 #include <thread> 260 std::thread CompileThread([this, &InputStream]() { in run()
|
/third_party/skia/third_party/externals/tint/tools/src/cmd/remote-compile/ |
H A D | main.cc | 23 #include <thread> // NOLINT 355 std::thread([=] { in RunServer()
|
/third_party/skia/tools/ |
H A D | remote_demo.cpp | 16 #include <thread> 320 std::thread(gpu, render_to_gpu[kRead], gpu_to_render[kWrite]).detach(); in main()
|
/third_party/skia/third_party/externals/abseil-cpp/absl/base/internal/ |
H A D | sysinfo.cc | 49 #include <thread> // NOLINT(build/c++11) 138 return std::thread::hardware_concurrency(); in GetNumCPUs() 244 // our thread was preempted between clock reads. 389 // There is no current thread context in vcore context, but we need to give in GetTID() 390 // a reasonable answer if asked for a thread ID (e.g., in a signal handler). in GetTID() 395 // struct pthread_tcb, so we extract and return the thread ID from that. in GetTID() 397 // TODO(dcross): Akaros anticipates moving the thread ID to the uthread in GetTID() 421 // We set a bit per thread in this array to indicate that an ID is in 451 // Return a per-thread small integer ID from pthread's thread [all...] |
/third_party/rust/crates/rustix/src/backend/linux_raw/thread/ |
H A D | syscalls.rs | 1 //! linux_raw syscalls supporting `rustix::thread`. 16 use crate::thread::{ClockId, FutexFlags, FutexOperation, NanosleepRelativeResult, Timespec}; 294 pub(crate) fn unshare(flags: crate::thread::UnshareFlags) -> io::Result<()> {
|
/third_party/ffmpeg/tests/fate/ |
H A D | vcodec.mak | 251 mpeg2-thread \ 252 mpeg2-thread-ivlc 277 fate-vsynth%-mpeg2-thread: ENCOPTS = -qscale 10 -bf 2 -flags +ildct+ilme \ 279 fate-vsynth%-mpeg2-thread-ivlc: ENCOPTS = -qscale 10 -bf 2 -flags +ildct+ilme \ 288 mpeg4-thread \ 328 fate-vsynth%-mpeg4-thread: ENCOPTS = -b 500k -flags +mv4+aic \
|
/third_party/lzma/CPP/7zip/UI/FileManager/ |
H A D | ProgressDialog2.cpp | 955 INT_PTR CProgressDialog::Create(const UString &title, NWindows::CThread &thread, HWND wndParent)
in Create() argument 963 HANDLE h[] = { thread, _createDialogEvent };
in Create() 978 thread.Wait_Close();
in Create() 1398 NWindows::CThread thread;
in Create() local 1399 const WRes wres = thread.Create(MyThreadFunction, this);
in Create() 1402 CProgressDialog::Create(title, thread, parentWindow);
in Create()
|
/third_party/lzma/C/ |
H A D | LzFindMt.c | 89 Thread_CONSTRUCT(&p->thread)
in MtSync_Construct() 148 /* if Writing (Processing) thread was started, we must call MtSync_StopWriting() */
153 if (!Thread_WasCreated(&p->thread) || p->needStart)
in MtSync_StopWriting() 160 /* we don't use buffer in this thread after StopWriting().
in MtSync_StopWriting() 162 And we restore default UNLOCKED state for stopped thread */
in MtSync_StopWriting() 168 So the thread will see (p->stopWriting) at some
in MtSync_StopWriting() 170 The thread doesn't need to fill all avail free blocks,
in MtSync_StopWriting() 171 so we can get fast thread stop.
in MtSync_StopWriting() 193 if (Thread_WasCreated(&p->thread))
in MtSync_Destruct() 195 /* we want thread t in MtSync_Destruct() [all...] |
/third_party/pulseaudio/src/modules/macosx/ |
H A D | module-coreaudio-device.c | 44 #include <pulsecore/thread.h> 45 #include <pulsecore/thread-mq.h> 86 pa_thread *thread; member 866 /* create the message thread */ in pa__init() 867 if (!(u->thread = pa_thread_new(u->device_name, thread_func, u))) { in pa__init() 868 pa_log("Failed to create thread."); in pa__init() 935 if (u->thread) { in pa__done() 937 pa_thread_free(u->thread); in pa__done()
|
/third_party/pulseaudio/src/modules/ |
H A D | module-solaris.c | 60 #include <pulsecore/thread-mq.h> 62 #include <pulsecore/thread.h> 93 pa_thread *thread; member 411 /* Called from the IO thread. */ 485 /* Called from the IO thread. */ 1090 if (!(u->thread = pa_thread_new("solaris", thread_func, u))) { in pa__init() 1091 pa_log("Failed to create thread."); in pa__init() 1158 if (u->thread) { in pa__done() 1160 pa_thread_free(u->thread); in pa__done()
|
/third_party/python/Lib/test/ |
H A D | test_hashlib.py | 943 thread = threading.Thread(target=hash_in_chunks, 945 threads.append(thread) 947 for thread in threads: 948 thread.start() 949 for thread in threads: 950 thread.join()
|
H A D | test_xmlrpc.py | 354 thread = threading.Thread(target=run_server) 355 thread.start() 356 self.addCleanup(thread.join) 785 # start server thread to handle requests 787 thread = threading.Thread(target=self.threadFunc, args=serv_args) 788 thread.start() 789 self.addCleanup(thread.join) 796 # wait on the server thread to terminate 1110 #due to thread scheduling) 1330 # start server thread t [all...] |
/third_party/skia/third_party/externals/abseil-cpp/absl/synchronization/ |
H A D | mutex_test.cc | 28 #include <thread> // NOLINT(build/c++11) 56 // Hack to schedule a function to run on a thread pool thread after a 424 // another thread. 457 // Set release. Calling released_cv.Wait() should un-block thread A, in TEST() 465 // mutex.Await() in another thread. 498 // Set release. Calling released_cv.Wait() should un-block thread A, in TEST() 504 "unblock the absl::Mutex::Await call in another thread."; in TEST() 522 // Now cause a thread waiting on an always-false to time out in TEST() 581 // 3. main thread lock [all...] |
/third_party/libuv/src/win/ |
H A D | pipe.c | 605 /* Try to avoid flushing the pipe buffer in the thread pool. */ in uv__pipe_shutdown() 626 /* Run FlushFileBuffers in the thread pool. */ in uv__pipe_shutdown() 1016 /* Cancel synchronous read (which is happening in the thread pool). */ in uv__pipe_interrupt_read() 1017 HANDLE thread; in uv__pipe_interrupt_read() local 1022 thread = *thread_ptr; in uv__pipe_interrupt_read() 1023 if (thread == NULL) { in uv__pipe_interrupt_read() 1024 /* The thread pool thread has not yet reached the point of blocking, we in uv__pipe_interrupt_read() 1029 /* Spin until the thread has acknowledged (by setting the thread t in uv__pipe_interrupt_read() 1248 HANDLE thread; uv_pipe_zero_readfile_thread_proc() local [all...] |
/third_party/rust/crates/nix/test/sys/ |
H A D | test_socket.rs | 318 use std::thread; 336 let send_thread = thread::spawn(move || { in sendrecv() 585 let send_thread = thread::spawn(move || { in udp_recvmmsg() 656 let send_thread = thread::spawn(move || { in udp_recvmmsg_dontwait_short_read() 1208 use std::thread; in test_scm_rights_single_cmsg_multiple_fds() 1211 let thread = thread::spawn(move || { in test_scm_rights_single_cmsg_multiple_fds() 1251 thread.join().unwrap(); in test_scm_rights_single_cmsg_multiple_fds() 1507 use std::thread; in test_named_unixdomain() 1522 let thr = thread in test_named_unixdomain() [all...] |
/third_party/icu/icu4j/main/tests/core/src/com/ibm/icu/dev/test/rbbi/ |
H A D | RBBITest.java | 393 final AssertionError[] assertErr = new AssertionError[1]; // saves an error found from within a thread in TestBug12873() 419 for (Thread thread: threads) { in TestBug12873() 420 thread.start(); in TestBug12873() 422 for (Thread thread: threads) { in TestBug12873() 424 thread.join(); in TestBug12873()
|