| /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/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | retry_filter.cc | 665 PendingBatch* pending) { in PendingBatchIsUnstarted()
763 PendingBatch* pending = &calld_->pending_batches_[i]; in AddBatchesForPendingBatches() local
1075 PendingBatch* pending = call_attempt->calld_->PendingBatchFind( in InvokeRecvInitialMetadataCallback() local
1168 PendingBatch* pending = calld->PendingBatchFind( in InvokeRecvMessageCallback() local
1278 PendingBatch* pending = calld->PendingBatchFind( in AddClosureForRecvTrailingMetadataReady() local
1342 PendingBatch* pending = &calld->pending_batches_[i]; in AddClosuresToFailUnstartedPendingBatches() local
1432 PendingBatch* pending = calld->PendingBatchFind( in AddClosuresForCompletedPendingBatch() local
1468 PendingBatch* pending = &calld->pending_batches_[i]; in AddClosuresForReplayOrPendingSendOps() local
1803 PendingBatch* pending = PendingBatchesAdd(batch); in StartTransportStreamOpBatch() local
1888 void RetryFilter::CallData::MaybeCacheSendOpsForBatch(PendingBatch* pending) { in MaybeCacheSendOpsForBatch()
[all …]
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/ |
| D | quic_stream_test.cc | 63 TestStream(PendingStream* pending, QuicSession* session, bool is_static) in TestStream()
186 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
198 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
209 PendingStream pending(server_initiated_pending_stream_id, session_.get()); in TEST_P() local
217 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
263 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
278 PendingStream pending(bidirection_stream_id, session_.get()); in TEST_P() local
293 PendingStream pending(bidirection_stream_id, session_.get()); in TEST_P() local
305 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
326 PendingStream pending(kTestPendingStreamId, session_.get()); in TEST_P() local
|
| /external/rust/crates/tokio-stream/src/ |
| D | lib.rs | 93 mod pending; module
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/fork/ |
| D | 12-1.c | 57 sigset_t mask, pending; in main() local
|
| /external/cronet/net/third_party/quiche/src/quiche/quic/core/qpack/ |
| D | qpack_receive_stream.cc | 11 QpackReceiveStream::QpackReceiveStream(PendingStream* pending, in QpackReceiveStream()
|
| /external/rust/crates/libz-sys/src/zlib-ng/test/ |
| D | test_deflate_pending.cc | 19 TEST(deflate, pending) { in TEST() argument
|
| /external/musl/src/multibyte/ |
| D | mbrtoc16.c | 8 unsigned *pending = (unsigned *)ps; in mbrtoc16() local
|
| /external/rust/crates/grpcio-sys/grpc/third_party/abseil-cpp/absl/strings/internal/ |
| D | cord_internal.cc | 36 absl::InlinedVector<CordRep*, Constants::kInlinedVectorSize> pending; in Destroy() local
|
| /external/ltp/testcases/open_posix_testsuite/conformance/interfaces/sigaction/ |
| D | 23-2.c | 86 sigset_t pending; in handler() local
|
| D | 23-14.c | 86 sigset_t pending; in handler() local
|
| D | 23-5.c | 86 sigset_t pending; in handler() local
|
| D | 23-9.c | 86 sigset_t pending; in handler() local
|
| D | 23-19.c | 78 sigset_t pending; in handler() local
|
| D | 23-17.c | 86 sigset_t pending; in handler() local
|
| D | 23-13.c | 86 sigset_t pending; in handler() local
|
| D | 23-12.c | 86 sigset_t pending; in handler() local
|
| D | 23-25.c | 86 sigset_t pending; in handler() local
|
| D | 23-1.c | 86 sigset_t pending; in handler() local
|
| D | 23-26.c | 86 sigset_t pending; in handler() local
|
| D | 23-16.c | 86 sigset_t pending; in handler() local
|
| D | 23-24.c | 86 sigset_t pending; in handler() local
|
| D | 23-6.c | 86 sigset_t pending; in handler() local
|
| D | 23-21.c | 86 sigset_t pending; in handler() local
|
| /external/rust/crates/futures-util/src/async_await/ |
| D | pending.rs | 16 macro_rules! pending { macro
|