Did I find the right examples for you? yes no

All Samples(28)  |  Call(16)  |  Derive(0)  |  Import(12)

src/g/r/gruvi-0.9.2/gruvi/http.py   gruvi(Download)
from . import hub, protocols, error, reader, http_ffi, logging, compat
from .hub import switchpoint
from .util import objref, docfrom, getsockname
from ._version import __version__
 
    def __init__(self):
        self._log = logging.get_logger(objref(self))
 
    def flush(self):
        pass
        env['wsgi.version'] = (1, 0)
        errors = env['wsgi.errors'] = ErrorStream()
        transport._log.debug('logging to {}', objref(errors))
        env['wsgi.multithread'] = True
        env['wsgi.multiprocess'] = True

src/g/r/gruvi-HEAD/gruvi/http.py   gruvi(Download)
from . import hub, protocols, error, reader, http_ffi, logging, compat
from .hub import switchpoint
from .util import objref, docfrom, getsockname
from ._version import __version__
 
    def __init__(self):
        self._log = logging.get_logger(objref(self))
 
    def flush(self):
        pass
        env['wsgi.version'] = (1, 0)
        errors = env['wsgi.errors'] = ErrorStream()
        transport._log.debug('logging to {}', objref(errors))
        env['wsgi.multithread'] = True
        env['wsgi.multiprocess'] = True

src/g/r/gruvi-0.9.2/gruvi/logging.py   gruvi(Download)
    """
    if not isinstance(context, compat.string_types):
        from .util import objref
        context = objref(context)
    logger = logging.getLogger(name)
    def thread_info(self):
        from .util import objref
        tid = objref(threading.current_thread())
        current = fibers.current()
        if current.parent or hasattr(current, 'loop'):
            fid = objref(current)

src/g/r/gruvi-0.9.2/gruvi/protocols.py   gruvi(Download)
from .pyuv import pyuv_exc, TCP, Pipe
from .ssl import SSL
from .util import docfrom, objref
 
__all__ = ['errno', 'ProtocolError', 'Protocol']
        self._transport = transport
        self._transport.listen(self._on_new_connection)
        self._log.debug('transport is {}', objref(transport))
 
    def _on_new_connection(self, transport, error):
            self._close_transport(client, errno.SERVER_BUSY)
            return
        self._log.debug('new client on {}', objref(client))
        self._init_transport(client)
 
        transport = util.create_connection(address, ssl, local_address, **transport_args)
        self._transport = transport
        self._log.debug('transport is {}', objref(transport))
        self._init_transport(self._transport)
 

src/g/r/gruvi-HEAD/gruvi/logging.py   gruvi(Download)
    """
    if not isinstance(context, compat.string_types):
        from .util import objref
        context = objref(context)
    logger = logging.getLogger(name)
    def thread_info(self):
        from .util import objref
        tid = objref(threading.current_thread())
        current = fibers.current()
        if current.parent or hasattr(current, 'loop'):
            fid = objref(current)

src/g/r/gruvi-HEAD/gruvi/protocols.py   gruvi(Download)
from .pyuv import pyuv_exc, TCP, Pipe
from .ssl import SSL
from .util import docfrom, objref
 
__all__ = ['errno', 'ProtocolError', 'Protocol']
        transport.listen(self._on_new_connection)
        self._transport = transport
        self._log.debug('transport is {}', objref(transport))
 
    def _on_new_connection(self, transport, error):
            self._close_transport(client, errno.SERVER_BUSY)
            return
        self._log.debug('new client on {}', objref(client))
        self._init_transport(client)
 
        transport = util.create_connection(address, ssl, local_address, **transport_args)
        self._transport = transport
        self._log.debug('transport is {}', objref(transport))
        self._init_transport(self._transport)
 

src/g/r/gruvi-0.9.2/gruvi/stream.py   gruvi(Download)
from .hub import switchpoint
from .pyuv import pyuv_exc
from .util import docfrom, objref
from . import fibers, reader, protocols, error
 

src/g/r/gruvi-HEAD/gruvi/stream.py   gruvi(Download)
from .hub import switchpoint
from .pyuv import pyuv_exc
from .util import docfrom, objref
from . import fibers, reader, protocols, error
 

src/g/r/gruvi-0.9.2/gruvi/dbus.py   gruvi(Download)
from . import hub, error, txdbus, protocols, dbus_ffi, compat
from .hub import switchpoint
from .util import objref
from .protocols import errno, ProtocolError
 

src/g/r/gruvi-HEAD/gruvi/dbus.py   gruvi(Download)
from . import hub, error, txdbus, protocols, dbus_ffi, compat
from .hub import switchpoint
from .util import objref
from .protocols import errno, ProtocolError