def init_ssh():
  global _master_keys_lock
  assert _master_keys_lock is None, "Should only call init_ssh once"
  _master_keys_lock = _threading.Lock()
Called when the connection to zookeeper has a state change.
dataset/ETHPy150Open android/tools_repo/git_config.py/init_ssh--crossover with--dataset/ETHPy150Open liquidgecka/twitcher/twitcher/zkwrapper.py/ZKWrapper._global_watch