Rooba
/
mitogen
mirror of https://github.com/mitogen-hq/mitogen.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix stale references to m.master.connect & m.ssh.connect 

I'm fairly sure these updates are correct, but I'm not able to run the
test suite to confirm.
This commit is contained in:
Alex Willmer 2017-09-21 20:03:51 +01:00
parent a8d216eeab
commit 81fe37b108
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
mitogen/ansible/connection.py
View File

@ -39,11 +39,13 @@ class Connection(ansible.plugins.connection.ConnectionBase):
if self.connected: if self.connected:
return return
self.broker = mitogen.master.Broker() self.broker = mitogen.master.Broker()
self.router = mitogen.master.Router(self.broker)
if self._play_context.remote_addr == 'localhost': if self._play_context.remote_addr == 'localhost':
self.context = mitogen.master.connect(self.broker) self.context = self.router.connect(mitogen.master.Stream)
else: else:
self.context = mitogen.ssh.connect(broker, self.context = self.router.connect(mitogen.ssh.Stream,
self._play_context.remote_addr) hostname=self._play_context.remote_addr,
)
def exec_command(self, cmd, in_data=None, sudoable=True): def exec_command(self, cmd, in_data=None, sudoable=True):
super(Connection, self).exec_command(cmd, in_data=in_data, sudoable=sudoable) super(Connection, self).exec_command(cmd, in_data=in_data, sudoable=sudoable)