Make invirt-lvm lvcreate-all use sqlalchemy correctly.
[invirt/packages/invirt-remote.git] / python / remote / bcast.py
1 from subprocess import PIPE, Popen
2 from invirt.config import structs as config
3 import yaml
4
5 def bcast(cmd, hosts = [h.hostname for h in config.hosts]):
6     """
7     Given a command and a list of hostnames or IPs, issue the command to all
8     the nodes and return a list of (host, output) pairs (the order should be
9     the same as the order of the hosts).
10     """
11     pipes = [(host,
12               Popen(['remctl', host, 'remote', 'web', cmd], stdout=PIPE, stderr=PIPE))
13              for host in hosts]
14     outputs = dict((s, p.communicate()) for (s, p) in pipes)
15     for (s, p) in pipes:
16         if p.returncode != 0:
17             if outputs[s][1].startswith('remctl: cannot connect to %s' % s):
18                 del outputs[s]
19             else:
20                 raise RuntimeError("remctl to host %s returned non-zero exit status %d; stderr:\n%s"
21                                    % (s, p.returncode, outputs[s][1]))
22     return [(s, yaml.load(o[0], yaml.CSafeLoader)) for (s, o) in outputs.iteritems()]