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

     from ganeti import http
     from ganeti import errors
     from ganeti import compat
     from ganeti import constants
     # Dummy value to detect unchanged parameters
-...
         """
         return bool(self._checkIntVariable("dry-run"))
       def GetClient(self):
       def GetClient(self, query=False):
         """Wrapper for L{luxi.Client} with HTTP-specific error handling.
         @param query: this signifies that the client will only be used for
             queries; if the build-time parameter enable-split-queries is
             enabled, then the client will be connected to the query socket
             instead of the masterd socket
         """
         if query and constants.ENABLE_SPLIT_QUERY:
           address = constants.QUERY_SOCKET
         else:
           address = None
         # Could be a function, pylint: disable=R0201
         try:
           return self._client_cls()
           return self._client_cls(address=address)
         except luxi.NoMasterError, err:
           raise http.HttpBadGateway("Can't connect to master daemon: %s" % err)
         except luxi.PermissionError:

         """
         return self._called
       def __call__(self):
       def __call__(self, address=None):
         """Creates an instrumented LUXI client.
         The LUXI client will record all method calls (use L{CalledNames} to
-...
         """
         return luxi.Client(transport=compat.partial(_TestLuxiTransport,
                                                     self.Record))
                                                     self.Record),
                            address=address)
     def _TestWrapper(fn, *args, **kwargs):

     #!/usr/bin/python
+    #
     # Copyright (C) 2010 Google Inc.
     # Copyright (C) 2010, 2012 Google Inc.
+    #
     # This program is free software; you can redistribute it and/or modify
     # it under the terms of the GNU General Public License as published by
-...
     class _FakeClient:
       def __init__(self):
       def __init__(self, address=None):
         self._jobs = []
       def GetNextSubmittedJob(self):
-...
       def GetNextClient(self):
         return self._clients.pop(0)
       def __call__(self):
         cl = self._client_cls()
       def __call__(self, address=None):
         cl = self._client_cls(address=address)
         self._clients.append(cl)
         return cl
-...
     class TestClientConnectError(unittest.TestCase):
       @staticmethod
       def _FailingClient():
       def _FailingClient(address=None):
         raise luxi.NoMasterError("test")
       def test(self):
-...
     class TestJobSubmitError(unittest.TestCase):
       class _SubmitErrorClient:
         def __init__(self, address=None):
           pass
         @staticmethod
         def SubmitJob(ops):
           raise errors.JobQueueFull("test")
-...
     class TestClusterInfo(unittest.TestCase):
       class _ClusterInfoClient:
         def __init__(self):
         def __init__(self, address=None):
           self.cluster_info = None
         def QueryClusterInfo(self):

Synnefo » snf-ganeti » ganeti-local