Revision 7688d0d3 scripts/gnt-cluster
b/scripts/gnt-cluster | ||
---|---|---|
161 | 161 |
nodes - list containing the name of target nodes; if empty, all nodes |
162 | 162 |
|
163 | 163 |
""" |
164 |
# TODO: Query master |
|
165 |
cfg = ssconf.SimpleConfigReader() |
|
166 |
|
|
164 | 167 |
filename = args[0] |
165 | 168 |
if not os.path.exists(filename): |
166 | 169 |
raise errors.OpPrereqError("No such filename '%s'" % filename) |
... | ... | |
169 | 172 |
|
170 | 173 |
op = opcodes.OpQueryNodes(output_fields=["name"], names=opts.nodes) |
171 | 174 |
results = [row[0] for row in SubmitOpCode(op) if row[0] != myname] |
172 |
srun = ssh.SshRunner() |
|
175 |
srun = ssh.SshRunner(cfg)
|
|
173 | 176 |
for node in results: |
174 | 177 |
if not srun.CopyFileToNode(node, filename): |
175 | 178 |
print >> sys.stderr, ("Copy of file %s to node %s failed" % |
... | ... | |
188 | 191 |
nodes: list containing the name of target nodes; if empty, all nodes |
189 | 192 |
|
190 | 193 |
""" |
194 |
# TODO: Query master |
|
195 |
cfg = ssconf.SimpleConfigReader() |
|
196 |
|
|
191 | 197 |
command = " ".join(args) |
192 | 198 |
op = opcodes.OpQueryNodes(output_fields=["name"], names=opts.nodes) |
193 | 199 |
nodes = [row[0] for row in SubmitOpCode(op)] |
194 | 200 |
|
195 | 201 |
sstore = ssconf.SimpleStore() |
196 | 202 |
master_node = sstore.GetMasterNode() |
197 |
srun = ssh.SshRunner(sstore=sstore)
|
|
203 |
srun = ssh.SshRunner(cfg)
|
|
198 | 204 |
|
205 |
# Make sure master node is at list end |
|
199 | 206 |
if master_node in nodes: |
200 | 207 |
nodes.remove(master_node) |
201 | 208 |
nodes.append(master_node) |
Also available in: Unified diff