X-Git-Url: http://xvm.mit.edu/gitweb/invirt/packages/invirt-base.git/blobdiff_plain/dc5e452649dbc0d452c64f32875d38e25d018367..56cf287cf395f1cd8f135cabb8531ff37d52e122:/files/usr/share/python-support/sipb-xen-base/invirt/common.py diff --git a/files/usr/share/python-support/sipb-xen-base/invirt/common.py b/files/usr/share/python-support/sipb-xen-base/invirt/common.py index b193ecc..d986196 100644 --- a/files/usr/share/python-support/sipb-xen-base/invirt/common.py +++ b/files/usr/share/python-support/sipb-xen-base/invirt/common.py @@ -1,6 +1,5 @@ import unittest -from fcntl import flock, LOCK_EX, LOCK_UN -from os import remove +from fcntl import flock, LOCK_EX, LOCK_SH, LOCK_UN class struct(object): 'A simple namespace object.' @@ -40,7 +39,7 @@ def with_closing(rsrc): finally: rsrc.close() return wrapper -def with_lock_file(path): +def with_lock_file(path, exclusive = True): """ Context manager for lock files. Example: @@ -54,10 +53,11 @@ def with_lock_file(path): def wrapper(func): @with_closing(file(path, 'w')) def g(f): - flock(f, LOCK_EX) + if exclusive: locktype = LOCK_EX + else: locktype = LOCK_SH + flock(f, locktype) try: return func() finally: flock(f, LOCK_UN) - remove(path) return g return wrapper