/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

Revision 61cf6b5e

         # Declare that we don't want to remove the instance lock anymore, as we've
         # added the instance to the config
         del self.remove_locks[locking.LEVEL_INSTANCE]
         # Remove the temp. assignements for the instance's drbds
         self.cfg.ReleaseDRBDMinors(instance)
         # Unlock all the nodes
         if self.op.mode == constants.INSTANCE_IMPORT:
           nodes_keep = [self.op.src_node]
-...
           dev.logical_id = new_logical_id
           cfg.SetDiskID(dev, pri_node)
         cfg.Update(instance)
         # we can remove now the temp minors as now the new values are
         # written to the config file (and therefore stable)
         self.cfg.ReleaseDRBDMinors(instance.name)
         # and now perform the drbd attach
         info("attaching primary drbds to new secondary (standalone => connected)")

                       nodes, result)
         return result
       @locking.ssynchronized(_config_lock)
       def ReleaseDRBDMinors(self, instance):
       def _UnlockedReleaseDRBDMinors(self, instance):
         """Release temporary drbd minors allocated for a given instance.
         This should be called on both the error paths and on the success
         paths (after the instance has been added or updated).
         @type instance: string
         @param instance: the instance for which temporary minors should be
                          released
-...
           if name == instance:
             del self._temporary_drbds[key]
       @locking.ssynchronized(_config_lock)
       def ReleaseDRBDMinors(self, instance):
         """Release temporary drbd minors allocated for a given instance.
         This should be called on the error paths, on the success paths
         it's automatically called by the ConfigWriter add and update
         functions.
         This function is just a wrapper over L{_UnlockedReleaseDRBDMinors}.
         @type instance: string
         @param instance: the instance for which temporary minors should be
                          released
         """
         self._UnlockedReleaseDRBDMinors(instance)
       @locking.ssynchronized(_config_lock, shared=1)
       def GetConfigVersion(self):
         """Get the configuration version.
-...
         instance.serial_no = 1
         self._config_data.instances[instance.name] = instance
         self._UnlockedReleaseDRBDMinors(instance.name)
         self._WriteConfig()
       def _SetInstanceStatus(self, instance_name, status):
-...
           # for node updates, we need to increase the cluster serial too
           self._config_data.cluster.serial_no += 1
         if isinstance(target, objects.Instance):
           self._UnlockedReleaseDRBDMinors(target.name)
         self._WriteConfig()

Also available in: Unified diff

Synnefo » snf-ganeti

Revision 61cf6b5e