/usr/share/pyshared/arcom/store/basestore.py is in nordugrid-arc-python 1.1.1-1.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 | import arc
import os, threading, traceback
from arcom.logger import Logger
log = Logger(arc.Logger(arc.Logger_getRootLogger(), 'arcom.BaseStore'))
class BaseStore:
def __init__(self, storecfg, non_existent_object = {}):
""" Constructor of BaseStore.
BaseStore(storecfg)
'storecfg' is an XMLNode with a 'DataDir'
'non_existent_object' will be returned if an object not found
"""
# get the datadir from the storecfg XMLNode
self.datadir = str(storecfg.Get('DataDir'))
if not self.datadir:
log.msg(arc.ERROR, "DataDir is missing from store config")
raise Exception, "DataDir is missing from store config"
# set the value which we should return if there an object does not exist
self.non_existent_object = non_existent_object
# if the given data directory does not exist, try to create it
if not os.path.exists(self.datadir):
os.mkdir(self.datadir)
# initialize a lock which can be used to avoid race conditions
self.llock = threading.Lock()
def lock(self, blocking = True):
""" Acquire the lock.
lock(blocking = True)
'blocking': if blocking is True, then this only returns when the lock is acquired.
If it is False, then it returns immediately with False if the lock is not available,
or with True if it could be acquired.
"""
return self.llock.acquire(blocking)
def unlock(self):
""" Release the lock.
unlock()
"""
self.llock.release()
|