|
|
|
|
@ -327,7 +327,6 @@ def popen(**kwargs):
|
|
|
|
|
is invoked in the child.
|
|
|
|
|
"""
|
|
|
|
|
real_preexec_fn = kwargs.pop('preexec_fn', None)
|
|
|
|
|
|
|
|
|
|
def preexec_fn():
|
|
|
|
|
if _preexec_hook:
|
|
|
|
|
_preexec_hook()
|
|
|
|
|
@ -692,7 +691,6 @@ class PartialZlib(object):
|
|
|
|
|
A full compression costs ~6ms on a modern machine, this method costs ~35
|
|
|
|
|
usec.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def __init__(self, s):
|
|
|
|
|
self.s = s
|
|
|
|
|
if sys.version_info > (2, 5):
|
|
|
|
|
@ -842,7 +840,6 @@ class Argv(object):
|
|
|
|
|
"""
|
|
|
|
|
Wrapper to defer argv formatting when debug logging is disabled.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def __init__(self, argv):
|
|
|
|
|
self.argv = argv
|
|
|
|
|
|
|
|
|
|
@ -869,7 +866,6 @@ class CallSpec(object):
|
|
|
|
|
"""
|
|
|
|
|
Wrapper to defer call argument formatting when debug logging is disabled.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def __init__(self, func, args, kwargs):
|
|
|
|
|
self.func = func
|
|
|
|
|
self.args = args
|
|
|
|
|
@ -879,8 +875,8 @@ class CallSpec(object):
|
|
|
|
|
bits = [self.func.__module__]
|
|
|
|
|
if inspect.ismethod(self.func):
|
|
|
|
|
im_self = getattr(self.func, IM_SELF_ATTR)
|
|
|
|
|
bits.append(getattr(im_self, '__name__', None)
|
|
|
|
|
or getattr(type(im_self), '__name__', None))
|
|
|
|
|
bits.append(getattr(im_self, '__name__', None) or
|
|
|
|
|
getattr(type(im_self), '__name__', None))
|
|
|
|
|
bits.append(self.func.__name__)
|
|
|
|
|
return u'.'.join(bits)
|
|
|
|
|
|
|
|
|
|
@ -918,13 +914,13 @@ class PollPoller(mitogen.core.Poller):
|
|
|
|
|
|
|
|
|
|
# TODO: no proof we dont need writemask too
|
|
|
|
|
_readmask = (
|
|
|
|
|
getattr(select, 'POLLIN', 0)
|
|
|
|
|
| getattr(select, 'POLLHUP', 0)
|
|
|
|
|
getattr(select, 'POLLIN', 0) |
|
|
|
|
|
getattr(select, 'POLLHUP', 0)
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
def _update(self, fd):
|
|
|
|
|
mask = (((fd in self._rfds) and self._readmask)
|
|
|
|
|
| ((fd in self._wfds) and select.POLLOUT))
|
|
|
|
|
mask = (((fd in self._rfds) and self._readmask) |
|
|
|
|
|
((fd in self._wfds) and select.POLLOUT))
|
|
|
|
|
if mask:
|
|
|
|
|
self._pollobj.register(fd, mask)
|
|
|
|
|
else:
|
|
|
|
|
@ -1047,8 +1043,8 @@ class EpollPoller(mitogen.core.Poller):
|
|
|
|
|
|
|
|
|
|
def _control(self, fd):
|
|
|
|
|
mitogen.core._vv and IOLOG.debug('%r._control(%r)', self, fd)
|
|
|
|
|
mask = (((fd in self._rfds) and select.EPOLLIN)
|
|
|
|
|
| ((fd in self._wfds) and select.EPOLLOUT))
|
|
|
|
|
mask = (((fd in self._rfds) and select.EPOLLIN) |
|
|
|
|
|
((fd in self._wfds) and select.EPOLLOUT))
|
|
|
|
|
if mask:
|
|
|
|
|
if fd in self._registered_fds:
|
|
|
|
|
self._epoll.modify(fd, mask)
|
|
|
|
|
@ -1081,8 +1077,8 @@ class EpollPoller(mitogen.core.Poller):
|
|
|
|
|
self._wfds.pop(fd, None)
|
|
|
|
|
self._control(fd)
|
|
|
|
|
|
|
|
|
|
_inmask = (getattr(select, 'EPOLLIN', 0)
|
|
|
|
|
| getattr(select, 'EPOLLHUP', 0))
|
|
|
|
|
_inmask = (getattr(select, 'EPOLLIN', 0) |
|
|
|
|
|
getattr(select, 'EPOLLHUP', 0))
|
|
|
|
|
|
|
|
|
|
def _poll(self, timeout):
|
|
|
|
|
the_timeout = -1
|
|
|
|
|
@ -1253,7 +1249,6 @@ class LogProtocol(LineLoggingProtocolMixin, mitogen.core.DelimitedProtocol):
|
|
|
|
|
LogProtocol takes over this FD and creates log messages for anything
|
|
|
|
|
written to it.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def on_line_received(self, line):
|
|
|
|
|
"""
|
|
|
|
|
Read a line, decode it as UTF-8, and log it.
|
|
|
|
|
@ -1267,7 +1262,6 @@ class MitogenProtocol(mitogen.core.MitogenProtocol):
|
|
|
|
|
Extend core.MitogenProtocol to cause SHUTDOWN to be sent to the child
|
|
|
|
|
during graceful shutdown.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def on_shutdown(self, broker):
|
|
|
|
|
"""
|
|
|
|
|
Respond to the broker's request for the stream to shut down by sending
|
|
|
|
|
@ -1508,7 +1502,7 @@ class Connection(object):
|
|
|
|
|
|
|
|
|
|
def get_preamble(self):
|
|
|
|
|
suffix = (
|
|
|
|
|
'\nExternalContext(%r).main()\n' %
|
|
|
|
|
'\nExternalContext(%r).main()\n' %\
|
|
|
|
|
(self.get_econtext_config(),)
|
|
|
|
|
)
|
|
|
|
|
partial = get_core_source_partial()
|
|
|
|
|
@ -1615,13 +1609,13 @@ class Connection(object):
|
|
|
|
|
if self._reaper:
|
|
|
|
|
return
|
|
|
|
|
|
|
|
|
|
# kill: # Avoid killing so child has chance to write cProfile data
|
|
|
|
|
self._reaper = Reaper(
|
|
|
|
|
broker=self._router.broker,
|
|
|
|
|
proc=self.proc,
|
|
|
|
|
kill=not (
|
|
|
|
|
(self.detached and self.child_is_immediate_subprocess)
|
|
|
|
|
or self._router.profiling
|
|
|
|
|
(self.detached and self.child_is_immediate_subprocess) or
|
|
|
|
|
# kill: # Avoid killing so child has chance to write cProfile data
|
|
|
|
|
self._router.profiling
|
|
|
|
|
),
|
|
|
|
|
# Don't delay shutdown waiting for a detached child, since the
|
|
|
|
|
# detached child may expect to live indefinitely after its parent
|
|
|
|
|
@ -1717,7 +1711,6 @@ class ChildIdAllocator(object):
|
|
|
|
|
Allocate new context IDs from a block of unique context IDs allocated by
|
|
|
|
|
the master process.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def __init__(self, router):
|
|
|
|
|
self.router = router
|
|
|
|
|
self.lock = threading.Lock()
|
|
|
|
|
@ -1816,7 +1809,6 @@ class CallChain(object):
|
|
|
|
|
|
|
|
|
|
# chain.reset() automatically invoked.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def __init__(self, context, pipelined=False):
|
|
|
|
|
self.context = context
|
|
|
|
|
if pipelined:
|
|
|
|
|
@ -2004,9 +1996,9 @@ class Context(mitogen.core.Context):
|
|
|
|
|
|
|
|
|
|
def __eq__(self, other):
|
|
|
|
|
return (
|
|
|
|
|
isinstance(other, mitogen.core.Context)
|
|
|
|
|
and (other.context_id == self.context_id)
|
|
|
|
|
and (other.router == self.router)
|
|
|
|
|
isinstance(other, mitogen.core.Context) and
|
|
|
|
|
(other.context_id == self.context_id) and
|
|
|
|
|
(other.router == self.router)
|
|
|
|
|
)
|
|
|
|
|
|
|
|
|
|
def __hash__(self):
|
|
|
|
|
@ -2091,7 +2083,6 @@ class RouteMonitor(object):
|
|
|
|
|
:data:`None` in the master process, or reference to the parent context
|
|
|
|
|
we should propagate route updates towards.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def __init__(self, router, parent=None):
|
|
|
|
|
self.router = router
|
|
|
|
|
self.parent = parent
|
|
|
|
|
@ -2176,8 +2167,8 @@ class RouteMonitor(object):
|
|
|
|
|
"""
|
|
|
|
|
for stream in self.router.get_streams():
|
|
|
|
|
if target_id in stream.protocol.egress_ids and (
|
|
|
|
|
(self.parent is None)
|
|
|
|
|
or (self.parent.context_id != stream.protocol.remote_id)
|
|
|
|
|
(self.parent is None) or
|
|
|
|
|
(self.parent.context_id != stream.protocol.remote_id)
|
|
|
|
|
):
|
|
|
|
|
self._send_one(stream, mitogen.core.DEL_ROUTE, target_id, None)
|
|
|
|
|
|
|
|
|
|
@ -2348,7 +2339,6 @@ class Router(mitogen.core.Router):
|
|
|
|
|
|
|
|
|
|
l = mitogen.core.Latch()
|
|
|
|
|
mitogen.core.listen(stream, 'disconnect', l.put)
|
|
|
|
|
|
|
|
|
|
def disconnect():
|
|
|
|
|
LOG.debug('Starting disconnect of %r', stream)
|
|
|
|
|
stream.on_disconnect(self.broker)
|
|
|
|
|
@ -2679,7 +2669,6 @@ class PopenProcess(Process):
|
|
|
|
|
:param subprocess.Popen proc:
|
|
|
|
|
The subprocess.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def __init__(self, proc, stdin, stdout, stderr=None):
|
|
|
|
|
super(PopenProcess, self).__init__(proc.pid, stdin, stdout, stderr)
|
|
|
|
|
#: The subprocess.
|
|
|
|
|
@ -2695,7 +2684,6 @@ class ModuleForwarder(object):
|
|
|
|
|
forwarding the request to our parent context, or satisfying the request
|
|
|
|
|
from our local Importer cache.
|
|
|
|
|
"""
|
|
|
|
|
|
|
|
|
|
def __init__(self, router, parent_context, importer):
|
|
|
|
|
self.router = router
|
|
|
|
|
self.parent_context = parent_context
|
|
|
|
|
|
Steven Robertson
5 years ago