diff options
Diffstat (limited to 'src/core/transport/connectivity_state.c')
| -rw-r--r-- | src/core/transport/connectivity_state.c | 17 |
1 files changed, 14 insertions, 3 deletions
diff --git a/src/core/transport/connectivity_state.c b/src/core/transport/connectivity_state.c index 8df08af32f..9a956a5a58 100644 --- a/src/core/transport/connectivity_state.c +++ b/src/core/transport/connectivity_state.c @@ -79,8 +79,10 @@ int grpc_connectivity_state_notify_on_state_change( return tracker->current_state == GRPC_CHANNEL_IDLE; } -void grpc_connectivity_state_set(grpc_connectivity_state_tracker *tracker, - grpc_connectivity_state state) { +void grpc_connectivity_state_set_with_scheduler( + grpc_connectivity_state_tracker *tracker, grpc_connectivity_state state, + void (*scheduler)(void *arg, grpc_iomgr_closure *closure), + void *arg) { grpc_connectivity_state_watcher *new = NULL; grpc_connectivity_state_watcher *w; /*gpr_log(GPR_DEBUG, "CS:%p:set:%d", tracker, state);*/ @@ -93,7 +95,7 @@ void grpc_connectivity_state_set(grpc_connectivity_state_tracker *tracker, if (state != *w->current) { *w->current = state; - grpc_iomgr_add_callback(w->notify); + scheduler(arg, w->notify); gpr_free(w); } else { w->next = new; @@ -102,3 +104,12 @@ void grpc_connectivity_state_set(grpc_connectivity_state_tracker *tracker, } tracker->watchers = new; } + +static void default_scheduler(void *ignored, grpc_iomgr_closure *closure) { + grpc_iomgr_add_callback(closure); +} + +void grpc_connectivity_state_set(grpc_connectivity_state_tracker *tracker, + grpc_connectivity_state state) { + grpc_connectivity_state_set_with_scheduler(tracker, state, default_scheduler, NULL); +} |