Home
last modified time | relevance | path

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

/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc2365 subchannel_batch_data* replay_batch_data = nullptr; in maybe_create_subchannel_batch_for_replay() local
2376 replay_batch_data = batch_data_create(elem, 1, true /* set_on_complete */); in maybe_create_subchannel_batch_for_replay()
2378 replay_batch_data); in maybe_create_subchannel_batch_for_replay()
2392 if (replay_batch_data == nullptr) { in maybe_create_subchannel_batch_for_replay()
2393 replay_batch_data = in maybe_create_subchannel_batch_for_replay()
2396 add_retriable_send_message_op(elem, retry_state, replay_batch_data); in maybe_create_subchannel_batch_for_replay()
2412 if (replay_batch_data == nullptr) { in maybe_create_subchannel_batch_for_replay()
2413 replay_batch_data = in maybe_create_subchannel_batch_for_replay()
2417 replay_batch_data); in maybe_create_subchannel_batch_for_replay()
2419 return replay_batch_data; in maybe_create_subchannel_batch_for_replay()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc4547 SubchannelCallBatchData* replay_batch_data = nullptr; in MaybeCreateSubchannelBatchForReplay() local
4558 replay_batch_data = in MaybeCreateSubchannelBatchForReplay()
4560 AddRetriableSendInitialMetadataOp(retry_state, replay_batch_data); in MaybeCreateSubchannelBatchForReplay()
4574 if (replay_batch_data == nullptr) { in MaybeCreateSubchannelBatchForReplay()
4575 replay_batch_data = in MaybeCreateSubchannelBatchForReplay()
4578 AddRetriableSendMessageOp(retry_state, replay_batch_data); in MaybeCreateSubchannelBatchForReplay()
4594 if (replay_batch_data == nullptr) { in MaybeCreateSubchannelBatchForReplay()
4595 replay_batch_data = in MaybeCreateSubchannelBatchForReplay()
4598 AddRetriableSendTrailingMetadataOp(retry_state, replay_batch_data); in MaybeCreateSubchannelBatchForReplay()
4600 return replay_batch_data; in MaybeCreateSubchannelBatchForReplay()
[all …]