diff options
author | Craig Tiller <ctiller@google.com> | 2015-10-02 16:59:50 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2015-10-02 16:59:50 -0700 |
commit | 8a50de7e65a9121eb676bc0802c798f1886b35c7 (patch) | |
tree | ec8d7c68782e5fca84f0b0bb8e478ddfa6b3af85 /src/core/client_config/subchannel.c | |
parent | 7cc27777b45b531320427a5cf93a2938e68c5299 (diff) | |
parent | 3b147818e3aef9d77cce55e96447b568558f2e62 (diff) |
Merge pull request #3586 from dgquintas/conn_state_watcher_plucking
Added subchannel ability to unsubscribe to connectivity state changes.
Diffstat (limited to 'src/core/client_config/subchannel.c')
-rw-r--r-- | src/core/client_config/subchannel.c | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/src/core/client_config/subchannel.c b/src/core/client_config/subchannel.c index e77311f4f8..a2c521a20d 100644 --- a/src/core/client_config/subchannel.c +++ b/src/core/client_config/subchannel.c @@ -413,6 +413,17 @@ void grpc_subchannel_notify_on_state_change(grpc_exec_ctx *exec_ctx, } } +int grpc_subchannel_state_change_unsubscribe(grpc_exec_ctx *exec_ctx, + grpc_subchannel *c, + grpc_closure *subscribed_notify) { + int success; + gpr_mu_lock(&c->mu); + success = grpc_connectivity_state_change_unsubscribe( + exec_ctx, &c->state_tracker, subscribed_notify); + gpr_mu_unlock(&c->mu); + return success; +} + void grpc_subchannel_process_transport_op(grpc_exec_ctx *exec_ctx, grpc_subchannel *c, grpc_transport_op *op) { |