| /external/libcups/cups/ |
| snmp.c | 374 int ready; /* Data ready on socket? */ local
381 while ((ready = poll(&pfd, 1, (int)(timeout * 1000.0))) < 0 &&
396 ready = select(fd + 1, &input_set, NULL, NULL, &stimeout);
399 while (ready < 0 && WSAGetLastError() == WSAEINTR);
401 while (ready < 0 && (errno == EINTR || errno == EAGAIN));
406 * If we don't have any data ready, return right away...
409 if (ready <= 0)
[all...] |
| /external/mesa3d/src/gallium/drivers/r600/sb/ |
| sb_gcm.cpp | 67 sblog << " ready: ";
72 ready.push_back(o);
180 while (!ready.empty()) {
181 for (sq_iterator N, I = ready.begin(), E = ready.end(); I != E;
185 ready.erase(I);
223 ready.push_back(u->op);
642 GCM_DUMP( sblog << " ready\n";);
|
| /external/tensorflow/tensorflow/python/ops/ |
| gradients_impl.py | 539 # 'ready' handles the case where one output gradient relies on
542 ready = (pending_count[op._id] == 0)
543 if ready and op._id not in to_ops_set:
646 # Update pending count for the inputs of op and enqueue ready ops.
667 """Update pending count for the inputs of op and enqueue ready ops."""
671 ready = (pending_count[x.op._id] == 0)
672 if loop_state and not ready:
673 ready = (
676 if ready:
813 gradients must be ready before any aggregation is performed
[all...] |
| /external/tensorflow/tensorflow/tools/graph_transforms/ |
| transform_utils.cc | 185 std::vector<int> ready; local
213 ready.push_back(n);
234 while (!ready.empty()) {
235 int o = ready.back();
236 ready.pop_back();
246 ready.push_back(output);
|
| /frameworks/base/packages/SettingsLib/tests/integ/src/com/android/settingslib/wifi/ |
| WifiTrackerTest.java | 735 CountDownLatch ready = new CountDownLatch(1); local
740 ready.countDown();
753 ready.await(); // Make sure we have entered the first message handler
771 final CountDownLatch ready = new CountDownLatch(1); local
776 ready.countDown();
788 ready.await(); // Make sure we have entered the first message handler
[all...] |
| /prebuilts/go/darwin-x86/src/internal/trace/ |
| order.go | 48 // from each batch (frontier). Then choose subset that is "ready" to be merged,
142 // becomes ready for merging (init) and the goroutine state after the event (next).
158 // noseq means that this event is ready for merging as soon as
|
| /prebuilts/go/linux-x86/src/internal/trace/ |
| order.go | 48 // from each batch (frontier). Then choose subset that is "ready" to be merged,
142 // becomes ready for merging (init) and the goroutine state after the event (next).
158 // noseq means that this event is ready for merging as soon as
|
| /system/core/adb/ |
| adb.cpp | 409 s->ready(s);
414 case A_OKAY: /* READY(local-id, remote-id, "") */
419 /* On first READY message, create the connection. */
422 s->ready(s);
424 /* Other READY messages must use the same local-id */
425 s->ready(s);
1247 bool ready; local
[all...] |
| /prebuilts/go/darwin-x86/src/runtime/ |
| netpoll.go | 19 // An implementation must call the following function to denote that the pd is ready.
28 // or, alternatively, concurrent io notification changes the state to READY,
31 // io notification or timeout/close changes the state to READY or nil respectively
59 seq uintptr // protects from stale timers and ready notifications
73 // because we can get ready notification from epoll/kqueue
292 // make pd ready, newly runnable goroutines (if any) are returned in rg/wg
339 // returns true if IO is ready, or false if timedout or closed
368 // be careful to not lose concurrent READY notification
388 // Only set READY for ioready. runtime_pollWait
|
| chan.go | 47 // (in particular, do not ready a G), as this can deadlock
160 // not ready for sending. Each of these observations is a single word-sized read
162 // Because a closed channel cannot transition from 'ready for sending' to
163 // 'not ready for sending', even if the channel is closed between the two observations,
165 // and not ready for sending. We behave as if we observed the channel at that moment,
169 // ready for sending and then observe that it is not closed, that implies that the
388 // Ready all Gs now that we've dropped the channel lock.
433 // After observing that the channel is not ready for receiving, we observe that the
|
| netpoll_solaris.go | 29 // ready when nobody is listening, when we finally care about it,
40 // ready for I/O.
181 // polls for ready network connections
|
| /prebuilts/go/linux-x86/src/runtime/ |
| netpoll.go | 19 // An implementation must call the following function to denote that the pd is ready.
28 // or, alternatively, concurrent io notification changes the state to READY,
31 // io notification or timeout/close changes the state to READY or nil respectively
59 seq uintptr // protects from stale timers and ready notifications
73 // because we can get ready notification from epoll/kqueue
292 // make pd ready, newly runnable goroutines (if any) are returned in rg/wg
339 // returns true if IO is ready, or false if timedout or closed
368 // be careful to not lose concurrent READY notification
388 // Only set READY for ioready. runtime_pollWait
|
| chan.go | 47 // (in particular, do not ready a G), as this can deadlock
160 // not ready for sending. Each of these observations is a single word-sized read
162 // Because a closed channel cannot transition from 'ready for sending' to
163 // 'not ready for sending', even if the channel is closed between the two observations,
165 // and not ready for sending. We behave as if we observed the channel at that moment,
169 // ready for sending and then observe that it is not closed, that implies that the
388 // Ready all Gs now that we've dropped the channel lock.
433 // After observing that the channel is not ready for receiving, we observe that the
|
| netpoll_solaris.go | 29 // ready when nobody is listening, when we finally care about it,
40 // ready for I/O.
181 // polls for ready network connections
|
| /prebuilts/gcc/linux-x86/host/x86_64-linux-glibc2.15-4.8/x86_64-linux/include/c++/4.8/bits/ |
| regex.h | 1530 bool ready() const { return !_Base_type::empty(); } function in class:match_results
[all...] |
| /prebuilts/gcc/linux-x86/host/x86_64-w64-mingw32-4.8/x86_64-w64-mingw32/include/c++/4.8.3/bits/ |
| regex.h | 1530 bool ready() const { return !_Base_type::empty(); } function in class:match_results
[all...] |
| /external/annotation-tools/scene-lib/test/annotations/tests/executable/ |
| TestSceneLib.java | 30 "annotation @Ready: @Retention(RUNTIME)\n" +
34 "field x: @Ready\n" +
46 static final AnnotationDef ready = field in class:TestSceneLib
48 "Ready",
53 "Ready",
104 .add(createEmptyAnnotation(ready));
109 .add(createEmptyAnnotation(ready));
123 .add(createEmptyAnnotation(ready));
296 .add(createEmptyAnnotation(ready));
304 assertEquals("Ready", de.annotationType)
[all...] |
| /external/mesa3d/src/compiler/nir/ |
| nir_from_ssa.c | 664 NIR_VLA(int, ready, num_copies * 2);
667 /* Mark the ones that are ready for copying. We know an index is a
668 * destination if it has a predecessor and it's ready for copying if
673 ready[++ready_idx] = i;
678 int b = ready[ready_idx--];
688 /* If a needs to be filled, it's ready for copying now */
690 ready[++ready_idx] = a;
718 ready[++ready_idx] = b;
|
| /external/python/cpython2/Lib/test/ |
| test_urllib2_localnet.py | 59 self.ready = threading.Event()
76 self.ready.set()
298 self.server.ready.wait()
349 self.server.ready.wait()
474 self.server.ready.wait()
|
| /external/python/cpython3/Lib/test/ |
| test_urllib2_localnet.py | 60 self.ready = threading.Event()
75 self.ready.set()
295 self.server.ready.wait()
343 self.server.ready.wait()
479 self.server.ready.wait()
|
| /external/tensorflow/tensorflow/python/framework/ |
| function.py | 882 ready = [
885 if not ready:
891 while ready:
892 fdef = ready.pop()
901 ready.extend(funcs[f] for f in grad_to_funcs[name])
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| ServiceManager.java | 419 * These two booleans are used to mark the state as ready to start.
420 * {@link #ready}: is set by {@link #markReady} to indicate that all listeners have been
430 boolean ready; field in class:ServiceManager.ServiceManagerState
493 * Marks the {@link State} as ready to receive transitions. Returns true if no transitions have
501 ready = true;
635 if (!ready) {
|
| /hardware/qcom/camera/msm8998/QCamera2/util/ |
| QCameraDualFOVPP.cpp | 355 // Start the blending process when it is ready
594 bool ready = false; local
596 ready = true;
599 return ready;
|
| /platform_testing/libraries/launcher-helper/src/android/support/test/launcherhelper/ |
| LeanbackLauncherStrategy.java | 453 long ready = SystemClock.uptimeMillis(); local
466 return ready;
471 return ready;
|
| /external/python/cpython3/Lib/concurrent/futures/ |
| process.py | 270 ready = wait([reader] + sentinels)
271 if reader in ready:
|
