We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 1843f18 commit f45d8eaCopy full SHA for f45d8ea
mitogen/unix.py
@@ -148,9 +148,7 @@ def on_accept_client(self, sock):
148
stream.name = u'unix_client.%d' % (pid,)
149
stream.protocol.auth_id = mitogen.context_id
150
stream.protocol.is_privileged = True
151
- side = mitogen.core.Side(stream, sock)
152
- stream.receive_side = side
153
- stream.transmit_side = side
+ stream.accept(sock, sock)
154
LOG.debug('%r: accepted %r', self, stream)
155
self._router.register(context, stream)
156
@@ -167,9 +165,7 @@ def _connect(path, broker, sock):
167
165
168
166
router = mitogen.master.Router(broker=broker)
169
stream = mitogen.core.MitogenProtocol.build_stream(router, remote_id)
170
171
172
173
stream.name = u'unix_listener.%d' % (pid,)
174
175
mitogen.core.listen(stream, 'disconnect', _cleanup)
0 commit comments