diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-09-07 13:39:26 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2017-09-07 13:39:26 -0700 |
| commit | a8fc020e0f9491effaf2f6cc8770245bd2d6a796 (patch) | |
| tree | f2ba2aa0bd4ab4257c26f3bf2c20dab07b71b726 /src/core/ext/filters/client_channel | |
| parent | ff952d292f3fb843f91ef7e0e5ec8772ec3038c5 (diff) | |
| parent | b6ef6e9ff5701d15a352f38a450de2af49d19657 (diff) | |
Merge github.com:grpc/grpc into write_completion
Diffstat (limited to 'src/core/ext/filters/client_channel')
| -rw-r--r-- | src/core/ext/filters/client_channel/channel_connectivity.c | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/core/ext/filters/client_channel/channel_connectivity.c b/src/core/ext/filters/client_channel/channel_connectivity.c index b83c95275f..0a9e90d12e 100644 --- a/src/core/ext/filters/client_channel/channel_connectivity.c +++ b/src/core/ext/filters/client_channel/channel_connectivity.c @@ -191,6 +191,12 @@ static void watcher_timer_init(grpc_exec_ctx *exec_ctx, void *arg, gpr_free(wa); } +int grpc_channel_support_connectivity_watcher(grpc_channel *channel) { + grpc_channel_element *client_channel_elem = + grpc_channel_stack_last_element(grpc_channel_get_channel_stack(channel)); + return client_channel_elem->filter != &grpc_client_channel_filter ? 0 : 1; +} + void grpc_channel_watch_connectivity_state( grpc_channel *channel, grpc_connectivity_state last_observed_state, gpr_timespec deadline, grpc_completion_queue *cq, void *tag) { |