Home
last modified time | relevance | path

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

/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc997 subchannel_call_retry_state* retry_state);
1093 grpc_call_element* elem, subchannel_call_retry_state* retry_state) { in free_cached_send_op_data_after_commit() argument
1096 if (retry_state->completed_send_initial_metadata) { in free_cached_send_op_data_after_commit()
1099 for (size_t i = 0; i < retry_state->completed_send_message_count; ++i) { in free_cached_send_op_data_after_commit()
1102 if (retry_state->completed_send_trailing_metadata) { in free_cached_send_op_data_after_commit()
1111 subchannel_call_retry_state* retry_state) { in free_cached_send_op_data_for_completed_batch() argument
1119 retry_state->completed_send_message_count - 1); in free_cached_send_op_data_for_completed_batch()
1183 subchannel_call_retry_state* retry_state = in pending_batches_add() local
1189 retry_commit(elem, retry_state); in pending_batches_add()
1369 subchannel_call_retry_state* retry_state) { in retry_commit() argument
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc678 void FreeCachedSendOpDataAfterCommit(SubchannelCallRetryState* retry_state);
683 SubchannelCallRetryState* retry_state);
719 void RetryCommit(SubchannelCallRetryState* retry_state);
721 void DoRetry(SubchannelCallRetryState* retry_state,
752 SubchannelCallRetryState* retry_state, CallCombinerClosureList* closures);
756 SubchannelCallRetryState* retry_state);
760 SubchannelCallRetryState* retry_state, grpc_error* error,
780 SubchannelCallRetryState* retry_state, CallCombinerClosureList* closures);
791 void AddRetriableSendInitialMetadataOp(SubchannelCallRetryState* retry_state,
794 void AddRetriableSendMessageOp(SubchannelCallRetryState* retry_state,
[all …]