def acquire(self, id, shared=False):
if shared:
self.lockid = id
+ self._addToRegistry()
return
d = xenrt.TEC().lookup("RESOURCE_LOCK_DIR")
if not os.path.exists(d):
except:
pass
self.lockid = id
+ self._addToRegistry()
+
+ def _addToRegistry(self):
+ xenrt.GEC().registry.centralResourcePut(self.lockid, self)
def _listProcess(self,id):
d = xenrt.TEC().lookup("RESOURCE_LOCK_DIR")
if not self.rangeObj:
xenrt.TEC().gec.registerCallback(self, mark=True, order=1)
self.lockid = "IP4ADDR-%s" % self.addr
+ xenrt.GEC().registry.centralResourcePut(self.lockid, self)
def getAddr(self):
return self.addr