| /external/antlr/runtime/CSharp2/Sources/Antlr3.Runtime/Antlr.Runtime.Tree/ |
| D | TreeIterator.cs | 95 nodes.Enqueue(eof); in MoveNext()
110 nodes.Enqueue(tree); // real node is next after DOWN in MoveNext()
118 nodes.Enqueue(up); // we're moving back up in MoveNext()
126 nodes.Enqueue(eof); // add to queue, might have UP nodes in there in MoveNext()
133 nodes.Enqueue(tree); // add to queue, might have UP nodes in there in MoveNext()
|
| /external/antlr/runtime/CSharp3/Sources/Antlr3.Runtime/Tree/ |
| D | TreeIterator.cs | 105 nodes.Enqueue( eof ); in MoveNext()
129 nodes.Enqueue( tree ); // real node is next after DOWN in MoveNext()
140 nodes.Enqueue( up ); // we're moving back up in MoveNext()
149 nodes.Enqueue( eof ); // add to queue, might have UP nodes in there in MoveNext()
158 nodes.Enqueue( tree ); // add to queue, might have UP nodes in there in MoveNext()
|
| /external/llvm-project/compiler-rt/lib/sanitizer_common/tests/ |
| D | sanitizer_quarantine_test.cpp | 87 cache.Enqueue(cb, kFakePtr, kBlockSize); in TEST()
105 from.Enqueue(cb, kFakePtr, kBlockSize); in TEST()
107 cache.Enqueue(cb, kFakePtr, kBlockSize); in TEST()
130 from.Enqueue(cb, kFakePtr, kBlockSize); in TEST()
131 cache.Enqueue(cb, kFakePtr, kBlockSize); in TEST()
157 from.Enqueue(cb, kFakePtr, kBlockSize); in TEST()
|
| /external/grpc-grpc/src/csharp/Grpc.Core/Internal/ |
| D | DefaultObjectPool.cs | 107 localData.Queue.Enqueue(sharedQueue.Dequeue()); in LeaseInternal()
138 localData.Queue.Enqueue(item); in Return()
154 sharedQueue.Enqueue(item); in Return()
159 sharedQueue.Enqueue(localData.Queue.Dequeue()); in Return()
|
| /external/googletest/googletest/samples/ |
| D | sample3_unittest.cc | 75 q1_.Enqueue(1); in SetUp()
76 q2_.Enqueue(2); in SetUp()
77 q2_.Enqueue(3); in SetUp()
|
| D | sample5_unittest.cc | 148 q1_.Enqueue(1); in SetUp()
149 q2_.Enqueue(2); in SetUp()
150 q2_.Enqueue(3); in SetUp()
|
| D | sample3-inl.h | 115 void Enqueue(const E& element) { in Enqueue() function
156 new_queue->Enqueue(function(node->element())); in Map()
|
| /external/rust/crates/quiche/deps/boringssl/src/third_party/googletest/samples/ |
| D | sample3_unittest.cc | 75 q1_.Enqueue(1); in SetUp()
76 q2_.Enqueue(2); in SetUp()
77 q2_.Enqueue(3); in SetUp()
|
| D | sample5_unittest.cc | 148 q1_.Enqueue(1); in SetUp()
149 q2_.Enqueue(2); in SetUp()
150 q2_.Enqueue(3); in SetUp()
|
| D | sample3-inl.h | 115 void Enqueue(const E& element) { in Enqueue() function
156 new_queue->Enqueue(function(node->element())); in Map()
|
| /external/tensorflow/tensorflow/core/common_runtime/ |
| D | ring_gatherer.cc | 137 ready_queue.Enqueue(&rfv_[rf_index]); in RunAsyncParts()
181 ready_queue.Enqueue(rf); in RunAsyncParts()
193 ready_queue.Enqueue(rf); in RunAsyncParts()
222 ready_queue.Enqueue(rf); in RunAsyncParts()
|
| D | ring_reducer.cc | 187 ready_queue.Enqueue(&rfv_[rf_index]); in RunAsyncParts()
231 ready_queue.Enqueue(rf); in RunAsyncParts()
243 ready_queue.Enqueue(rf); in RunAsyncParts()
295 ready_queue.Enqueue(rf); in RunAsyncParts()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | executor.cc | 195 void GrpcExecutor::Enqueue(grpc_closure* closure, grpc_error* error, in Enqueue() function in GrpcExecutor
322 executors[GRPC_DEFAULT_EXECUTOR]->Enqueue(closure, error, in default_enqueue_short()
327 executors[GRPC_DEFAULT_EXECUTOR]->Enqueue(closure, error, in default_enqueue_long()
332 executors[GRPC_RESOLVER_EXECUTOR]->Enqueue(closure, error, in resolver_enqueue_short()
337 executors[GRPC_RESOLVER_EXECUTOR]->Enqueue(closure, error, in resolver_enqueue_long()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | executor.cc | 61 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_short()
66 executors[static_cast<size_t>(ExecutorType::DEFAULT)]->Enqueue( in default_enqueue_long()
71 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_short()
76 executors[static_cast<size_t>(ExecutorType::RESOLVER)]->Enqueue( in resolver_enqueue_long()
254 void Executor::Enqueue(grpc_closure* closure, grpc_error* error, in Enqueue() function in grpc_core::Executor
|
| /external/clang/lib/StaticAnalyzer/Checkers/ |
| D | VirtualCallChecker.cpp | 70 void Enqueue(WorkListUnit WLUnit) { in Enqueue() function in __anon9819bb6f0111::WalkAST
135 Enqueue(CE); in VisitCallExpr()
167 Enqueue(CE); in VisitCXXMemberCallExpr()
|
| /external/walt/android/WALT/app/src/main/jni/ |
| D | player.c | 121 SLresult result = (*bqPlayerBufferQueue)->Enqueue(bqPlayerBufferQueue, beepBuffer, in bqPlayerCallback()
126 SLresult result = (*bqPlayerBufferQueue)->Enqueue(bqPlayerBufferQueue, silenceBuffer, in bqPlayerCallback()
154 result = (*bqPlayerBufferQueue)->Enqueue(bqPlayerBufferQueue, beepBuffer, in Java_org_chromium_latency_walt_AudioTest_playTone()
327 result = (*bqPlayerBufferQueue)->Enqueue(bqPlayerBufferQueue, silenceBuffer, bufferSizeInBytes); in Java_org_chromium_latency_walt_AudioTest_startWarmTest()
498 result = (*recorderBufferQueue)->Enqueue(recorderBufferQueue, recorderBuffer, in Java_org_chromium_latency_walt_AudioTest_startRecording()
|
| /external/llvm-project/openmp/libomptarget/deviceRTLs/common/src/ |
| D | omptarget.cu | 75 omptarget_nvptx_device_State[slot].Enqueue( in __kmpc_kernel_deinit()
150 omptarget_nvptx_device_State[slot].Enqueue( in __kmpc_spmd_kernel_deinit_v2()
|
| /external/python/cpython2/Lib/ |
| D | smtpd.py | 447 msg.Enqueue(mlist, tolist=1)
449 msg.Enqueue(mlist, toadmin=1)
451 msg.Enqueue(mlist, toowner=1)
453 msg.Enqueue(mlist, torequest=1)
460 msg.Enqueue(mlist, torequest=1)
|
| /external/tensorflow/tensorflow/core/distributed_runtime/eager/ |
| D | eager_service_impl_test.cc | 92 done(impl_->Enqueue(call_opts, request, response)); in EnqueueAsync()
106 done(impl_->Enqueue(nullptr, request, response)); in StreamingEnqueueAsync()
431 TF_ASSERT_OK(eager_service_impl.Enqueue(nullptr, &remote_enqueue_request, in TEST_F()
491 TF_ASSERT_OK(eager_service_impl.Enqueue(nullptr, &enqueue_request, in TestFunction()
532 status = eager_service_impl.Enqueue(&call_opts, &remote_enqueue_request, in TestFunction()
589 TF_ASSERT_OK(eager_service_impl.Enqueue(nullptr, &enqueue_request, in TestComponentFunction()
607 TF_ASSERT_OK(eager_service_impl.Enqueue(nullptr, &remote_enqueue_request, in TestComponentFunction()
772 TF_EXPECT_OK(eager_service_impl_.Enqueue(nullptr, &remote_enqueue_request, in Init()
1079 TF_ASSERT_OK(eager_service_impl.Enqueue(nullptr, &remote_enqueue_request, in TEST_F()
1160 TF_ASSERT_OK(eager_service_impl.Enqueue(nullptr, &remote_enqueue_request, in TEST_F()
[all …]
|
| /external/libchrome/base/synchronization/ |
| D | waitable_event_posix.cc | 187 Enqueue(&sw); in TimedWaitUntil()
347 waitables[i].first->Enqueue(waiter); in EnqueueMany()
414 void WaitableEvent::Enqueue(Waiter* waiter) { in Enqueue() function in base::WaitableEvent
|
| /external/tensorflow/tensorflow/core/kernels/ |
| D | collective_nccl_broadcaster.cc | 27 col_ctx_->nccl_communicator->Enqueue(col_ctx_, std::move(done)); in Run()
|
| D | collective_nccl_gatherer.cc | 27 col_ctx_->nccl_communicator->Enqueue(col_ctx_, std::move(done)); in Run()
|
| /external/tensorflow/tensorflow/core/nccl/ |
| D | collective_communicator.cc | 31 void Enqueue(std::shared_ptr<CollectiveContext> col_ctx,
70 void NcclCommunicator::Enqueue(std::shared_ptr<CollectiveContext> col_ctx, in Enqueue() function in tensorflow::NcclCommunicator
|
| /external/tensorflow/tensorflow/core/distributed_runtime/rpc/eager/ |
| D | grpc_eager_service_impl.h | 78 call->SendResponse(ToGrpcStatus(local_impl_.Enqueue( in EnqueueHandler()
132 Status status = local_impl_.Enqueue( in StreamingEnqueueHandler()
|
| /external/tensorflow/tensorflow/core/api_def/base_api/ |
| D | api_def_OutfeedEnqueue.pbtxt | 10 summary: "Enqueue a Tensor on the computation outfeed."
|