sx-remote-listvms: someone's uncommitted changes

[invirt/packages/invirt-remote.git] / files / usr / sbin / sipb-xen-remote-listvms

diff --git a/files/usr/sbin/sipb-xen-remote-listvms b/files/usr/sbin/sipb-xen-remote-listvms
index 8b47167..52f5da6 100755 (executable)
--- a/files/usr/sbin/sipb-xen-remote-listvms
+++ b/files/usr/sbin/sipb-xen-remote-listvms
@@ -1,114 +1,52 @@
-#!/usr/bin/env python2.5
+#!/usr/bin/python

 
 """
 Collates the results of listvms from multiple VM servers.  Part of the xvm
 suite.
 """
 
 
 """
 Collates the results of listvms from multiple VM servers.  Part of the xvm
 suite.
 """
 

-from itertools import chain
-from subprocess import CalledProcessError, PIPE, Popen
-from sys import argv, stdout
-from cPickle import dump, loads
+from subprocess import PIPE, Popen
+try:
+    from subprocess import CalledProcessError
+except ImportError:
+    # Python 2.4 doesn't implement CalledProcessError
+    class CalledProcessError(Exception):
+        """This exception is raised when a process run by check_call() returns
+        a non-zero exit status. The exit status will be stored in the
+        returncode attribute."""
+        def __init__(self, returncode, cmd):
+            self.returncode = returncode
+            self.cmd = cmd
+        def __str__(self):
+            return "Command '%s' returned non-zero exit status %d" % (self.cmd, self.returncode)
+import sys
+import yaml

 
 ###
 
 
 ###
 

-#import compiler
-#
-#class Unsafe_Source_Error(Exception):
-#    def __init__(self,error,descr = None,node = None):
-#        self.error = error
-#        self.descr = descr
-#        self.node = node
-#        self.lineno = getattr(node,"lineno",None)
-#        
-#    def __repr__(self):
-#        return "Line %d.  %s: %s" % (self.lineno, self.error, self.descr)
-#    __str__ = __repr__    
-#           
-#class SafeEval(object):
-#    
-#    def visit(self, node,**kw):
-#        cls = node.__class__
-#        meth = getattr(self,'visit'+cls.__name__,self.default)
-#        return meth(node, **kw)
-#            
-#    def default(self, node, **kw):
-#        for child in node.getChildNodes():
-#            return self.visit(child, **kw)
-#            
-#    visitExpression = default
-#    
-#    def visitConst(self, node, **kw):
-#        return node.value
-#
-#    def visitDict(self,node,**kw):
-#        return dict([(self.visit(k),self.visit(v)) for k,v in node.items])
-#        
-#    def visitTuple(self,node, **kw):
-#        return tuple(self.visit(i) for i in node.nodes)
-#        
-#    def visitList(self,node, **kw):
-#        return [self.visit(i) for i in node.nodes]
-#
-#class SafeEvalWithErrors(SafeEval):
-#
-#    def default(self, node, **kw):
-#        raise Unsafe_Source_Error("Unsupported source construct",
-#                                node.__class__,node)
-#            
-#    def visitName(self,node, **kw):
-#        if node.name == 'None': return None
-#        raise Unsafe_Source_Error("Strings must be quoted", 
-#                                 node.name, node)
-#                                 
-#    # Add more specific errors if desired
-#            
-#def safe_eval(source, fail_on_error = True):
-#    if source.strip() == '': return None
-#    walker = fail_on_error and SafeEvalWithErrors() or SafeEval()
-#    try:
-#        ast = compiler.parse(source,"eval")
-#    except SyntaxError, err:
-#        raise
-#    try:
-#        return walker.visit(ast)
-#    except Unsafe_Source_Error, err:
-#        raise
-
-###
-
-def run(cmd):
-  """
-  Run the given command (a list of program and argument strings) and return the
-  stdout as a string, raising a CalledProcessError if the program exited with a
-  non-zero status.
-  """
-  p = Popen(cmd, stdout=PIPE)
-  stdout = p.communicate()[0]
-  if p.returncode != 0: raise CalledProcessError(p.returncode, cmd)
-  return stdout
-

 def main(argv):
 def main(argv):

-  # Query each of the server for their VMs.
-  # run('kinit -k host/sipb-vm-58.mit.edu'.split())
-  # TODO get `servers` from a real list of all the VM hosts (instead of
-  # hardcoding the list here)
-  servers = [ 'black-mesa.mit.edu', 'sx-blade-2.mit.edu' ]
-  # XXX
-  results = [ loads(run(['remctl', server, 'remote', 'web', 'listvms', '--pickle']))
-              for server in servers ]
-  results = filter( lambda x: x is not None, results )
-
-  # Merge the results and print.
-  merged = {}
-  for result in results: merged.update(result)
-  if argv[1:] == ['--pickle']:
-    dump(merged, stdout)
-  else:
-    print merged
-    print '.'
+    # Query each of the server for their VMs.
+    # TODO get `servers` from a real list of all the VM hosts (instead of
+    # hardcoding the list here)
+    servers = ['black-mesa.mit.edu', 'sx-blade-2.mit.edu']
+    # XXX
+    pipes = [Popen(['remctl', server, 'remote', 'web', 'listvms'], stdout=PIPE)
+             for server in servers]
+    outputs = [p.communicate()[0] for p in pipes]
+    for p in pipes:
+        if p.returncode != 0:
+            raise CalledProcessError(p.returncode, 'remctl')
+    results = [yaml.load(o, yaml.CSafeLoader) for o in outputs]
+    results = filter(lambda x: x is not None, results)
+
+    # Merge the results and print.
+    merged = {}
+    for result in results:
+        merged.update(result)
+
+    print yaml.dump(merged, Dumper=yaml.CSafeDumper, default_flow_style=False)

 
 if __name__ == '__main__':
 
 if __name__ == '__main__':

-  main(argv)
+    main(sys.argv)

 
 

-# vim:et:sw=2:ts=2
+# vim:et:sw=2:ts=4