Revision c36176cc
b/daemons/ganeti-masterd | ||
---|---|---|
291 | 291 |
# Add it to the configuration |
292 | 292 |
self.cfg.AddNode(node) |
293 | 293 |
|
294 |
# If preseeding fails it'll not be added |
|
295 |
self.jobqueue.AddNode(node.name) |
|
296 |
|
|
294 | 297 |
# Add the new node to the Ganeti Lock Manager |
295 | 298 |
self.glm.add(locking.LEVEL_NODE, node.name) |
296 | 299 |
|
... | ... | |
298 | 301 |
"""Updates a node that's already in the configuration |
299 | 302 |
|
300 | 303 |
""" |
304 |
# Synchronize the queue again |
|
305 |
self.jobqueue.AddNode(node.name) |
|
301 | 306 |
|
302 | 307 |
def RemoveNode(self, name): |
303 | 308 |
"""Removes a node from the configuration and lock manager. |
... | ... | |
306 | 311 |
# Remove node from configuration |
307 | 312 |
self.cfg.RemoveNode(name) |
308 | 313 |
|
314 |
# Notify job queue |
|
315 |
self.jobqueue.RemoveNode(name) |
|
316 |
|
|
309 | 317 |
# Remove the node from the Ganeti Lock Manager |
310 | 318 |
self.glm.remove(locking.LEVEL_NODE, name) |
311 | 319 |
|
Also available in: Unified diff