lock.py
49 lines
| 1.1 KiB
| text/x-python
|
PythonLexer
/ mercurial / lock.py
mpm@selenic.com
|
r161 | # lock.py - simple locking scheme for mercurial | ||
# | ||||
# Copyright 2005 Matt Mackall <mpm@selenic.com> | ||||
# | ||||
# This software may be used and distributed according to the terms | ||||
# of the GNU General Public License, incorporated herein by reference. | ||||
import os, time | ||||
mpm@selenic.com
|
r422 | import util | ||
mpm@selenic.com
|
r161 | |||
class LockHeld(Exception): | ||||
pass | ||||
class lock: | ||||
def __init__(self, file, wait = 1): | ||||
self.f = file | ||||
self.held = 0 | ||||
self.wait = wait | ||||
self.lock() | ||||
def __del__(self): | ||||
self.release() | ||||
def lock(self): | ||||
while 1: | ||||
try: | ||||
self.trylock() | ||||
return 1 | ||||
except LockHeld, inst: | ||||
if self.wait: | ||||
time.sleep(1) | ||||
continue | ||||
raise inst | ||||
mpm@selenic.com
|
r515 | |||
mpm@selenic.com
|
r161 | def trylock(self): | ||
pid = os.getpid() | ||||
try: | ||||
mpm@selenic.com
|
r422 | util.makelock(str(pid), self.f) | ||
mpm@selenic.com
|
r161 | self.held = 1 | ||
except: | ||||
mpm@selenic.com
|
r422 | raise LockHeld(util.readlock(self.f)) | ||
mpm@selenic.com
|
r161 | |||
def release(self): | ||||
if self.held: | ||||
self.held = 0 | ||||
mpm@selenic.com
|
r503 | try: | ||
os.unlink(self.f) | ||||
except: pass | ||||
mpm@selenic.com
|
r161 | |||