| /external/python/cpython2/Objects/ |
| listobject.c | 1390 struct s_slice pending[MAX_MERGE_PENDING]; member in struct:s_MergeState
[all...] |
| /external/tensorflow/tensorflow/python/debug/lib/ |
| debug_data.py | 889 def _satisfied_at_timestamp(self, device_name, pending, timestamp, start_i=0):
890 """Determine whether pending inputs are satisfied at given timestamp.
892 Note: This method mutates the input argument "pending".
896 pending: A list of 2-tuple (node_name, output_slot): the dependencies to
903 (bool) Whether all the dependencies in pending are satisfied at the
904 timestamp. If pending is empty to begin with, return True.
906 if not pending:
[all...] |
| /external/mesa3d/src/gallium/drivers/r600/sb/ |
| sb_sched.cpp | 773 if (!pending.empty())
774 dump::dump_op_list(&pending);
777 assert(pending.empty());
981 pending.push_back(n);
982 PSC_DUMP( sblog << "pending\n"; );
1158 int last_pending = pending.count();
1163 int new_pending = pending.count();
1204 if (!pending.empty()) {
1205 sblog << "##post_scheduler: unscheduled pending instructions :";
1206 dump::dump_op_list(&pending);
[all...] |
| /external/python/cpython3/Lib/test/test_asyncio/ |
| test_tasks.py | 287 # test pending Task
294 '<Task pending %s cb=[<Dummy>()]>' % coro)
361 # test pending Task
375 '<Task pending %s cb=[<Dummy>()]>' % coro)
899 done, pending = await asyncio.wait([b, a], loop=loop)
901 self.assertEqual(pending, set())
928 done, pending = await asyncio.wait([b, a])
930 self.assertEqual(pending, set())
950 done, pending = self.loop.run_until_complete(task)
952 self.assertFalse(pending)
[all...] |
| /external/python/cpython3/Lib/ |
| weakref.py | 615 pending = None
617 if pending is None or finalize._dirty:
618 pending = cls._select_for_exit()
620 if not pending:
622 f = pending.pop()
|
| /frameworks/av/media/bufferpool/2.0/ |
| AccessorImpl.cpp | 379 ALOGV("bufferpoo2 invalidation requested and pending");
380 Pending pending(needsAck, from, to, left, impl);
381 mPendings.push_back(pending);
415 // All invalidation Ids are synced and no more pending invalidations.
619 auto pending = mPendingTransactions.find(connectionId); local
620 if (pending != mPendingTransactions.end()) {
621 for (const TransactionId& transactionId : pending->second) {
|
| /frameworks/av/media/bufferpool/1.0/ |
| AccessorImpl.cpp | 432 auto pending = mPendingTransactions.find(connectionId); local
433 if (pending != mPendingTransactions.end()) {
434 for (const TransactionId& transactionId : pending->second) {
|
| /external/tensorflow/tensorflow/contrib/verbs/ |
| README.md | 57 Our entry point is the implementation of **RdmaRemoteRendezvous::RecvFromRemoteAsync()**, located in rdma_rendezvous_mgr.cc. The implementation creates a new **RdmaTensorRequest** object, keyed by request index (uint32_t), stores it in a list of pending requests, and calls its **Start()** method. The **Start()** method basically does 2 things:
64 When the sender receives an **RDMA_MESSAGE_TENSOR_REQUEST**, it will create a new **RdmaTensorResponse** object for the given request message, store it in a list of pending responses, and will invoke its **Start()** method. The **Start()** method does the following:
88 3. Deallocate the result/proxy tensors and remove the request from the pending list.
130 * **Destroy()** - Destroy the response's resources and remove it form the pending list.
132 * **class RdmaChannel** - Responsible for RDMA connection to a particular node. It manages messagee buffers. A channel has a request table which stores all the pending tensor requests.
133 * **class RdmaMessageBuffer** - Responsible for sending or receiving messages. It has a fixed size memory to store the data. It has a queue to store the pending jobs. A channel has two message buffers one for tx and one for rx.
|
| /external/wpa_supplicant_8/src/radius/ |
| radius_client.c | 37 * RADIUS_CLIENT_MAX_ENTRIES - RADIUS client maximum pending messages
82 * store pending RADIUS requests that may still need to be retransmitted.
221 * msgs - Pending outgoing RADIUS messages
226 * num_msgs - Number of pending messages in the msgs list
740 * such retries are used with RADIUS_ACCT_INTERIM, i.e., such a pending message
743 * The related device MAC address can be used to identify pending messages that
910 "Received RADIUS packet matched with a pending "
965 * This function is used to fetch a unique (among pending requests) identifier
982 "Removing pending RADIUS message, "
1004 * radius_client_flush - Flush all pending RADIUS client message
1560 int pending = 0; local
1609 int pending = 0; local
[all...] |
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/ |
| ssl.py | 267 def pending(self):
member in class:SSLSocket
269 return self._sslobj.pending()
|
| /external/adhd/cras/src/common/ |
| cras_shm.h | 431 /* Sets if a callback is pending with the client. */
433 void cras_shm_set_callback_pending(struct cras_audio_shm *shm, int pending)
435 shm->area->callback_pending = !!pending;
438 /* Returns non-zero if a callback is pending for this shm region. */
|
| /external/grpc-grpc/src/csharp/Grpc.Core/ |
| AsyncDuplexStreamingCall.cs | 116 /// Otherwise, requests cancellation of the call which should terminate all pending async operations associated with the call.
|
| AsyncServerStreamingCall.cs | 100 /// Otherwise, requests cancellation of the call which should terminate all pending async operations associated with the call.
|
| AsyncUnaryCall.cs | 110 /// Otherwise, requests cancellation of the call which should terminate all pending async operations associated with the call.
|
| /external/mesa3d/src/intel/vulkan/ |
| anv_gem.c | 377 uint32_t *active, uint32_t *pending)
386 *pending = stats.batch_pending;
|
| /external/syzkaller/syz-hub/ |
| hub.go | 114 log.Logf(0, "sync from %v: recv: add=%v del=%v repros=%v; send: progs=%v repros=%v pending=%v",
|
| /external/syzkaller/vendor/google.golang.org/api/gensupport/ |
| buffer.go | 18 chunk []byte // The current chunk which is pending upload. The capacity is the chunk size.
|
| /device/linaro/bootloader/edk2/AppPkg/Applications/Python/Python-2.7.2/Lib/test/ |
| test_deque.py | 721 ... pending = deque(iter(i) for i in iterables)
722 ... while pending:
723 ... task = pending.popleft()
728 ... pending.append(task)
|
| /external/aac/libSBRenc/src/ |
| resampler.cpp | 327 DownSampler->pending = ratio - 1;
|
| /external/libdrm/nouveau/ |
| nouveau.h | 174 struct nouveau_list pending; member in struct:nouveau_bufctx
|
| pushbuf.c | 424 DRMLISTJOIN(&bctx->current, &bctx->pending);
501 DRMLISTFOREACHENTRY(bref, &bctx->pending, thead) {
517 DRMLISTJOIN(&bctx->pending, &bctx->current);
518 DRMINITLISTHEAD(&bctx->pending);
661 /* make sure there's always enough space to queue up the pending
|
| /external/llvm/examples/OCaml-Kaleidoscope/Chapter7/ |
| parser.ml | 9 (* precedence - Get the precedence of the pending binary operator token. *)
132 * rhs, let the pending operator take rhs as its lhs. *)
|
| /external/mesa3d/src/gallium/drivers/freedreno/ |
| freedreno_query_acc.c | 133 if (pending(rsc, false)) {
|
| /external/swiftshader/third_party/LLVM/examples/OCaml-Kaleidoscope/Chapter7/ |
| parser.ml | 9 (* precedence - Get the precedence of the pending binary operator token. *)
132 * rhs, let the pending operator take rhs as its lhs. *)
|
| /external/swiftshader/third_party/llvm-7.0/llvm/examples/OCaml-Kaleidoscope/Chapter7/ |
| parser.ml | 9 (* precedence - Get the precedence of the pending binary operator token. *)
132 * rhs, let the pending operator take rhs as its lhs. *)
|
