Home
last modified time | relevance | path

Searched refs:wait (Results 1 - 25 of 1670) sorted by relevance

12345678910>>...67

/third_party/NuttX/fs/vfs/
H A Dfs_poll.c36 #include "linux/wait.h"
103 /* The only case that an error should occur here is if the wait were in poll_semtake()
114 static void set_add_poll_wait_flag(poll_wait_head wait, bool add_queue_flag) in set_add_poll_wait_flag() argument
116 wait->add_queue_flag = add_queue_flag; in set_add_poll_wait_flag()
119 static int destroy_poll_wait(poll_wait_head wait) in destroy_poll_wait() argument
126 for (i = 0; i < wait->inline_index; ++i) in destroy_poll_wait()
128 wait_node = &wait->inline_items[i]; in destroy_poll_wait()
134 while (wait->table) in destroy_poll_wait()
136 curr_table = wait->table; in destroy_poll_wait()
137 wait in destroy_poll_wait()
158 get_poll_item(poll_wait_head wait) get_poll_item() argument
185 poll_wait_head wait = p->wait; add_pollwait_queue() local
198 wait_sem_time(poll_wait_head wait, const struct timespec *time_ptr) wait_sem_time() argument
210 file_poll(struct file *filep, poll_table *wait) file_poll() argument
222 fdesc_poll(int fd, poll_table *wait) fdesc_poll() argument
251 query_fd(int fd, poll_table *wait) query_fd() argument
274 query_fds(struct pollfd *fds, nfds_t nfds, poll_table *wait) query_fds() argument
[all...]
/third_party/FreeBSD/sys/compat/linuxkpi/common/include/linux/
H A Dwait.h65 void __wake_up_interruptible(wait_queue_head_t *wait);
66 void __init_waitqueue_head(wait_queue_head_t *wait);
69 * @ingroup wait
77 * <li>Please make sure the input parameter wait is valid, otherwise, the system would be crash.</li>
80 * @param wait [IN] struct of the process that registered on the wait queue .
87 #define init_waitqueue_head(wait) __init_waitqueue_head(wait)
90 * @ingroup wait
91 * @brief wakeup the process that registered on the wait queu
[all...]
/third_party/FreeBSD/sys/compat/linuxkpi/common/src/
H A Dlinux_semaphore.c34 #include "linux/wait.h"
130 void __init_waitqueue_head(wait_queue_head_t *wait) in __init_waitqueue_head() argument
132 if (wait == NULL) { in __init_waitqueue_head()
135 (VOID)LOS_EventInit(&wait->stEvent); in __init_waitqueue_head()
136 spin_lock_init(&wait->lock); in __init_waitqueue_head()
137 LOS_ListInit(&wait->poll_queue); in __init_waitqueue_head()
140 void __wake_up_interruptible(wait_queue_head_t *wait) in __wake_up_interruptible() argument
142 if (wait == NULL) { in __wake_up_interruptible()
145 (VOID)LOS_EventWrite(&wait->stEvent, 0x1); in __wake_up_interruptible()
146 notify_poll(wait); in __wake_up_interruptible()
149 __wake_up_interruptible_poll(wait_queue_head_t *wait, pollevent_t key) __wake_up_interruptible_poll() argument
[all...]
/third_party/rust/crates/rustix/src/process/
H A Dwait.rs6 /// Options for modifying the behavior of wait/waitpid
9 const NOHANG = backend::process::wait::WNOHANG as _;
11 const UNTRACED = backend::process::wait::WUNTRACED as _;
13 const CONTINUED = backend::process::wait::WCONTINUED as _;
37 backend::process::wait::WIFSTOPPED(self.0 as _) in stopped()
43 backend::process::wait::WIFCONTINUED(self.0 as _) in continued()
51 Some(backend::process::wait::WSTOPSIG(self.0 as _) as _) in stopping_signal()
61 if backend::process::wait::WIFEXITED(self.0 as _) { in exit_status()
62 Some(backend::process::wait::WEXITSTATUS(self.0 as _) as _) in exit_status()
72 if backend::process::wait in terminating_signal()
127 pub fn wait(waitopts: WaitOptions) -> io::Result<Option<(Pid, WaitStatus)>> { wait() functions
[all...]
/third_party/skia/third_party/externals/swiftshader/third_party/marl/src/
H A Devent_test.cpp67 event.wait(); in TEST_P()
75 done.wait(); in TEST_P()
78 done.wait(); in TEST_P()
81 done.wait(); in TEST_P()
91 event.wait(); in TEST_P()
97 wg.wait(); in TEST_P()
109 eventB.wait(); in TEST_P()
114 eventA.wait(); in TEST_P()
119 eventC.wait(); in TEST_P()
125 done.wait(); in TEST_P()
[all...]
H A Dscheduler_test.cpp74 wg.wait(); in TEST_P()
107 wg.wait(); in TEST_P()
117 fence.wait(); in TEST_P()
125 wg.wait(); in TEST_P()
144 fence.wait(); in TEST_P()
152 wg.wait(); in TEST_P()
178 wg.wait(); in TEST_F()
197 event.wait(); // Test that tasks can wait on other tasks. in TEST_F()
210 // As the scheduler has not been bound to the main thread, the wait() cal in TEST_F()
[all...]
H A Devent_bench.cpp31 prev.wait(); in BENCHMARK_DEFINE_F()
36 events.back().wait(); in BENCHMARK_DEFINE_F()
53 passToA.wait(); in BENCHMARK_DEFINE_F()
62 passToB.wait(); in BENCHMARK_DEFINE_F()
70 done.wait(); in BENCHMARK_DEFINE_F()
H A Dconditionvariable_test.cpp31 cv.wait(lock, [&] { in TEST_F()
50 cv.wait(lock, [&] { in TEST_F()
74 cv.wait(lock, [&] { in TEST_P()
93 cv.wait(lock, [&] { in TEST_P()
140 wg.wait(); in TEST_P()
/third_party/skia/third_party/externals/swiftshader/third_party/llvm-10.0/llvm/lib/Support/
H A DGraphWriter.cpp94 StringRef Filename, bool wait, in ExecGraphViewer()
96 if (wait) { in ExecGraphViewer()
148 bool llvm::DisplayGraph(StringRef FilenameRef, bool wait, in DisplayGraph() argument
156 wait &= !ViewBackground; in DisplayGraph()
160 if (wait) in DisplayGraph()
164 if (!ExecGraphViewer(ViewerPath, args, Filename, wait, ErrMsg)) in DisplayGraph()
173 if (!ExecGraphViewer(ViewerPath, args, Filename, wait, ErrMsg)) in DisplayGraph()
184 return ExecGraphViewer(ViewerPath, args, Filename, wait, ErrMsg); in DisplayGraph()
197 return ExecGraphViewer(ViewerPath, args, Filename, wait, ErrMsg); in DisplayGraph()
259 wait in DisplayGraph()
93 ExecGraphViewer(StringRef ExecPath, std::vector<StringRef> &args, StringRef Filename, bool wait, std::string &ErrMsg) ExecGraphViewer() argument
[all...]
H A DThreadPool.cpp28 // Create ThreadCount threads that will loop forever, wait on QueueCondition in ThreadPool()
38 QueueCondition.wait(LockGuard, in ThreadPool()
46 // in order for wait() to properly detect that even if the queue is in ThreadPool()
59 // Adjust `ActiveThreads`, in case someone waits on ThreadPool::wait() in ThreadPool()
64 // Notify task completion, in case someone waits on ThreadPool::wait() in ThreadPool()
71 void ThreadPool::wait() { in wait() function in ThreadPool
77 CompletionCondition.wait(LockGuard, in wait()
122 void ThreadPool::wait() {
134 // Wrap the future so that both ThreadPool::wait() can operate and the
142 wait();
[all...]
/third_party/python/Lib/test/test_asyncio/
H A Dtest_locks.py308 if await ev.wait():
312 if await ev.wait():
316 if await ev.wait():
342 res = await ev.wait()
348 wait = asyncio.create_task(ev.wait())
349 asyncio.get_running_loop().call_soon(wait.cancel)
351 await wait
369 if await ev.wait():
401 if await cond.wait()
1081 async def wait(barrier): global() function
[all...]
H A Dtest_subprocess.py128 exitcode = await proc.wait()
159 exitcode = self.loop.run_until_complete(proc.wait())
170 exitcode = self.loop.run_until_complete(proc.wait())
179 returncode = self.loop.run_until_complete(proc.wait())
206 returncode = self.loop.run_until_complete(proc.wait())
219 returncode = self.loop.run_until_complete(proc.wait())
243 # basic synchronization to wait until the program is sleeping
248 returncode = await proc.wait()
283 self.loop.run_until_complete(proc.wait())
291 self.loop.run_until_complete(proc.wait())
[all...]
/third_party/node/test/pummel/
H A Dtest-stream-pipe-multi.js40 this.wait = false;
48 console.error(this.ID, 'write', this.wait);
49 if (this.wait) {
52 this.wait = !this.wait;
53 return this.wait;
/third_party/skia/third_party/externals/swiftshader/src/Vulkan/
H A DVkTimelineSemaphore.hpp35 // A timeline does not have a "signaled" and "unsignalled" state. Threads instead wait
50 void wait(uint64_t value);
54 VkResult wait(uint64_t value, const std::chrono::time_point<CLOCK, DURATION> end_ns);
63 // Dependent timeline semaphores allow an 'any' semaphore to be created that can wait on the
70 // Instead, the dependent semaphore needs to wait for its parent semaphore to be signaled
103 void wait(uint64_t value);
106 VkResult wait(uint64_t value, const std::chrono::time_point<CLOCK, DURATION> end_ns);
146 VkResult TimelineSemaphore::wait(uint64_t value, in wait() function in vk::TimelineSemaphore
149 return shared->wait(value, timeout); in wait()
153 VkResult TimelineSemaphore::Shared::wait(uint64_ function in vk::TimelineSemaphore::Shared
[all...]
H A DVkFence.hpp51 VkResult wait() in wait() function in vk::Fence
53 counted_event->wait(); in wait()
58 VkResult wait(const std::chrono::time_point<CLOCK, DURATION> &timeout) in wait() function in vk::Fence
60 return counted_event->wait(timeout) ? VK_SUCCESS : VK_TIMEOUT; in wait()
/third_party/python/Lib/test/
H A Dlock_tests.py24 # A crude wait/yield function not relying on synchronization primitives.
204 # Just a sanity test that it didn't actually wait for the timeout.
387 results1.append(evt.wait())
388 results2.append(evt.wait())
412 results1.append(evt.wait(0.0))
414 r = evt.wait(0.5)
432 # Issue #13502: check that wait() returns true even when the event is
439 results.append(evt.wait(timeout * 4))
491 self.assertRaises(RuntimeError, cond.wait)
517 result = cond.wait()
[all...]
/third_party/skia/src/gpu/
H A DGrDeferredProxyUploader.h35 * 7) When the ASAP upload happens, we wait to make sure that the pixels are marked ready
46 this->wait(); in ~GrDeferredProxyUploader()
56 this->wait(); in scheduleUpload()
82 void wait() { in wait() function in GrDeferredProxyUploader
84 fPixelsReady.wait(); in wait()
107 // We need to wait here, so that we don't free fData before the worker thread is done
110 this->wait();
/third_party/skia/third_party/externals/spirv-cross/include/spirv_cross/
H A Dthread_group.hpp43 void wait() in wait() function in spirv_cross::ThreadGroup
46 worker.wait(); in wait()
67 cond.wait(l, [this] { return state != Idle; }); in start()
81 void wait() in wait() function
84 cond.wait(l, [this] { return state == Idle; }); in wait()
/third_party/mesa3d/src/gallium/drivers/nouveau/nv50/
H A Dnv50_query.c67 bool wait, union pipe_query_result *result) in nv50_get_query_result()
70 return q->funcs->get_query_result(nv50_context(pipe), q, wait, result); in nv50_get_query_result()
83 bool wait = in nv50_render_condition() local
96 wait = true; in nv50_render_condition()
102 wait = true; in nv50_render_condition()
104 cond = wait ? NV50_3D_COND_MODE_NOT_EQUAL : NV50_3D_COND_MODE_ALWAYS; in nv50_render_condition()
106 cond = wait ? NV50_3D_COND_MODE_EQUAL : NV50_3D_COND_MODE_ALWAYS; in nv50_render_condition()
130 if (wait && hq->state != NV50_HW_QUERY_STATE_READY) { in nv50_render_condition()
66 nv50_get_query_result(struct pipe_context *pipe, struct pipe_query *pq, bool wait, union pipe_query_result *result) nv50_get_query_result() argument
/third_party/skia/third_party/externals/angle2/src/libANGLE/
H A DWorkerThread.cpp29 void WaitableEventDone::wait() {} in wait() function in angle::WaitableEventDone
45 void wait() override;
49 void SingleThreadedWaitableEvent::wait() {} in wait() function in angle::SingleThreadedWaitableEvent
86 void wait() override;
93 // To block wait() when the task is still in queue to be run.
108 void AsyncWaitableEvent::wait() in wait() function in angle::AsyncWaitableEvent
110 ANGLE_TRACE_EVENT0("gpu.angle", "AsyncWaitableEvent::wait"); in wait()
113 mCondition.wait(lock, [this] { return !mIsPending; }); in wait()
117 mFuture.wait(); in wait()
223 void wait() overrid
244 void DelegateWaitableEvent::wait() wait() function in angle::DelegateWaitableEvent
[all...]
/third_party/rust/crates/once_cell/tests/
H A Dit.rs365 fn wait() { in wait() functions
369 let greeting = cell.wait(); in wait()
388 b.wait(); in get_or_init_stress()
389 let j = if t % 2 == 0 { s.wait() } else { s.get_or_init(|| i) }; in get_or_init_stress()
669 barrier.wait(); in get_does_not_block()
670 barrier.wait(); in get_does_not_block()
674 barrier.wait(); in get_does_not_block()
676 barrier.wait(); in get_does_not_block()
765 b1.wait(); in once_non_zero_usize_first_wins()
766 b2.wait(); in once_non_zero_usize_first_wins()
[all...]
/third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/
H A Dscheduler.h143 // wait() suspends execution of this Fiber until the Fiber is woken up with
150 // lock must be locked before calling, and is unlocked by wait() just before
152 // will be locked before wait() returns.
154 // wait() must only be called on the currently executing fiber.
156 void wait(marl::lock& lock, const Predicate& pred);
158 // wait() suspends execution of this Fiber until the Fiber is woken up with
167 // lock must be locked before calling, and is unlocked by wait() just before
169 // will be locked before wait() returns.
171 // wait() must only be called on the currently executing fiber.
173 MARL_NO_EXPORT inline bool wait(
549 bool Scheduler::Fiber::wait( wait() function in marl::Scheduler::Fiber
559 void Scheduler::Fiber::wait() { wait() function in marl::Scheduler::Fiber
564 bool Scheduler::Fiber::wait( wait() function in marl::Scheduler::Fiber
[all...]
/third_party/skia/src/core/
H A DSkSemaphore.cpp21 void wait() { dispatch_semaphore_wait(fSemaphore, DISPATCH_TIME_FOREVER); } in wait() function
38 void wait() { WaitForSingleObject(fSemaphore, INFINITE/*timeout in ms*/); } in wait() function
51 void wait() { in wait() function
71 fOSSemaphore->wait(); in osWait()
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/sem_post/
H A D8-1.c45 #include <sys/wait.h>
215 ret_pid = wait(&status); in main()
220 ret_pid = wait(&status); in main()
225 ret_pid = wait(&status); in main()
241 while ((wait(NULL) > 0)) ; in main()
249 while ((wait(NULL) > 0)) ; in main()
/third_party/mesa3d/src/gallium/frontends/clover/core/
H A Devent.cpp116 cv.wait(lock, [=]{ return !_wait_count; }); in wait_signalled()
120 event::wait() const { in wait() function in event
125 ev.wait(); in wait()
174 hard_event::wait() const { in wait() function in hard_event
177 event::wait(); in wait()
267 soft_event::wait() const {
268 event::wait();

Completed in 12 milliseconds

12345678910>>...67