diff options
Diffstat (limited to 'grpc/src/core/ext/filters/client_idle/client_idle_filter.cc')
-rw-r--r-- | grpc/src/core/ext/filters/client_idle/client_idle_filter.cc | 33 |
1 files changed, 17 insertions, 16 deletions
diff --git a/grpc/src/core/ext/filters/client_idle/client_idle_filter.cc b/grpc/src/core/ext/filters/client_idle/client_idle_filter.cc index 2ea3eade..01abaab7 100644 --- a/grpc/src/core/ext/filters/client_idle/client_idle_filter.cc +++ b/grpc/src/core/ext/filters/client_idle/client_idle_filter.cc @@ -126,8 +126,8 @@ grpc_millis GetClientIdleTimeout(const grpc_channel_args* args) { class ChannelData { public: - static grpc_error* Init(grpc_channel_element* elem, - grpc_channel_element_args* args); + static grpc_error_handle Init(grpc_channel_element* elem, + grpc_channel_element_args* args); static void Destroy(grpc_channel_element* elem); static void StartTransportOp(grpc_channel_element* elem, @@ -139,11 +139,12 @@ class ChannelData { private: ChannelData(grpc_channel_element* elem, grpc_channel_element_args* args, - grpc_error** error); + grpc_error_handle* error); ~ChannelData() = default; - static void IdleTimerCallback(void* arg, grpc_error* error); - static void IdleTransportOpCompleteCallback(void* arg, grpc_error* error); + static void IdleTimerCallback(void* arg, grpc_error_handle error); + static void IdleTransportOpCompleteCallback(void* arg, + grpc_error_handle error); void StartIdleTimer(); @@ -170,9 +171,9 @@ class ChannelData { grpc_closure idle_transport_op_complete_callback_; }; -grpc_error* ChannelData::Init(grpc_channel_element* elem, - grpc_channel_element_args* args) { - grpc_error* error = GRPC_ERROR_NONE; +grpc_error_handle ChannelData::Init(grpc_channel_element* elem, + grpc_channel_element_args* args) { + grpc_error_handle error = GRPC_ERROR_NONE; new (elem->channel_data) ChannelData(elem, args, &error); return error; } @@ -187,7 +188,7 @@ void ChannelData::StartTransportOp(grpc_channel_element* elem, ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); // Catch the disconnect_with_error transport op. if (op->disconnect_with_error != nullptr) { - // IncreaseCallCount() introduces a dummy call and prevent the timer from + // IncreaseCallCount() introduces a phony call and prevent the timer from // being reset by other threads. chand->IncreaseCallCount(); // If the timer has been set, cancel the timer. @@ -283,7 +284,7 @@ void ChannelData::DecreaseCallCount() { ChannelData::ChannelData(grpc_channel_element* elem, grpc_channel_element_args* args, - grpc_error** /*error*/) + grpc_error_handle* /*error*/) : elem_(elem), channel_stack_(args->channel_stack), client_idle_timeout_(GetClientIdleTimeout(args->channel_args)) { @@ -303,7 +304,7 @@ ChannelData::ChannelData(grpc_channel_element* elem, grpc_schedule_on_exec_ctx); } -void ChannelData::IdleTimerCallback(void* arg, grpc_error* error) { +void ChannelData::IdleTimerCallback(void* arg, grpc_error_handle error) { GRPC_IDLE_FILTER_LOG("timer alarms"); ChannelData* chand = static_cast<ChannelData*>(arg); if (error != GRPC_ERROR_NONE) { @@ -352,7 +353,7 @@ void ChannelData::IdleTimerCallback(void* arg, grpc_error* error) { } void ChannelData::IdleTransportOpCompleteCallback(void* arg, - grpc_error* /*error*/) { + grpc_error_handle /*error*/) { ChannelData* chand = static_cast<ChannelData*>(arg); GRPC_CHANNEL_STACK_UNREF(chand->channel_stack_, "idle transport op"); } @@ -381,15 +382,15 @@ void ChannelData::EnterIdle() { class CallData { public: - static grpc_error* Init(grpc_call_element* elem, - const grpc_call_element_args* args); + static grpc_error_handle Init(grpc_call_element* elem, + const grpc_call_element_args* args); static void Destroy(grpc_call_element* elem, const grpc_call_final_info* final_info, grpc_closure* then_schedule_closure); }; -grpc_error* CallData::Init(grpc_call_element* elem, - const grpc_call_element_args* /*args*/) { +grpc_error_handle CallData::Init(grpc_call_element* elem, + const grpc_call_element_args* /*args*/) { ChannelData* chand = static_cast<ChannelData*>(elem->channel_data); chand->IncreaseCallCount(); return GRPC_ERROR_NONE; |