/ - Diff - snf-ganeti - Greek Research and Technology Network's projects

Revision 2609da63

       return result.stdout.splitlines()
     def _ParseXmList(lines, include_node):
       """Parses the output of C{xm list}.
     def _ParseInstanceList(lines, include_node):
       """Parses the output of listing instances by xen.
       @type lines: list
       @param lines: Output lines of C{xm list}
       @param lines: Result of retrieving the instance list from xen
       @type include_node: boolean
       @param include_node: If True, return information for Dom0
       @return: list of tuple containing (name, id, memory, vcpus, state, time
-...
         # Domain-0   0  3418     4 r-----    266.2
         data = line.split()
         if len(data) != 6:
           raise errors.HypervisorError("Can't parse output of xm list,"
           raise errors.HypervisorError("Can't parse instance list,"
                                        " line: %s" % line)
         try:
           data[1] = int(data[1])
-...
           data[3] = int(data[3])
           data[5] = float(data[5])
         except (TypeError, ValueError), err:
           raise errors.HypervisorError("Can't parse output of xm list,"
           raise errors.HypervisorError("Can't parse instance list,"
                                        " line: %s, error: %s" % (line, err))
         # skip the Domain-0 (optional)
-...
     def _GetInstanceList(fn, include_node, _timeout=5):
       """Return the list of running instances.
       See L{_RunInstanceList} and L{_ParseXmList} for parameter details.
       See L{_RunInstanceList} and L{_ParseInstanceList} for parameter details.
       """
       instance_list_errors = []
-...
         raise errors.HypervisorError(errmsg)
       return _ParseXmList(lines, include_node)
       return _ParseInstanceList(lines, include_node)
     def _ParseNodeInfo(info):
-...
       @type info: dict
       @param info: Result from L{_ParseNodeInfo}
       @type fn: callable
       @param fn: Function returning result of running C{xm list}
       @param fn: Function retrieving the instance list
       @rtype: dict
       """
-...
         """
         result = self._RunXen(["info"])
         if result.failed:
           logging.error("Can't run 'xm info' (%s): %s", result.fail_reason,
                         result.output)
           logging.error("Can't retrieve xen hypervisor information (%s): %s",
                         result.fail_reason, result.output)
           return None
         return _GetNodeInfo(result.stdout, self._GetInstanceList)

         self.assertRaises(errors.ProgrammerError, hv._GetCommand, test_hvparams)
     class TestParseXmList(testutils.GanetiTestCase):
     class TestParseInstanceList(testutils.GanetiTestCase):
       def test(self):
         data = testutils.ReadTestData("xen-xm-list-4.0.1-dom0-only.txt")
         # Exclude node
         self.assertEqual(hv_xen._ParseXmList(data.splitlines(), False), [])
         self.assertEqual(hv_xen._ParseInstanceList(data.splitlines(), False), [])
         # Include node
         result = hv_xen._ParseXmList(data.splitlines(), True)
         result = hv_xen._ParseInstanceList(data.splitlines(), True)
         self.assertEqual(len(result), 1)
         self.assertEqual(len(result[0]), 6)
-...
         for lines in tests:
           try:
             hv_xen._ParseXmList(["Header would be here"] + lines, False)
             hv_xen._ParseInstanceList(["Header would be here"] + lines, False)
           except errors.HypervisorError, err:
             self.assertTrue("Can't parse output of xm list" in str(err))
             self.assertTrue("Can't parse instance list" in str(err))
           else:
             self.fail("Exception was not raised")

Also available in: Unified diff

Synnefo » snf-ganeti

Revision 2609da63