/ - Diff - ./kamaki - Greek Research and Technology Network's projects

         PooledHTTPConnection
     except ImportError:
         stderr.write("`objpool` package is required to build kamaki docs.\n")
         raise
         # raise
     path.insert(0, os.path.join(os.path.abspath(os.path.dirname(__file__)), '..'))

             if parser.arguments['version'].value:
                 exit(0)
             log_file = parser.arguments['config'].get('global', 'log_file')
             if log_file:
                 from kamaki.logger import set_log_filename
                 set_log_filename(log_file)
             _init_session(parser.arguments)
             from kamaki.cli.utils import suggest_missing

     # interpreted as representing official policies, either expressed
     # or implied, of GRNET S.A.command
     import logging
     from kamaki import logger
     sendlog = logging.getLogger('clients.send')
     recvlog = logging.getLogger('clients.recv')
     logger.add_file_logger('cli', __name__, filename=logger.get_log_filename())
     sendlog = logger.get_logger('cli')
     class _command_init(object):
-...
             except KeyError:
                 pass
         def _update_low_level_log(self):
         def _set_log_params(self):
             try:
                 self.client.LOG_TOKEN, self.client.LOG_DATA = (
                     self['config'].get('global', 'log_token') == 'on',

             base_url = self.config.get('astakos', 'url')\
                 or self.config.get('global', 'url')
             self.client = AstakosClient(base_url=base_url, token=token)
             self._update_low_level_log()
             self._set_log_params()
             self._update_max_threads()
         def main(self):

             base_url = self.config.get(service, 'url')\
                 or self.config.get('global', 'url')
             self.client = CycladesClient(base_url=base_url, token=token)
             self._update_low_level_log()
             self._set_log_params()
             self._update_max_threads()
         def main(self):

                 or self.config.get('compute', 'url')\
                 or self.config.get('global', 'url')
             self.client = ImageClient(base_url=base_url, token=token)
             self._update_low_level_log()
             self._set_log_params()
             self._update_max_threads()
         def main(self):

                 token=self.token,
                 account=self.account,
                 container=self.container)
             self._update_low_level_log()
             self._set_log_params()
             self._update_max_threads()
         def main(self):

     from objpool.http import PooledHTTPConnection
     from kamaki.clients.utils import logger
     from kamaki import logger
     DEBUG_LOG = logger.get_log_filename()
     LOG_FILE = logger.get_log_filename()
     TIMEOUT = 60.0   # seconds
     HTTP_METHODS = ['GET', 'POST', 'PUT', 'HEAD', 'DELETE', 'COPY', 'MOVE']
     logger.add_file_logger('clients.send', __name__, filename=DEBUG_LOG)
     logger.add_file_logger('clients.send', __name__, filename=LOG_FILE)
     sendlog = logger.get_logger('clients.send')
     sendlog.debug('Logging location: %s' % DEBUG_LOG)
     sendlog.debug('Logging location: %s' % LOG_FILE)
     logger.add_file_logger('data.send', __name__, filename=DEBUG_LOG)
     logger.add_file_logger('data.send', __name__, filename=LOG_FILE)
     datasendlog = logger.get_logger('data.send')
     logger.add_file_logger('clients.recv', __name__, filename=DEBUG_LOG)
     logger.add_file_logger('clients.recv', __name__, filename=LOG_FILE)
     recvlog = logger.get_logger('clients.recv')
     logger.add_file_logger('data.recv', __name__, filename=DEBUG_LOG)
     logger.add_file_logger('data.recv', __name__, filename=LOG_FILE)
     datarecvlog = logger.get_logger('data.recv')
     logger.add_file_logger('ClientError', __name__, filename=DEBUG_LOG)
     logger.add_file_logger('ClientError', __name__, filename=LOG_FILE)
     clienterrorlog = logger.get_logger('ClientError')
-...
                 headers=self.headers,
                 body=self.data)
             self.log()
             keep_trying = 60.0
             keep_trying = TIMEOUT
             while keep_trying > 0:
                 try:
                     return conn.getresponse()

     # Copyright 2013 GRNET S.A. All rights reserved.
