Commit cba33475 authored by David Wilson's avatar David Wilson

issue #155: move connection factories to parent.py.

parent 972f77c6
...@@ -669,21 +669,6 @@ class Router(mitogen.parent.Router): ...@@ -669,21 +669,6 @@ class Router(mitogen.parent.Router):
self.broker.shutdown() self.broker.shutdown()
self.broker.join() self.broker.join()
def docker(self, **kwargs):
return self.connect('docker', **kwargs)
def local(self, **kwargs):
return self.connect('local', **kwargs)
def fork(self, **kwargs):
return self.connect('fork', **kwargs)
def sudo(self, **kwargs):
return self.connect('sudo', **kwargs)
def ssh(self, **kwargs):
return self.connect('ssh', **kwargs)
def disconnect_stream(self, stream): def disconnect_stream(self, stream):
self.broker.defer(stream.on_disconnect, self.broker) self.broker.defer(stream.on_disconnect, self.broker)
......
...@@ -615,6 +615,8 @@ class RouteMonitor(object): ...@@ -615,6 +615,8 @@ class RouteMonitor(object):
class Router(mitogen.core.Router): class Router(mitogen.core.Router):
context_class = Context context_class = Context
debug = False
profiling = False
id_allocator = None id_allocator = None
responder = None responder = None
...@@ -710,6 +712,21 @@ class Router(mitogen.core.Router): ...@@ -710,6 +712,21 @@ class Router(mitogen.core.Router):
self._context_by_id[context.context_id] = context self._context_by_id[context.context_id] = context
return context return context
def docker(self, **kwargs):
return self.connect('docker', **kwargs)
def local(self, **kwargs):
return self.connect('local', **kwargs)
def fork(self, **kwargs):
return self.connect('fork', **kwargs)
def sudo(self, **kwargs):
return self.connect('sudo', **kwargs)
def ssh(self, **kwargs):
return self.connect('ssh', **kwargs)
class ProcessMonitor(object): class ProcessMonitor(object):
def __init__(self): def __init__(self):
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment