|
|
|
@ -39,12 +39,10 @@ void grpc_connectivity_state_init(grpc_connectivity_state_tracker *tracker, |
|
|
|
|
grpc_connectivity_state init_state) { |
|
|
|
|
tracker->current_state = init_state; |
|
|
|
|
tracker->watchers = NULL; |
|
|
|
|
/*gpr_log(GPR_DEBUG, "CS:%p:init:%d", tracker, init_state);*/ |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
void grpc_connectivity_state_destroy(grpc_connectivity_state_tracker *tracker) { |
|
|
|
|
grpc_connectivity_state_watcher *w; |
|
|
|
|
/*gpr_log(GPR_DEBUG, "CS:%p:destroy", tracker);*/ |
|
|
|
|
while ((w = tracker->watchers)) { |
|
|
|
|
tracker->watchers = w->next; |
|
|
|
|
|
|
|
|
@ -84,7 +82,6 @@ void grpc_connectivity_state_set_with_scheduler( |
|
|
|
|
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);*/ |
|
|
|
|
if (tracker->current_state == state) { |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|