← Back to branch summary

~bzr-pqm/bzr/bzr.dev

« back to all changes in this revision

Viewing changes to bzrlib/lockdir.py

  • Committer: Martin Pool
  • Date: 2011-06-07 06:18:01 UTC
  • mto: (5425.4.26 220464-stale-locks)
  • mto: This revision was merged to the branch mainline in revision 5970.
  • Revision ID: mbp@canonical.com-20110607061801-bnx5xng4gfc6q8ys
PEP8 cleanups

Show diffs side-by-side

added added

removed removed

Lines of Context:
bzrlib/lockdir.py
226
226
 
227
227
        :returns: The nonce of the lock, if it was successfully acquired.
228
228
 
229
 
        :raises LockContention: If the lock is held by someone else.  The exception
230
 
            contains the info of the current holder of the lock.
 
229
        :raises LockContention: If the lock is held by someone else.  The
 
230
            exception contains the info of the current holder of the lock.
231
231
        """
232
232
        self._trace("lock_write...")
233
233
        start_time = time.time()
389
389
        if holder_info is not None:
390
390
            if ui.ui_factory.confirm_action(
391
391
                u"Break %(lock_info)s",
392
 
                'bzrlib.lockdir.break', 
 
392
                'bzrlib.lockdir.break',
393
393
                dict(lock_info=unicode(holder_info))):
394
394
                result = self.force_break(holder_info)
395
395
                ui.ui_factory.show_message(
406
406
        It is possible that another process may sneak in and take the
407
407
        lock before the breaking process acquires it.
408
408
 
409
 
        :param dead_holder_info: 
 
409
        :param dead_holder_info:
410
410
            Must be the result of a previous LockDir.peek() call; this is used
411
411
            to check that it's still held by the same process that the user
412
412
            decided was dead.  If this is not the current holder,
442
442
 
443
443
    def force_break_corrupt(self, corrupt_info_lines):
444
444
        """Release a lock that has been corrupted.
445
 
        
 
445
 
446
446
        This is very similar to force_break, it except it doesn't assume that
447
447
        self.peek() can work.
448
 
        
 
448
 
449
449
        :param corrupt_info_lines: the lines of the corrupted info file, used
450
450
            to check that the lock hasn't changed between reading the (corrupt)
451
451
            info file and calling force_break_corrupt.
698
698
    """The information recorded about a held lock.
699
699
 
700
700
    This information is recorded into the lock when it's taken, and it can be
701
 
    read back by any process with access to the lockdir.  It can be used, for 
 
701
    read back by any process with access to the lockdir.  It can be used, for
702
702
    example, to tell the user who holds the lock, or to try to detect whether
703
703
    the lock holder is still alive.
704
704
 
724
724
 
725
725
        For example, the start time is presented relative to the current time,
726
726
        rather than as seconds since the epoch.
727
 
        
728
 
        Returns a list of [user, hostname, pid, time_ago] all as readable 
 
727
 
 
728
        Returns a list of [user, hostname, pid, time_ago] all as readable
729
729
        strings.
730
730
        """
731
731
        start_time = self.info_dict.get('start_time')
791
791
            or cmp(self.info_dict, other.info_dict))
792
792
 
793
793
    def is_locked_by_this_process(self):
794
 
        """Check if the hostname and pid in the lock are the same as for this process."""
 
794
        """True if this process seems to be the current lock holder."""
795
795
        return (
796
796
            self.get('hostname') == get_host_name()
797
797
            and self.get('pid') == str(os.getpid())
825
825
        try:
826
826
            pid = int(pid_str)
827
827
        except ValueError:
828
 
            mutter("can't parse pid %r from %r" 
 
828
            mutter("can't parse pid %r from %r"
829
829
                % (pid_str, self))
830
830
            return False
831
831
        return osutils.is_local_pid_dead(pid)