Home
last modified time | relevance | path

Searched refs:started_send_message_count (Results 1 – 2 of 2) sorted by relevance

/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc874 size_t started_send_message_count; member
1893 retry_state->started_send_message_count < calld->send_messages->size()) { in pending_batch_is_unstarted()
2058 retry_state->started_send_message_count < calld->send_messages->size(); in add_closures_for_replay_or_pending_send_ops()
2247 chand, calld, retry_state->started_send_message_count); in add_retriable_send_message_op()
2250 (*calld->send_messages)[retry_state->started_send_message_count]; in add_retriable_send_message_op()
2251 ++retry_state->started_send_message_count; in add_retriable_send_message_op()
2382 if (retry_state->started_send_message_count < calld->send_messages->size() && in maybe_create_subchannel_batch_for_replay()
2383 retry_state->started_send_message_count == in maybe_create_subchannel_batch_for_replay()
2403 retry_state->started_send_message_count == calld->send_messages->size() && in maybe_create_subchannel_batch_for_replay()
2447 retry_state->started_send_message_count) { in add_subchannel_batches_for_pending_batches()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc635 size_t started_send_message_count = 0; member
4131 retry_state->started_send_message_count < send_messages_.size()) { in PendingBatchIsUnstarted()
4268 retry_state->started_send_message_count < send_messages_.size(); in AddClosuresForReplayOrPendingSendOps()
4442 chand_, this, retry_state->started_send_message_count); in AddRetriableSendMessageOp()
4445 send_messages_[retry_state->started_send_message_count]; in AddRetriableSendMessageOp()
4446 ++retry_state->started_send_message_count; in AddRetriableSendMessageOp()
4564 if (retry_state->started_send_message_count < send_messages_.size() && in MaybeCreateSubchannelBatchForReplay()
4565 retry_state->started_send_message_count == in MaybeCreateSubchannelBatchForReplay()
4585 retry_state->started_send_message_count == send_messages_.size() && in MaybeCreateSubchannelBatchForReplay()
4624 retry_state->started_send_message_count) { in AddSubchannelBatchesForPendingBatches()
[all …]