/third_party/pulseaudio/src/pulsecore/ |
H A D | poll-posix.c | 63 int ready; in pa_poll() local 107 ready = select(maxfd + 1, &rset, &wset, &xset, (timeout == -1 ? NULL : &tv)); in pa_poll() 109 if ((ready == -1) && (errno == EBADF)) { in pa_poll() 110 ready = 0; in pa_poll() 152 ++ready; in pa_poll() 167 ready++; in pa_poll() 178 if (ready) { in pa_poll() 182 ready = select(maxfd + 1, &rset, &wset, &xset, (timeout == -1 ? NULL : &tv)); in pa_poll() 190 if (ready > 0) { in pa_poll() 191 ready in pa_poll() [all...] |
/third_party/node/lib/internal/repl/ |
H A D | history.js | 33 function setupHistory(repl, historyPath, ready) { 40 return ready(null, repl); 52 return ready(null, repl); 75 return ready(null, repl); 82 return ready(err); 89 return ready(err); 103 return ready(err); 113 ready(null, repl);
|
/third_party/mesa3d/src/gallium/drivers/freedreno/ |
H A D | freedreno_fence.c | 45 if (!util_queue_fence_is_signalled(&fence->ready)) { 54 util_queue_fence_wait(&fence->ready); 57 if (!util_queue_fence_wait_timeout(&fence->ready, abs_timeout)) { 62 util_queue_fence_wait(&fence->submit_fence.ready); 74 util_queue_fence_wait(&fence->submit_fence.ready); 118 util_queue_fence_wait(&fence->submit_fence.ready); in fd_fence_destroy() 171 util_queue_fence_init(&fence->ready); in fence_create() 172 util_queue_fence_init(&fence->submit_fence.ready); in fence_create() 290 util_queue_fence_signal(&fence->ready); in fd_fence_set_batch() 303 util_queue_fence_reset(&fence->ready); in fd_fence_create_unflushed() [all...] |
/third_party/rust/crates/rustix/tests/net/ |
H A D | v6.rs | 16 fn server(ready: Arc<(Mutex<u16>, Condvar)>) { in server() 35 let (lock, cvar) = &*ready; in server() 49 fn client(ready: Arc<(Mutex<u16>, Condvar)>) { in client() 51 let (lock, cvar) = &*ready; in client() 78 let ready = Arc::new((Mutex::new(0_u16), Condvar::new())); in test_v6() 79 let ready_clone = Arc::clone(&ready); in test_v6() 84 server(ready); in test_v6()
|
H A D | v4.rs | 16 fn server(ready: Arc<(Mutex<u16>, Condvar)>) { in server() 31 let (lock, cvar) = &*ready; in server() 45 fn client(ready: Arc<(Mutex<u16>, Condvar)>) { in client() 47 let (lock, cvar) = &*ready; in client() 69 let ready = Arc::new((Mutex::new(0_u16), Condvar::new())); in test_v4() 70 let ready_clone = Arc::clone(&ready); in test_v4() 75 server(ready); in test_v4()
|
H A D | unix.rs | 30 fn server(ready: Arc<(Mutex<bool>, Condvar)>, path: &Path) { in server() 43 let (lock, cvar) = &*ready; in server() 72 fn client(ready: Arc<(Mutex<bool>, Condvar)>, path: &Path, runs: &[(&[&str], i32)]) { in client() 74 let (lock, cvar) = &*ready; in client() 117 let ready = Arc::new((Mutex::new(false), Condvar::new())); in test_unix() 118 let ready_clone = Arc::clone(&ready); in test_unix() 126 server(ready, &send_path); in test_unix()
|
H A D | poll.rs | 15 fn server(ready: Arc<(Mutex<u16>, Condvar)>) { in server() 34 let (lock, cvar) = &*ready; in server() 61 fn client(ready: Arc<(Mutex<u16>, Condvar)>) { in client() 63 let (lock, cvar) = &*ready; in client() 102 let ready = Arc::new((Mutex::new(0_u16), Condvar::new())); in test_poll() 103 let ready_clone = Arc::clone(&ready); in test_poll() 108 server(ready); in test_poll()
|
/third_party/python/Lib/ |
H A D | selectors.py | 157 ready or a timeout expires. 163 report the currently ready file objects 165 file object becomes ready 168 list of (key, events) for ready file objects 321 ready = [] 325 return ready 337 ready.append((key, events & key.events)) 338 return ready 413 ready = [] 417 return ready [all...] |
/third_party/skia/third_party/externals/angle2/src/tests/gl_tests/ |
H A D | TimerQueriesTest.cpp | 131 GLuint ready = GL_FALSE; in TEST_P() local 132 while (ready == GL_FALSE && timeout > 0) in TEST_P() 135 glGetQueryObjectuivEXT(query1, GL_QUERY_RESULT_AVAILABLE_EXT, &ready); in TEST_P() 138 ready = GL_FALSE; in TEST_P() 139 while (ready == GL_FALSE && timeout > 0) in TEST_P() 142 glGetQueryObjectuivEXT(query2, GL_QUERY_RESULT_AVAILABLE_EXT, &ready); in TEST_P() 211 GLuint ready = GL_FALSE; in TEST_P() local 212 while (ready == GL_FALSE && timeout > 0) in TEST_P() 215 glGetQueryObjectuivEXT(query, GL_QUERY_RESULT_AVAILABLE_EXT, &ready); in TEST_P() 453 GLuint ready in TEST_P() local [all...] |
/third_party/rust/crates/rustix/tests/io/ |
H A D | epoll.rs | 16 fn server(ready: Arc<(Mutex<u16>, Condvar)>) { in server() 27 let (lock, cvar) = &*ready; in server() 62 fn client(ready: Arc<(Mutex<u16>, Condvar)>) { in client() 64 let (lock, cvar) = &*ready; in client() 87 let ready = Arc::new((Mutex::new(0_u16), Condvar::new())); in test_epoll() 88 let ready_clone = Arc::clone(&ready); in test_epoll() 93 server(ready); in test_epoll()
|
/third_party/ltp/testcases/kernel/syscalls/pidfd_open/ |
H A D | pidfd_open03.c | 23 int fd, ready; in run() local 42 ready = poll(&pollfd, 1, -1); in run() 47 if (ready != 1) in run() 48 tst_res(TFAIL, "poll() returned %d", ready); in run()
|
/third_party/libphonenumber/tools/java/java-build/test/com/google/i18n/phonenumbers/ |
H A D | BuildShortNumberMetadataJsonFromXmlGoldenTest.java | 47 while (outputReader.ready() && goldenReader.ready()) { in testBuildMetadataJsonFromXmlGolden() 58 assertEquals(outputReader.ready(), goldenReader.ready()); in testBuildMetadataJsonFromXmlGolden()
|
H A D | BuildMetadataJsonFromXmlGoldenTest.java | 46 while (outputReader.ready() && goldenReader.ready()) { in testBuildMetadataJsonFromXmlGolden() 57 assertEquals(outputReader.ready(), goldenReader.ready()); in testBuildMetadataJsonFromXmlGolden()
|
/third_party/mesa3d/src/gallium/frontends/lavapipe/ |
H A D | lvp_query.c | 112 bool ready = false; in lvp_GetQueryPoolResults() local 114 ready = device->queue.ctx->get_query_result(device->queue.ctx, in lvp_GetQueryPoolResults() 122 if (!ready && !(flags & VK_QUERY_RESULT_PARTIAL_BIT)) in lvp_GetQueryPoolResults() 125 if (ready || (flags & VK_QUERY_RESULT_PARTIAL_BIT)) { in lvp_GetQueryPoolResults() 152 if (ready || (flags & VK_QUERY_RESULT_PARTIAL_BIT)) { in lvp_GetQueryPoolResults() 192 *(uint64_t *)dptr = ready; in lvp_GetQueryPoolResults() 194 *(uint32_t *)dptr = ready; in lvp_GetQueryPoolResults()
|
/third_party/node/test/fixtures/wpt/streams/writable-streams/ |
H A D | write.any.js | 80 return writer.ready.then(() => { 94 writer.ready.then(value => { 95 assert_equals(resolveSinkWritePromise, undefined, 'sinkWritePromise should be fulfilled before writer.ready'); 96 assert_true(writePromiseResolved, 'writePromise should be fulfilled before writer.ready'); 123 return writer.ready.then(() => { 185 promise_rejects_exactly(t, error1, writer.ready, 186 'writer.ready must reject with the error passed to the controller'), 191 }, 'writer.write(), ready and closed reject with the error passed to controller.error() made before sink.write' + 212 return writer.ready.then(() => { 234 return writer.ready [all...] |
/third_party/python/Tools/peg_generator/pegen/ |
H A D | sccutils.py | 92 ready = {item for item, dep in data.items() if not dep} 93 if not ready: 95 yield ready 96 data = {item: (dep - ready) for item, dep in data.items() if item not in ready}
|
/third_party/skia/third_party/externals/dawn/src/tests/unittests/ |
H A D | PerThreadProcTests.cpp | 47 std::atomic<bool> ready(false); in TEST_F() 75 while (!ready) { in TEST_F() 96 while (!ready) { in TEST_F() 110 ready = true; in TEST_F()
|
/third_party/mesa3d/src/gallium/drivers/r600/sfn/ |
H A D | sfn_scheduler.cpp | 163 bool collect_ready_type(std::list<T *>& ready, std::list<T *>& orig); 165 bool collect_ready_alu_vec(std::list<AluInstr *>& ready, std::list<AluInstr *>& available); 301 sfn_log << SfnLog::schedule << "Have ready instructions\n"; in schedule_block() 464 // Assert that if condition is ready in schedule_block() 492 /* If we have ready ALU instructions we have to start a new ALU block */ in schedule_alu() 790 bool BlockSheduler::collect_ready_alu_vec(std::list<AluInstr *>& ready, std::list<AluInstr *>& available) in collect_ready_alu_vec() argument 795 for (auto alu : ready) { in collect_ready_alu_vec() 801 if (ready.size() < 32 && (*i)->ready()) { in collect_ready_alu_vec() 804 /* LDS fetches that use static offsets are usually ready er in collect_ready_alu_vec() 917 collect_ready_type(std::list<T *>& ready, std::list<T *>& available) collect_ready_type() argument [all...] |
/third_party/python/Lib/test/ |
H A D | test_devpoll.py | 15 def find_ready_matching(ready, flag): 17 for fd, mode in ready: 51 ready = p.poll() 52 ready_writers = find_ready_matching(ready, select.POLLOUT) 54 self.fail("no pipes ready for writing") 58 ready = p.poll() 59 ready_readers = find_ready_matching(ready, select.POLLIN) 61 self.fail("no pipes ready for reading")
|
H A D | test_poll.py | 24 def find_ready_matching(ready, flag): 26 for fd, mode in ready: 60 ready = p.poll() 61 ready_writers = find_ready_matching(ready, select.POLLOUT) 63 raise RuntimeError("no pipes ready for writing") 67 ready = p.poll() 68 ready_readers = find_ready_matching(ready, select.POLLIN) 70 raise RuntimeError("no pipes ready for reading")
|
/third_party/node/test/parallel/ |
H A D | test-net-error-twice.js | 33 function ready() { function 50 ready(); 56 ready();
|
/third_party/ltp/testcases/open_posix_testsuite/conformance/interfaces/sigaction/ |
H A D | 16-1.c | 84 static volatile int ready; variable 132 ready = 1; in threaded() 160 ready = 0; in test_sig() 168 * sync on the ready flag. Since the child is running in in test_sig() 174 while (!ready) in test_sig()
|
/third_party/mesa3d/src/gallium/drivers/freedreno/ir3/ |
H A D | ir3_gallium.c | 58 struct util_queue_fence ready; member 322 util_queue_fence_init(&hwcso->ready); in ir3_shader_compute_state_create() 336 util_queue_add_job(&screen->compile_queue, hwcso, &hwcso->ready, in ir3_shader_compute_state_create() 392 util_queue_fence_init(&hwcso->ready); in ir3_shader_state_create() 397 util_queue_add_job(&ctx->screen->compile_queue, hwcso, &hwcso->ready, in ir3_shader_state_create() 420 util_queue_drop_job(&screen->compile_queue, &hwcso->ready); in ir3_shader_state_delete() 436 util_queue_fence_destroy(&hwcso->ready); in ir3_shader_state_delete() 452 util_queue_fence_wait(&hwcso->ready); in ir3_get_shader() 523 return util_queue_fence_is_signalled(&hwcso->ready); in ir3_is_parallel_shader_compilation_finished()
|
/third_party/mesa3d/src/gallium/drivers/radeonsi/ |
H A D | si_fence.c | 43 struct util_queue_fence ready; member 223 util_queue_fence_init(&fence->ready); in si_create_multi_fence() 235 util_queue_fence_reset(&fence->ready); in si_create_fence() 293 if (!util_queue_fence_is_signalled(&sfence->ready)) { in si_fence_finish() 301 * may not be ready yet when this call returns. in si_fence_finish() 310 util_queue_fence_wait(&sfence->ready); in si_fence_finish() 312 if (!util_queue_fence_wait_timeout(&sfence->ready, abs_timeout)) in si_fence_finish() 432 util_queue_fence_wait(&sfence->ready); in si_fence_get_fd() 536 util_queue_fence_signal(&new_fence->ready); in si_flush_all_queues() 586 util_queue_fence_wait(&sfence->ready); in si_fence_server_sync() [all...] |
/third_party/skia/third_party/externals/oboe/src/common/ |
H A D | AudioStream.cpp | 171 bool ready = false; in waitForAvailableFrames() local 177 ready = (framesAvailable >= numFrames); in waitForAvailableFrames() 178 if (!ready) { in waitForAvailableFrames() 183 } while (!ready); in waitForAvailableFrames() 184 return (!ready) in waitForAvailableFrames()
|