From d33ef1866e649cd5ef53aac9b5cb4bf41c4b72e3 Mon Sep 17 00:00:00 2001
From: David Wilson <dw@botanicus.net>
Date: Sun, 10 Jun 2018 03:06:18 +0000
Subject: [PATCH] ansible: wrap socket calls in io_op()

Breaks under signal stress test.
---
 ansible_mitogen/process.py | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/ansible_mitogen/process.py b/ansible_mitogen/process.py
index c4f58310..d61de0a2 100644
--- a/ansible_mitogen/process.py
+++ b/ansible_mitogen/process.py
@@ -110,7 +110,7 @@ class MuxProcess(object):
         if cls.child_pid:
             cls.child_sock.close()
             cls.child_sock = None
-            cls.worker_sock.recv(1)
+            mitogen.core.io_op(cls.worker_sock.recv, 1)
         else:
             cls.worker_sock.close()
             cls.worker_sock = None
@@ -128,9 +128,9 @@ class MuxProcess(object):
         self._setup_services()
 
         # Let the parent know our listening socket is ready.
-        self.child_sock.send('1')
+        mitogen.core.io_op(self.child_sock.send, '1')
         # Block until the socket is closed, which happens on parent exit.
-        self.child_sock.recv(1)
+        mitogen.core.io_op(self.child_sock.recv, 1)
 
     def _setup_master(self):
         """