def _dispatch_client_change_callback(self, client):
if self._is_destroyed:
return
log.info("Start dispatching client change callback.")
for callback in self._client_callbacks:
try:
callback(client)
except (Exception, gevent.Timeout):
self._sc.increment("errors.zk.client.change_callback.failure",
tags={'host': hostname},
sample_rate=1)
log.exception("Failed to exec client change callback.")
评论列表
文章目录