+    #
     # Redistribution and use in source and binary forms, with or
     # without modification, are permitted provided that the following
     # conditions are met:
+    #
     #   1. Redistributions of source code must retain the above
     #      copyright notice, this list of conditions and the following
     #      disclaimer.
+    #
     #   2. Redistributions in binary form must reproduce the above
     #      copyright notice, this list of conditions and the following
     #      disclaimer in the documentation and/or other materials
     #      provided with the distribution.
+    #
     # THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
     # OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
     # WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     # PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
     # CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
     # SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
     # LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
     # USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
     # AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
     # ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     # POSSIBILITY OF SUCH DAMAGE.
+    #
     # The views and conclusions contained in the software and
     # documentation are those of the authors and should not be
     # interpreted as representing official policies, either expressed
     # or implied, of GRNET S.A.
     import logging
     def get_log_filename(filename=(
             '/var/log/kamaki.log',
             '/var/log/kamaki/clients.log',
             '/tmp/kamaki.log',
             'kamaki.log')):
         if not (isinstance(filename, list) or isinstance(filename, tuple)):
             filename = (filename,)
         for logfile in filename:
             try:
                 with open(logfile) as f:
                     f.seek(0)
             except IOError:
                 continue
             return logfile
         print('Failed to open any logging locations, file-logging aborted')
     def add_file_logger(
             name, caller,
             level=logging.DEBUG, prefix='', filename='/tmp/kamaki.log'):
         try:
             assert caller and filename
             logger = logging.getLogger(name)
             h = logging.FileHandler(filename)
             fmt = logging.Formatter(
                 '%(asctime)s ' + caller + ' %(name)s-%(levelname)s: %(message)s')
             h.setFormatter(fmt)
             logger.addHandler(h)
             logger.setLevel(level)
         except Exception:
             pass
     def get_logger(name):
         return logging.getLogger(name)

     # Copyright 2013 GRNET S.A. All rights reserved.
+    #
     # Redistribution and use in source and binary forms, with or
     # without modification, are permitted provided that the following
     # conditions are met:
+    #
     #   1. Redistributions of source code must retain the above
     #      copyright notice, this list of conditions and the following
     #      disclaimer.
+    #
     #   2. Redistributions in binary form must reproduce the above
     #      copyright notice, this list of conditions and the following
     #      disclaimer in the documentation and/or other materials
     #      provided with the distribution.
+    #
     # THIS SOFTWARE IS PROVIDED BY GRNET S.A. ``AS IS'' AND ANY EXPRESS
     # OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
     # WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
     # PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL GRNET S.A OR
     # CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
     # SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
     # LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF
     # USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED
     # AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
     # LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN
     # ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
     # POSSIBILITY OF SUCH DAMAGE.
+    #
     # The views and conclusions contained in the software and
     # documentation are those of the authors and should not be
     # interpreted as representing official policies, either expressed
     # or implied, of GRNET S.A.
     import logging
     LOG_FILE = [
         '/var/log/kamaki.log',
         '/var/log/kamaki/clients.log',
         '/tmp/kamaki.log',
         'kamaki.log']
     def get_log_filename():
         for logfile in LOG_FILE:
             try:
                 with open(logfile, 'w+') as f:
                     f.seek(0)
             except IOError:
                 continue
             return logfile
         print('Failed to open any logging locations, file-logging aborted')
     def set_log_filename(filename):
         global LOG_FILE
         LOG_FILE = [filename] + LOG_FILE
     def add_file_logger(
             name, caller,
             level=logging.DEBUG, prefix='', filename='/tmp/kamaki.log'):
         try:
             assert caller and filename
             logger = logging.getLogger(name)
             h = logging.FileHandler(filename)
             fmt = logging.Formatter(
                 '%(asctime)s ' + caller + ' %(name)s-%(levelname)s: %(message)s')
             h.setFormatter(fmt)
             logger.addHandler(h)
             logger.setLevel(level)
         except Exception:
             pass
     def get_logger(name):
         return logging.getLogger(name)

Synnefo » ./kamaki

Revision f47417e7