Revision 8e00939c
| b/lib/jqueue.py | ||
|---|---|---|
| 291 | 291 |
" check in jstore and here") |
| 292 | 292 |
|
| 293 | 293 |
# Get initial list of nodes |
| 294 |
self._nodes = self.context.cfg.GetNodeList() |
|
| 294 |
self._nodes = set(self.context.cfg.GetNodeList()) |
|
| 295 |
|
|
| 296 |
# Remove master node |
|
| 297 |
try: |
|
| 298 |
self._nodes.remove(self._my_hostname) |
|
| 299 |
except ValueError: |
|
| 300 |
pass |
|
| 295 | 301 |
|
| 296 | 302 |
# TODO: Check consistency across nodes |
| 297 | 303 |
|
| ... | ... | |
| 333 | 339 |
except ValueError: |
| 334 | 340 |
pass |
| 335 | 341 |
|
| 342 |
def _WriteAndReplicateFileUnlocked(self, file_name, data): |
|
| 343 |
"""Writes a file locally and then replicates it to all nodes. |
|
| 344 |
|
|
| 345 |
""" |
|
| 346 |
utils.WriteFile(file_name, data=data) |
|
| 347 |
|
|
| 336 | 348 |
failed_nodes = 0 |
| 337 |
result = rpc.call_upload_file(nodes, file_name) |
|
| 338 |
for node in nodes: |
|
| 349 |
result = rpc.call_upload_file(self._nodes, file_name)
|
|
| 350 |
for node in self._nodes:
|
|
| 339 | 351 |
if not result[node]: |
| 340 | 352 |
failed_nodes += 1 |
| 341 | 353 |
logging.error("Copy of job queue file to node %s failed", node)
|
Also available in: Unified diff