summaryrefslogtreecommitdiff
path: root/grpc/src/core/ext/filters/client_idle/client_idle_filter.cc
diff options
context:
space:
mode:
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.cc33
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;