Mercurial > public > mercurial-scm > hg-stable
diff mercurial/lock.py @ 43077:687b865b95ad
formatting: byteify all mercurial/ and hgext/ string literals
Done with
python3.7 contrib/byteify-strings.py -i $(hg files 'set:mercurial/**.py - mercurial/thirdparty/** + hgext/**.py - hgext/fsmonitor/pywatchman/** - mercurial/__init__.py')
black -l 80 -t py33 -S $(hg files 'set:**.py - mercurial/thirdparty/** - "contrib/python-zstandard/**" - hgext/fsmonitor/pywatchman/**')
# skip-blame mass-reformatting only
Differential Revision: https://phab.mercurial-scm.org/D6972
author | Augie Fackler <augie@google.com> |
---|---|
date | Sun, 06 Oct 2019 09:48:39 -0400 |
parents | 2372284d9457 |
children | c59eb1560c44 |
line wrap: on
line diff
--- a/mercurial/lock.py Sun Oct 06 09:45:02 2019 -0400 +++ b/mercurial/lock.py Sun Oct 06 09:48:39 2019 -0400 @@ -35,9 +35,9 @@ extra Linux-specific pid namespace identifier. """ result = encoding.strtolocal(socket.gethostname()) - if pycompat.sysplatform.startswith('linux'): + if pycompat.sysplatform.startswith(b'linux'): try: - result += '/%x' % os.stat('/proc/self/ns/pid').st_ino + result += b'/%x' % os.stat(b'/proc/self/ns/pid').st_ino except OSError as ex: if ex.errno not in (errno.ENOENT, errno.EACCES, errno.ENOTDIR): raise @@ -76,7 +76,13 @@ try: # save handlers first so they can be restored even if a setup is # interrupted between signal.signal() and orighandlers[] =. - for name in ['CTRL_C_EVENT', 'SIGINT', 'SIGBREAK', 'SIGHUP', 'SIGTERM']: + for name in [ + b'CTRL_C_EVENT', + b'SIGINT', + b'SIGBREAK', + b'SIGHUP', + b'SIGTERM', + ]: num = getattr(signal, name, None) if num and num not in orighandlers: orighandlers[num] = signal.getsignal(num) @@ -114,17 +120,17 @@ def printwarning(printer, locker): """issue the usual "waiting on lock" message through any channel""" # show more details for new-style locks - if ':' in locker: - host, pid = locker.split(":", 1) + if b':' in locker: + host, pid = locker.split(b":", 1) msg = _( - "waiting for lock on %s held by process %r on host %r\n" + b"waiting for lock on %s held by process %r on host %r\n" ) % ( pycompat.bytestr(l.desc), pycompat.bytestr(pid), pycompat.bytestr(host), ) else: - msg = _("waiting for lock on %s held by %r\n") % ( + msg = _(b"waiting for lock on %s held by %r\n") % ( l.desc, pycompat.bytestr(locker), ) @@ -159,9 +165,9 @@ l.delay = delay if l.delay: if 0 <= warningidx <= l.delay: - ui.warn(_("got lock after %d seconds\n") % l.delay) + ui.warn(_(b"got lock after %d seconds\n") % l.delay) else: - ui.debug("got lock after %d seconds\n" % l.delay) + ui.debug(b"got lock after %d seconds\n" % l.delay) if l.acquirefn: l.acquirefn() return l @@ -268,7 +274,7 @@ return if lock._host is None: lock._host = _getlockprefix() - lockname = '%s:%d' % (lock._host, self.pid) + lockname = b'%s:%d' % (lock._host, self.pid) retry = 5 while not self.held and retry: retry -= 1 @@ -307,7 +313,7 @@ # use empty locker to mean "busy for frequent lock/unlock # by many processes" raise error.LockHeld( - errno.EAGAIN, self.vfs.join(self.f), self.desc, "" + errno.EAGAIN, self.vfs.join(self.f), self.desc, b"" ) def _readlock(self): @@ -327,7 +333,7 @@ if locker is None: return None try: - host, pid = locker.split(":", 1) + host, pid = locker.split(b":", 1) except ValueError: return locker if host != lock._host: @@ -341,7 +347,7 @@ # if locker dead, break lock. must do this with another lock # held, or can race and break valid lock. try: - l = lock(self.vfs, self.f + '.break', timeout=0) + l = lock(self.vfs, self.f + b'.break', timeout=0) self.vfs.unlink(self.f) l.release() except error.LockError: @@ -371,11 +377,11 @@ """ if not self.held: raise error.LockInheritanceContractViolation( - 'inherit can only be called while lock is held' + b'inherit can only be called while lock is held' ) if self._inherited: raise error.LockInheritanceContractViolation( - 'inherit cannot be called while lock is already inherited' + b'inherit cannot be called while lock is already inherited' ) if self._inheritchecker is not None: self._inheritchecker()