From 90a7547a05f74a17356a0dd38fd1b74919040db3 Mon Sep 17 00:00:00 2001 From: Guido Trotter <ultrotter@google.com> Date: Mon, 24 Nov 2008 09:45:11 +0000 Subject: [PATCH] Parallelize instance operations on the same node With static minors we don't have a race condition anymore when starting/stopping/rebooting/reinstalling more than one instance on the same node, so we'll drop node locking altogether. Reviewed-by: iustinp --- lib/cmdlib.py | 25 ------------------------- 1 file changed, 25 deletions(-) diff --git a/lib/cmdlib.py b/lib/cmdlib.py index 81d8d7e73..899a3e1d7 100644 --- a/lib/cmdlib.py +++ b/lib/cmdlib.py @@ -2264,12 +2264,6 @@ class LUStartupInstance(LogicalUnit): def ExpandNames(self): self._ExpandAndLockInstance() - self.needed_locks[locking.LEVEL_NODE] = [] - self.recalculate_locks[locking.LEVEL_NODE] = constants.LOCKS_REPLACE - - def DeclareLocks(self, level): - if level == locking.LEVEL_NODE: - self._LockInstancesNodes() def BuildHooksEnv(self): """Build hooks env. @@ -2340,13 +2334,6 @@ class LURebootInstance(LogicalUnit): constants.INSTANCE_REBOOT_HARD, constants.INSTANCE_REBOOT_FULL)) self._ExpandAndLockInstance() - self.needed_locks[locking.LEVEL_NODE] = [] - self.recalculate_locks[locking.LEVEL_NODE] = constants.LOCKS_REPLACE - - def DeclareLocks(self, level): - if level == locking.LEVEL_NODE: - primary_only = not constants.INSTANCE_REBOOT_FULL - self._LockInstancesNodes(primary_only=primary_only) def BuildHooksEnv(self): """Build hooks env. @@ -2414,12 +2401,6 @@ class LUShutdownInstance(LogicalUnit): def ExpandNames(self): self._ExpandAndLockInstance() - self.needed_locks[locking.LEVEL_NODE] = [] - self.recalculate_locks[locking.LEVEL_NODE] = constants.LOCKS_REPLACE - - def DeclareLocks(self, level): - if level == locking.LEVEL_NODE: - self._LockInstancesNodes() def BuildHooksEnv(self): """Build hooks env. @@ -2466,12 +2447,6 @@ class LUReinstallInstance(LogicalUnit): def ExpandNames(self): self._ExpandAndLockInstance() - self.needed_locks[locking.LEVEL_NODE] = [] - self.recalculate_locks[locking.LEVEL_NODE] = constants.LOCKS_REPLACE - - def DeclareLocks(self, level): - if level == locking.LEVEL_NODE: - self._LockInstancesNodes() def BuildHooksEnv(self): """Build hooks env. -- GitLab