DEMO COMMIT ONLY

❯ PYTHONPATH=$(pwd)/tests:$PYTHONPATH python -m unittest -v tests.first_stage_test.ConnectionTest.test_stdin_non_blocking
test_stdin_non_blocking (tests.first_stage_test.ConnectionTest.test_stdin_non_blocking)
Test that first stage works with non-blocking STDIN ... Traceback (most recent call last):
  File "<string>", line 1, in <module>
  File "<string>", line 22, in <module>
BlockingIOError: [Errno 11] Resource temporarily unavailable
ERROR

======================================================================
ERROR: test_stdin_non_blocking (tests.first_stage_test.ConnectionTest.test_stdin_non_blocking)
Test that first stage works with non-blocking STDIN
----------------------------------------------------------------------
Traceback (most recent call last):
  File "/home/mhartmay/storage/git/mitogen/tests/first_stage_test.py", line 96, in test_stdin_non_blocking
    ctx = self.router._connect(DummyConnectionNonBlocking, connect_timeout=0.5)
          ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
  File "/home/mhartmay/storage/git/mitogen/mitogen/parent.py", line 2444, in _connect
    conn.connect(context=context)
  File "/home/mhartmay/storage/git/mitogen/mitogen/parent.py", line 1726, in connect
    raise self.exception
mitogen.parent.EofError: EOF on stream; last 100 lines received:
MITO000

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

Author: mhartmay

mitogen/parent.py

@@ -1450,9 +1450,6 @@ def _first_stage():
         C=''.encode()
         V='V'
         while n>len(C) and V:
-            rl,_,_=select.select([0],[],[],t)
-            if not rl:
-                raise Exception("TimeoutError")
             V=os.read(0,n-len(C))
             C+=V
         C=zlib.decompress(C)