]> xenbits.xensource.com Git - xenrt-citrix/xenrt.git/commitdiff
Add to registry
authorJohn Dilley <john.dilley@citrix.com>
Wed, 4 Nov 2015 18:12:56 +0000 (18:12 +0000)
committerJohn Dilley <john.dilley@citrix.com>
Wed, 4 Nov 2015 18:12:56 +0000 (18:12 +0000)
exec/xenrt/resources.py

index 238d951ebda19e15a5f74a7a530982cf28986cf9..3a1af12449fd1b8b3ecc70af5078be4f6a9e7e36 100755 (executable)
@@ -380,6 +380,7 @@ class CentralResource(object):
     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):
@@ -423,6 +424,10 @@ class CentralResource(object):
         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")
@@ -3378,6 +3383,7 @@ class StaticIP4AddrDHCP(object):
         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