Home
last modified time | relevance | path

Searched refs:thread (Results 451 - 475 of 758) sorted by relevance

1...<<11121314151617181920>>...31

/third_party/rust/crates/nix/test/
H A Dtest.rs120 if std::thread::panicking() { in drop()
H A Dtest_unistd.rs618 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 Dunw_resume.tex32 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 Dtime-schedule.c110 "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 DIceCompileServer.cpp45 #include <thread>
260 std::thread CompileThread([this, &InputStream]() { in run()
/third_party/skia/third_party/externals/tint/tools/src/cmd/remote-compile/
H A Dmain.cc23 #include <thread> // NOLINT
355 std::thread([=] { in RunServer()
/third_party/skia/tools/
H A Dremote_demo.cpp16 #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 Dsysinfo.cc49 #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 Dsyscalls.rs1 //! 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 Dvcodec.mak251 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 DProgressDialog2.cpp955 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 DLzFindMt.c89 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 Dmodule-coreaudio-device.c44 #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 Dmodule-solaris.c60 #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 Dtest_hashlib.py943 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 Dtest_xmlrpc.py354 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 Dmutex_test.cc28 #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 Dpipe.c605 /* 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 Dtest_socket.rs318 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 DRBBITest.java393 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()
/third_party/libwebsockets/lib/misc/threadpool/
H A Dthreadpool.c73 pthread_t thread; member
162 "(queued %dms, on thread: %dms, " in __lws_threadpool_task_dump()
313 * tsi context for any wsis bound to a worked thread that need it
349 * writable from the correct service thread in lws_threadpool_tsi_context()
373 * writable from the correct service thread in lws_threadpool_tsi_context()
567 * a "callback on writable" request on the service thread and in lws_threadpool_worker()
570 * This allows the work on the thread to be synchronized to the in lws_threadpool_worker()
726 if (pthread_create(&tp->pool_list[n].thread, NULL, in lws_threadpool_create()
728 lwsl_err("thread creation failed\n"); in lws_threadpool_create()
732 pthread_setname_np(tp->pool_list[n].thread, nam in lws_threadpool_create()
[all...]
/third_party/node/deps/v8/src/snapshot/
H A Dcode-serializer.cc423 StressOffThreadDeserializeThread thread(isolate, cached_data); in Deserialize()
424 CHECK(thread.Start()); in Deserialize()
425 thread.Join(); in Deserialize()
426 return thread.Finalize(isolate, source, origin_options); in Deserialize()
427 // TODO(leszeks): Compare off-thread deserialized data to on-thread. in Deserialize()
482 // the main thread in StartDeserializeOffThread()
509 // holds the result of the off-thread sanity check. in FinishOffThreadDeserialize()
519 // off-thread. in FinishOffThreadDeserialize()
523 // The only kind of sanity check we can't test for off-thread i in FinishOffThreadDeserialize()
[all...]
/third_party/rust/crates/once_cell/tests/
H A Dit.rs262 use crossbeam_utils::thread::scope;
453 std::thread::sleep(std::time::Duration::from_secs(2)); in reentrant_init()
702 use crossbeam_utils::thread::scope;
839 use crossbeam_utils::thread::scope;
/third_party/skia/third_party/externals/swiftshader/src/Pipeline/
H A DSpirvShaderDebugger.cpp1317 // terminate() ensures that the debugger thread stack is at the same
1321 // trap() updates the debugger thread with the stack frames and
1323 // trap() will notify the debugger that the thread has paused, and will
1374 std::shared_ptr<vk::dbg::Thread> thread;
2165 thread = state->debugger->ctx->lock().currentThread();
2170 thread->enter(state->debugger->spirvFile, "SPIR-V", [&](vk::dbg::Frame &frame) {
2187 thread->exit();
2192 thread->exit();
2200 // Update the thread frames from the stack of scopes
2224 thread
[all...]
/third_party/elfutils/src/
H A Dstack.c457 thread_callback (Dwfl_Thread *thread, void *thread_arg) in thread_callback() argument
460 pid_t tid = dwfl_thread_tid (thread); in thread_callback()
463 switch (dwfl_thread_getframes (thread, frame_callback, thread_arg)) in thread_callback()
569 N_("-1 needs a thread id given by -p.")); in parse_opt()
673 N_("Show the backtrace of only one thread"), 0 }, in main()
675 N_("Show at most MAXFRAMES per thread (default 256, use 0 for unlimited)"), 0 }, in main()
685 .doc = N_("Print a stack for each thread in a process or core file.\n\ in main()

Completed in 37 milliseconds

1...<<11121314151617181920>>...31