Synnefo » snf-ganeti

  def ReportLocks(self, msg):

    """Report lock operations.

  def _ReportLocks(self, level, names, shared, timeout, acquired, result):

    """Reports lock operations.

    @type level: int

    @param level: Lock level

    @type names: list or string

    @param names: Lock names

    @type shared: bool

    @param shared: Whether the locks should be acquired in shared mode

    @type timeout: None or float

    @param timeout: Timeout for acquiring the locks

    @type acquired: bool

    @param acquired: Whether the locks have already been acquired

    @type result: None or set

    @param result: Result from L{locking.GanetiLockManager.acquire}

    """

    parts = []

    # Build message

    if acquired:

      if result is None:

        parts.append("timeout")

      else:

        parts.append("acquired")

    else:

      parts.append("waiting")

      if timeout is None:

        parts.append("blocking")

      else:

        parts.append("timeout=%0.6fs" % timeout)

    parts.append(locking.LEVEL_NAMES[level])

    if names == locking.ALL_SET:

      parts.append("ALL")

    elif isinstance(names, basestring):

      parts.append(names)

    else:

      parts.append(",".join(sorted(names)))

    if shared:

      parts.append("shared")

    else:

      parts.append("exclusive")

    msg = "/".join(parts)

    logging.debug("LU locks %s", msg)

    if self._cbs:

      self._cbs.ReportLocks(msg)

    self._ReportLocks(level, names, shared, timeout, False, None)

    self._ReportLocks(level, names, shared, timeout, True, acquired)