first_stage_test: Add more tests

 + test_stdin_non_blocking
 + test_stdin_blocking

Signed-off-by: Marc Hartmayer <[email protected]>

Author: mhartmay

tests/first_stage_test.py

@@ -1,9 +1,117 @@
+import fcntl
+import functools
+import operator
+
 import mitogen.core
 import mitogen.parent
 from mitogen.core import b
 
 import testlib
 
+def own_create_child(args, blocking, pipe_size=None, preexec_fn=None):
+    """
+    Create a child process whose stdin/stdout is connected to a pipe.
+
+    :param list args:
+        Program argument vector.
+    :param bool blocking:
+        If :data:`True`, the pipes use blocking IO, otherwise non-blocking.
+    :param function preexec_fn:
+        If not :data:`None`, a function to run within the post-fork child
+        before executing the target program.
+    :returns:
+        :class:`Process` instance.
+    """
+    parent_rfp, child_wfp = mitogen.core.pipe(blocking=blocking)
+    child_rfp, parent_wfp = mitogen.core.pipe(blocking=blocking)
+    if pipe_size is not None:
+        fcntl.fcntl(parent_rfp.fileno(), fcntl.F_SETPIPE_SZ, pipe_size)
+        fcntl.fcntl(child_rfp.fileno(), fcntl.F_SETPIPE_SZ, pipe_size)
+        assert fcntl.fcntl(parent_rfp.fileno(), fcntl.F_GETPIPE_SZ) == pipe_size
+        assert fcntl.fcntl(child_rfp.fileno(), fcntl.F_GETPIPE_SZ) == pipe_size
+
+    stderr_r, stderr = None, None
+    try:
+        proc = testlib.subprocess.Popen(
+            args=args,
+            stdin=child_rfp,
+            stdout=child_wfp,
+            stderr=stderr,
+            close_fds=True,
+            preexec_fn=preexec_fn,
+        )
+    except Exception:
+        child_rfp.close()
+        child_wfp.close()
+        parent_rfp.close()
+        parent_wfp.close()
+        raise
+
+    child_rfp.close()
+    child_wfp.close()
+    return mitogen.parent.PopenProcess(
+        proc=proc,
+        stdin=parent_wfp,
+        stdout=parent_rfp,
+        stderr=stderr_r,
+    )
+
+
+class DummyConnectionBlocking(mitogen.parent.Connection):
+    """Dummy blocking IO connection"""
+
+    pipe_size = 4096 if getattr(fcntl, 'F_SETPIPE_SZ', None) else None
+    create_child = staticmethod(functools.partial(own_create_child, blocking=True, pipe_size=pipe_size))
+    name_prefix = u'dummy_blocking'
+
+
+class DummyConnectionNonBlocking(mitogen.parent.Connection):
+    """Dummy non-blocking IO connection"""
+
+    pipe_size = 4096 if getattr(fcntl, 'F_SETPIPE_SZ', None) else None
+    create_child = staticmethod(functools.partial(own_create_child, blocking=False, pipe_size=pipe_size))
+    name_prefix = u'dummy_non_blocking'
+
+
+class ConnectionTest(testlib.RouterMixin, testlib.TestCase):
+    def test_stdin_non_blocking(self):
+        """Test that first stage works with non-blocking STDIN
+
+        The boot command should read the preamble from STDIN, write all ECO
+        markers to STDOUT, and then execute the preamble.
+
+        This test writes the complete preamble to non-blocking STDIN.
+
+        1. Fork child reads from non-blocking STDIN
+        2. Fork child writes all data as expected by the protocol.
+        3. A context call works as expected.
+
+        """
+        log = testlib.LogCapturer()
+        log.start()
+        ctx = self.router._connect(DummyConnectionNonBlocking, connect_timeout=0.5)
+        self.assertEqual(3, ctx.call(operator.add, 1, 2))
+        logs = log.stop()
+
+    def test_stdin_blocking(self):
+        """Test that first stage works with blocking STDIN
+
+        The boot command should read the preamble from STDIN, write all ECO
+        markers to STDOUT, and then execute the preamble.
+
+        This test writes the complete preamble to blocking STDIN.
+
+        1. Fork child reads from blocking STDIN
+        2. Fork child writes all data as expected by the protocol.
+        3. A context call works as expected.
+
+        """
+        log = testlib.LogCapturer()
+        log.start()
+        ctx = self.router._connect(DummyConnectionBlocking, connect_timeout=0.5)
+        self.assertEqual(3, ctx.call(operator.add, 1, 2))
+        logs = log.stop()
+
 
 class CommandLineTest(testlib.RouterMixin, testlib.TestCase):
     # Ensure this version of Python produces a command line that is sufficient