diff options
Diffstat (limited to 'src/core/surface')
| -rw-r--r-- | src/core/surface/channel.h | 3 | ||||
| -rw-r--r-- | src/core/surface/secure_channel_create.c | 4 |
2 files changed, 5 insertions, 2 deletions
diff --git a/src/core/surface/channel.h b/src/core/surface/channel.h index f271616f60..593faec7df 100644 --- a/src/core/surface/channel.h +++ b/src/core/surface/channel.h @@ -36,6 +36,7 @@ #include "src/core/channel/channel_stack.h" #include "src/core/client_config/subchannel_factory.h" +#include "src/core/iomgr/workqueue.h" grpc_channel *grpc_channel_create_from_filters( const char *target, const grpc_channel_filter **filters, size_t count, @@ -61,6 +62,8 @@ grpc_mdstr *grpc_channel_get_encodings_accepted_by_peer_string( grpc_mdstr *grpc_channel_get_message_string(grpc_channel *channel); gpr_uint32 grpc_channel_get_max_message_length(grpc_channel *channel); +grpc_workqueue *grpc_channel_get_workqueue(grpc_channel *channel); + #ifdef GRPC_CHANNEL_REF_COUNT_DEBUG void grpc_channel_internal_ref(grpc_channel *channel, const char *reason); void grpc_channel_internal_unref(grpc_channel *channel, const char *reason); diff --git a/src/core/surface/secure_channel_create.c b/src/core/surface/secure_channel_create.c index 35b60bdbef..1b6d1b3f46 100644 --- a/src/core/surface/secure_channel_create.c +++ b/src/core/surface/secure_channel_create.c @@ -95,7 +95,7 @@ static void on_secure_transport_setup_done(void *arg, } notify = c->notify; c->notify = NULL; - grpc_iomgr_add_callback(notify); + notify->cb(notify->cb_arg, 1); } static void connected(void *arg, grpc_endpoint *tcp) { @@ -108,7 +108,7 @@ static void connected(void *arg, grpc_endpoint *tcp) { memset(c->result, 0, sizeof(*c->result)); notify = c->notify; c->notify = NULL; - grpc_iomgr_add_callback(notify); + notify->cb(notify->cb_arg, 1); } } |