Synnefo » snf-ganeti

    """Is the current thread a current level owner?"""

    return threading.currentThread() in self.__owners

    """Note the current thread owns the given lock"""

    else:

    """Note the current thread owns the given lock"""

      del self.__owners[threading.currentThread()]

  def _list_owned(self):

      # so we'll get the list lock exclusively as well in order to be able to

      # do add() on the set while owning it.

      self.__lock.acquire(shared=shared)

    try:

      # Support passing in a single resource to acquire rather than many

      if isinstance(names, basestring):

        names = [names]

      else:

        names.sort()

      acquire_list = []

        try:

          lock.acquire(shared=shared) # raises LockError if the lock is deleted

          # now the lock cannot be deleted, we have it!

          acquired.add(lname)

        except (errors.LockError):

          if self.__lock._is_owned():

            name_fail = lname

            for lname in self._list_owned():

              self.__lockdict[lname].release()

            raise errors.LockError('non-existing lock in set (%s)' % name_fail)

        except:

          # We shouldn't have problems adding the lock to the owners list, but

    # After this 'add' can work again

    if self.__lock._is_owned():

      self.__lock.release()

    for lockname in names:

      # If we are sure the lock doesn't leave __lockdict without being

      # exclusively held we can do this...

      self.__lockdict[lockname].release()

  def add(self, names, acquired=0, shared=0):

    """Add a new set of elements to the set

          lock.acquire(shared=shared)

          # now the lock cannot be deleted, we have it!

          try:

          except:

            # We shouldn't have problems adding the lock to the owners list,

            # but if we did we'll try to release this lock and re-raise

        del self.__lockdict[lname]

        # And let's remove it from our private list if we owned it.

        if self._is_owned():

    return removed