def acquire(self, shared=0, timeout=None, priority=None,
              test_notify=None):
    if priority is None:
      priority = _DEFAULT_PRIORITY

    self.__lock.acquire()
    try:
      # We already got the lock, notify now
      if __debug__ and callable(test_notify):
        test_notify()

      return self.__acquire_unlocked(shared, timeout, priority)
    finally:
      self.__lock.release()
Return cassandra node info
dataset/ETHPy150Open ganeti/ganeti/lib/locking.py/SharedLock.acquire--crossover with--dataset/ETHPy150Open saltstack/salt/salt/modules/cassandra.py/info