| /external/grpc-grpc/src/core/client_channel/ |
| D | retry_filter_legacy_call_data.cc | 199 PendingBatchContainsUnstartedSendOps(PendingBatch* pending) { in PendingBatchContainsUnstartedSendOps()
370 PendingBatch* pending = &calld_->pending_batches_[i]; in AddBatchesForPendingBatches() local
803 PendingBatch* pending = call_attempt_->calld_->PendingBatchFind( in MaybeAddClosureForRecvInitialMetadataCallback() local
906 PendingBatch* pending = call_attempt_->calld_->PendingBatchFind( in MaybeAddClosureForRecvMessageCallback() local
1033 PendingBatch* pending = calld->PendingBatchFind( in MaybeAddClosureForRecvTrailingMetadataReady() local
1100 PendingBatch* pending = &calld->pending_batches_[i]; in AddClosuresToFailUnstartedPendingBatches() local
1234 PendingBatch* pending = calld->PendingBatchFind( in AddClosuresForCompletedPendingBatch() local
1269 PendingBatch* pending = &calld->pending_batches_[i]; in AddClosuresForReplayOrPendingSendOps() local
1651 PendingBatch* pending = PendingBatchesAdd(batch); in StartTransportStreamOpBatch() local
1738 PendingBatch* pending) { in MaybeCacheSendOpsForBatch()
[all …]
|
| /external/pigweed/pw_rpc/ts/ |
| D | rpc_classes.ts | 66 pending: Map<string, Call> = new Map(); property in PendingCalls
173 for (const pending in allPendingCalls) { constant
174 const curCall = allPendingCalls[pending]; constant
|
| /external/openscreen/cast/sender/channel/ |
| D | sender_socket_factory.cc | 96 PendingAuth& pending = *pending_auth_.back(); in OnConnected() local
120 for (const PendingConnection& pending : connections) { in OnError() local
128 [&endpoint](const PendingConnection& pending) { in FindPendingConnection()
159 std::unique_ptr<PendingAuth> pending = std::move(*it); in OnMessage() local
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | retry_filter.cc | 745 PendingBatch* pending) { in PendingBatchContainsUnstartedSendOps()
915 PendingBatch* pending = &calld_->pending_batches_[i]; in AddBatchesForPendingBatches() local
1347 PendingBatch* pending = call_attempt_->calld_->PendingBatchFind( in MaybeAddClosureForRecvInitialMetadataCallback() local
1450 PendingBatch* pending = call_attempt_->calld_->PendingBatchFind( in MaybeAddClosureForRecvMessageCallback() local
1577 PendingBatch* pending = calld->PendingBatchFind( in MaybeAddClosureForRecvTrailingMetadataReady() local
1644 PendingBatch* pending = &calld->pending_batches_[i]; in AddClosuresToFailUnstartedPendingBatches() local
1778 PendingBatch* pending = calld->PendingBatchFind( in AddClosuresForCompletedPendingBatch() local
1813 PendingBatch* pending = &calld->pending_batches_[i]; in AddClosuresForReplayOrPendingSendOps() local
2205 PendingBatch* pending = PendingBatchesAdd(batch); in StartTransportStreamOpBatch() local
2291 void RetryFilter::CallData::MaybeCacheSendOpsForBatch(PendingBatch* pending) { in MaybeCacheSendOpsForBatch()
[all …]
|
| /external/python/cpython3/Python/ |
| D | ceval_gil.c | 628 struct _pending_calls *pending = &tstate->interp->ceval.pending; in _PyEval_ReInitThreads() local
711 _push_pending_call(struct _pending_calls *pending, in _push_pending_call()
737 _next_pending_call(struct _pending_calls *pending, in _next_pending_call()
755 _pop_pending_call(struct _pending_calls *pending, in _pop_pending_call()
776 struct _pending_calls *pending = &interp->ceval.pending; in _PyEval_AddPendingCall() local
837 _make_pending_calls(struct _pending_calls *pending, int32_t *p_npending) in _make_pending_calls()
905 clear_pending_handling_thread(struct _pending_calls *pending) in clear_pending_handling_thread()
920 struct _pending_calls *pending = &interp->ceval.pending; in make_pending_calls() local
1006 struct _pending_calls *pending = &tstate->interp->ceval.pending; in _Py_FinishPendingCalls() local
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/tools/ |
| D | quic_simple_server_session.cc | 70 PendingStream* pending) { in CreateIncomingStream()
109 PendingStream* pending) { in ProcessBidirectionalPendingStream()
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/tools/ |
| D | quic_simple_server_session.cc | 70 PendingStream* pending) { in CreateIncomingStream()
109 PendingStream* pending) { in ProcessBidirectionalPendingStream()
|
| /external/sdv/vsomeip/third_party/boost/serialization/src/ |
| D | basic_iarchive.cpp | 172 struct pending { struct in boost::archive::detail::basic_iarchive_impl
173 void * object;
174 const basic_iserializer * bis;
175 version_type version;
176 pending() : in pending() argument
|
| /external/stg/ |
| D | post_processing.cc | 48 std::vector<std::pair<std::string, std::string>> pending; in SummariseCRCChanges() local
158 std::map<std::string, std::vector<std::string>>> pending; in GroupRemovedAddedSymbols() local
203 std::vector<std::string> pending; in SummariseEnumeratorAdditionsAndRemovals() local
|
| /external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/promise/ |
| D | poll.h | 97 bool pending() const { return !ready_; } in pending() function
156 bool pending() const { return !ready_; } in pending() function
|
| /external/grpc-grpc/src/core/lib/promise/ |
| D | poll.h | 95 bool pending() const { return !ready_; } in pending() function
154 bool pending() const { return !ready_; } in pending() function
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_stream_test.cc | 67 TestStream(PendingStream* pending, QuicSession* session, bool is_static) in TestStream()
199 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
211 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
222 PendingStream pending(server_initiated_pending_stream_id, session_.get()); in TEST_P() local
230 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
276 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
291 PendingStream pending(bidirection_stream_id, session_.get()); in TEST_P() local
306 PendingStream pending(bidirection_stream_id, session_.get()); in TEST_P() local
318 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
339 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
[all …]
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_stream_test.cc | 67 TestStream(PendingStream* pending, QuicSession* session, bool is_static) in TestStream()
199 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
211 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
222 PendingStream pending(server_initiated_pending_stream_id, session_.get()); in TEST_P() local
230 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
276 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
291 PendingStream pending(bidirection_stream_id, session_.get()); in TEST_P() local
306 PendingStream pending(bidirection_stream_id, session_.get()); in TEST_P() local
318 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
339 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
[all …]
|
| /external/rust/android-crates-io/crates/signal-hook/src/iterator/ |
| D | backend.rs | 159 pending: Arc<dyn AddSignal>, field
240 pending: Arc<PendingSignals<E>>, field
269 let pending = Arc::new(PendingSignals::new(exfiltrator)); in with_pipe() localVariable
335 pub fn pending(&mut self) -> Pending<E> { in pending() function
378 pending: Arc<PendingSignals<E>>, field
|
| /external/linux-kselftest/tools/testing/selftests/bpf/progs/ |
| D | cgroup_hierarchical_stats.c | 21 __u64 pending; member
56 static int create_attach_counter(__u64 cg_id, __u64 state, __u64 pending) in create_attach_counter()
|
| /external/cronet/tot/net/third_party/quiche/src/quiche/quic/core/qpack/ |
| D | qpack_receive_stream.cc | 11 QpackReceiveStream::QpackReceiveStream(PendingStream* pending, in QpackReceiveStream()
|
| /external/musl/src/multibyte/ |
| D | mbrtoc16.c | 8 unsigned *pending = (unsigned *)ps; in mbrtoc16() local
|
| /external/trusty/musl/src/multibyte/ |
| D | mbrtoc16.c | 8 unsigned *pending = (unsigned *)ps; in mbrtoc16() local
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/fork/ |
| D | 12-1.c | 57 sigset_t mask, pending; in main() local
|
| /external/cronet/stable/net/third_party/quiche/src/quiche/quic/core/qpack/ |
| D | qpack_receive_stream.cc | 11 QpackReceiveStream::QpackReceiveStream(PendingStream* pending, in QpackReceiveStream()
|
| /external/rust/android-crates-io/crates/tokio-stream/src/ |
| D | lib.rs | 108 mod pending; module
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/sigaction/ |
| D | 23-18.c | 86 sigset_t pending; in handler() local
|
| D | 23-15.c | 86 sigset_t pending; in handler() local
|
| D | 23-22.c | 86 sigset_t pending; in handler() local
|
| D | 23-11.c | 86 sigset_t pending; in handler() local
|