From af3213f38bb5c3737c94a685ee508d289552b5a1 Mon Sep 17 00:00:00 2001 From: Alexander Polcyn Date: Wed, 15 Mar 2017 16:44:52 -0700 Subject: [PATCH] remove now-unused channel completion queues --- src/ruby/ext/grpc/rb_channel.c | 5 ----- 1 file changed, 5 deletions(-) diff --git a/src/ruby/ext/grpc/rb_channel.c b/src/ruby/ext/grpc/rb_channel.c index 94a10faf3fd..3b1111e5e2c 100644 --- a/src/ruby/ext/grpc/rb_channel.c +++ b/src/ruby/ext/grpc/rb_channel.c @@ -73,7 +73,6 @@ typedef struct grpc_rb_channel { /* The actual channel */ grpc_channel *wrapped; - grpc_completion_queue *queue; int request_safe_destroy; int safe_to_destroy; grpc_connectivity_state current_connectivity_state; @@ -103,7 +102,6 @@ static void grpc_rb_channel_free(void *p) { if (ch->wrapped != NULL) { grpc_rb_channel_safe_destroy(ch); - grpc_rb_completion_queue_destroy(ch->queue); ch->wrapped = NULL; } @@ -215,7 +213,6 @@ static VALUE grpc_rb_channel_init(int argc, VALUE *argv, VALUE self) { } rb_ivar_set(self, id_target, target); wrapper->wrapped = ch; - wrapper->queue = grpc_completion_queue_create(NULL); return self; } @@ -404,8 +401,6 @@ static VALUE grpc_rb_channel_destroy(VALUE self) { ch = wrapper->wrapped; if (ch != NULL) { grpc_rb_channel_safe_destroy(wrapper); - GPR_ASSERT(wrapper->queue != NULL); - grpc_rb_completion_queue_destroy(wrapper->queue); wrapper->wrapped = NULL; }