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

     """
     # pylint: disable-msg=E1103
     # E1103: %s %r has no %r member (but some types could not be
     # inferred), because the _TryOSFromDisk returns either (True, os_obj)
     # or (False, "string") which confuses pylint
     import os
     import os.path

     """
     # pylint: disable-msg=E0203
     # E0203: Access to member %r before its definition, since we use
     # objects.py which doesn't explicitely initialise its members
     import socket
     import time
     import random
-...
         if not filter_upcall:
           self._callback(up)

     """
     # pylint: disable-msg=E1103
     # # E1103: %s %r has no %r member (but some types could not be
     # inferred), since _socketobject could be ssl or not and pylint
     # doesn't parse that
     import os
     import select
     import socket

         self.queue = queue
     class JobQueue(object):
       """Queue used to manage the jobs.
     def _RequireOpenQueue(fn):
       """Decorator for "public" functions.
       @cvar _RE_JOB_FILE: regex matching the valid job file names
       This function should be used for all 'public' functions. That is,
       functions usually called from other classes. Note that this should
       be applied only to methods (not plain functions), since it expects
       that the decorated function is called with a first argument that has
       a '_queue_lock' argument.
       """
       _RE_JOB_FILE = re.compile(r"^job-(%s)$" % constants.JOB_ID_TEMPLATE)
       @warning: Use this decorator only after utils.LockedMethod!
       def _RequireOpenQueue(fn):
         """Decorator for "public" functions.
       Example::
         @utils.LockedMethod
         @_RequireOpenQueue
         def Example(self):
           pass
         This function should be used for all 'public' functions. That is,
         functions usually called from other classes.
       """
       def wrapper(self, *args, **kwargs):
         assert self._queue_lock is not None, "Queue should be open"
         return fn(self, *args, **kwargs)
       return wrapper
         @warning: Use this decorator only after utils.LockedMethod!
         Example::
           @utils.LockedMethod
           @_RequireOpenQueue
           def Example(self):
             pass
     class JobQueue(object):
       """Queue used to manage the jobs.
         """
         def wrapper(self, *args, **kwargs):
           assert self._queue_lock is not None, "Queue should be open"
           return fn(self, *args, **kwargs)
         return wrapper
       @cvar _RE_JOB_FILE: regex matching the valid job file names
       """
       _RE_JOB_FILE = re.compile(r"^job-(%s)$" % constants.JOB_ID_TEMPLATE)
       def __init__(self, context):
         """Constructor for JobQueue.

     """
     # pylint: disable-msg=E0203
     # E0203: Access to member %r before its definition, since we use
     # objects.py which doesn't explicitely initialise its members
     import ConfigParser
     import re

b/lib/storage.py
328	328	"""LVM Physical Volume storage unit.
329	329
330	330	"""
	331	@staticmethod
331	332	def _GetAllocatable(attr):
332	333	if attr:
333	334	return (attr[0] == "a")

         @type field: str
         @param field: the string to match
         @return: either False or a regular expression match object
         @return: either None or a regular expression match object
         """
         for m in itertools.ifilter(None, (val.match(field) for val in self.items)):
           return m
         return False
         return None
       def NonMatching(self, items):
         """Returns the list of fields not matching the current set

Synnefo » snf-ganeti » ganeti-local

Revision 6c881c52