Revision 3a24c527 scripts/gnt-instance
b/scripts/gnt-instance | ||
---|---|---|
29 | 29 |
from ganeti.cli import * |
30 | 30 |
from ganeti import cli |
31 | 31 |
from ganeti import opcodes |
32 |
from ganeti import logger |
|
33 | 32 |
from ganeti import constants |
34 | 33 |
from ganeti import utils |
35 | 34 |
from ganeti import errors |
... | ... | |
252 | 251 |
numfields=numfields, data=output) |
253 | 252 |
|
254 | 253 |
for line in data: |
255 |
logger.ToStdout(line)
|
|
254 |
ToStdout(line) |
|
256 | 255 |
|
257 | 256 |
return 0 |
258 | 257 |
|
... | ... | |
418 | 417 |
file_storage_dir=specs['file_storage_dir'], |
419 | 418 |
file_driver=specs['file_driver']) |
420 | 419 |
|
421 |
print '%s: %s' % (name, cli.SendJob([op]))
|
|
420 |
ToStdout("%s: %s", name, cli.SendJob([op]))
|
|
422 | 421 |
|
423 | 422 |
return 0 |
424 | 423 |
|
... | ... | |
438 | 437 |
result = SubmitOpCode(op) |
439 | 438 |
|
440 | 439 |
if not result: |
441 |
logger.ToStdout("Can't get the OS list")
|
|
440 |
ToStdout("Can't get the OS list") |
|
442 | 441 |
return 1 |
443 | 442 |
|
444 |
logger.ToStdout("Available OS templates:")
|
|
443 |
ToStdout("Available OS templates:") |
|
445 | 444 |
number = 0 |
446 | 445 |
choices = [] |
447 | 446 |
for entry in result: |
448 |
logger.ToStdout("%3s: %s" % (number, entry[0]))
|
|
447 |
ToStdout("%3s: %s", number, entry[0])
|
|
449 | 448 |
choices.append(("%s" % number, entry[0], entry[0])) |
450 | 449 |
number = number + 1 |
451 | 450 |
|
... | ... | |
454 | 453 |
choices) |
455 | 454 |
|
456 | 455 |
if selected == 'exit': |
457 |
logger.ToStdout("User aborted reinstall, exiting")
|
|
456 |
ToStdout("User aborted reinstall, exiting") |
|
458 | 457 |
return 1 |
459 | 458 |
|
460 | 459 |
os = selected |
... | ... | |
526 | 525 |
op = opcodes.OpActivateInstanceDisks(instance_name=instance_name) |
527 | 526 |
disks_info = SubmitOrSend(op, opts) |
528 | 527 |
for host, iname, nname in disks_info: |
529 |
print "%s:%s:%s" % (host, iname, nname)
|
|
528 |
ToStdout("%s:%s:%s", host, iname, nname)
|
|
530 | 529 |
return 0 |
531 | 530 |
|
532 | 531 |
|
... | ... | |
581 | 580 |
force=opts.force, |
582 | 581 |
extra_args=opts.extra_args) |
583 | 582 |
if multi_on: |
584 |
logger.ToStdout("Starting up %s" % name)
|
|
583 |
ToStdout("Starting up %s", name)
|
|
585 | 584 |
try: |
586 | 585 |
SubmitOrSend(op, opts) |
587 | 586 |
except JobSubmittedException, err: |
588 | 587 |
_, txt = FormatError(err) |
589 |
logger.ToStdout("%s" % txt)
|
|
588 |
ToStdout("%s", txt)
|
|
590 | 589 |
return 0 |
591 | 590 |
|
592 | 591 |
|
... | ... | |
636 | 635 |
for name in inames: |
637 | 636 |
op = opcodes.OpShutdownInstance(instance_name=name) |
638 | 637 |
if multi_on: |
639 |
logger.ToStdout("Shutting down %s" % name)
|
|
638 |
ToStdout("Shutting down %s", name)
|
|
640 | 639 |
try: |
641 | 640 |
SubmitOrSend(op, opts) |
642 | 641 |
except JobSubmittedException, err: |
643 | 642 |
_, txt = FormatError(err) |
644 |
logger.ToStdout("%s" % txt)
|
|
643 |
ToStdout("%s", txt)
|
|
645 | 644 |
return 0 |
646 | 645 |
|
647 | 646 |
|
... | ... | |
721 | 720 |
cmd = SubmitOpCode(op) |
722 | 721 |
|
723 | 722 |
if opts.show_command: |
724 |
print utils.ShellQuoteArgs(cmd)
|
|
723 |
ToStdout("%s", utils.ShellQuoteArgs(cmd))
|
|
725 | 724 |
else: |
726 | 725 |
try: |
727 | 726 |
os.execvp(cmd[0], cmd) |
728 | 727 |
finally: |
729 |
sys.stderr.write("Can't run console command %s with arguments:\n'%s'" %
|
|
730 |
(cmd, " ".join(argv)))
|
|
728 |
ToStderr("Can't run console command %s with arguments:\n'%s'",
|
|
729 |
cmd, " ".join(argv))
|
|
731 | 730 |
os._exit(1) |
732 | 731 |
|
733 | 732 |
|
... | ... | |
812 | 811 |
op = opcodes.OpQueryInstanceData(instances=args, static=opts.static) |
813 | 812 |
result = SubmitOpCode(op) |
814 | 813 |
if not result: |
815 |
logger.ToStdout("No instances.")
|
|
814 |
ToStdout("No instances.") |
|
816 | 815 |
return 1 |
817 | 816 |
|
818 | 817 |
buf = StringIO() |
... | ... | |
883 | 882 |
for device in instance["disks"]: |
884 | 883 |
_FormatBlockDevInfo(buf, device, 1, opts.static) |
885 | 884 |
|
886 |
logger.ToStdout(buf.getvalue().rstrip('\n'))
|
|
885 |
ToStdout(buf.getvalue().rstrip('\n')) |
|
887 | 886 |
return retcode |
888 | 887 |
|
889 | 888 |
|
... | ... | |
901 | 900 |
""" |
902 | 901 |
if not (opts.ip or opts.bridge or opts.mac or |
903 | 902 |
opts.hypervisor or opts.beparams): |
904 |
logger.ToStdout("Please give at least one of the parameters.")
|
|
903 |
ToStderr("Please give at least one of the parameters.")
|
|
905 | 904 |
return 1 |
906 | 905 |
|
907 | 906 |
if constants.BE_MEMORY in opts.beparams: |
... | ... | |
919 | 918 |
result = SubmitOrSend(op, opts) |
920 | 919 |
|
921 | 920 |
if result: |
922 |
logger.ToStdout("Modified instance %s" % args[0])
|
|
921 |
ToStdout("Modified instance %s", args[0])
|
|
923 | 922 |
for param, data in result: |
924 |
logger.ToStdout(" - %-5s -> %s" % (param, data))
|
|
925 |
logger.ToStdout("Please don't forget that these parameters take effect"
|
|
926 |
" only at the next start of the instance.")
|
|
923 |
ToStdout(" - %-5s -> %s", param, data)
|
|
924 |
ToStdout("Please don't forget that these parameters take effect" |
|
925 |
" only at the next start of the instance.") |
|
927 | 926 |
return 0 |
928 | 927 |
|
929 | 928 |
|
Also available in: Unified diff