summaryrefslogtreecommitdiff
path: root/tests/fork_test.py
diff options
context:
space:
mode:
authorSergey Shepelev <temotor@gmail.com>2016-12-22 04:35:14 +0300
committerSergey Shepelev <temotor@gmail.com>2017-01-04 23:42:32 +0300
commite4049a8a0016b28cbbdf3ab01425fc92a623e380 (patch)
tree58d140b6e9f784e5b28a0435fb41ae8f238984af /tests/fork_test.py
parent461348f9a8459724be87c281eea4e0408138a82c (diff)
downloadeventlet-is-timeout.tar.gz
WIP https://github.com/eventlet/eventlet/pull/346is-timeout
Diffstat (limited to 'tests/fork_test.py')
-rw-r--r--tests/fork_test.py52
1 files changed, 0 insertions, 52 deletions
diff --git a/tests/fork_test.py b/tests/fork_test.py
deleted file mode 100644
index f15883f..0000000
--- a/tests/fork_test.py
+++ /dev/null
@@ -1,52 +0,0 @@
-from tests.patcher_test import ProcessBase
-
-
-class ForkTest(ProcessBase):
- def test_simple(self):
- newmod = '''
-import eventlet
-import os
-import sys
-import signal
-from eventlet.support import bytes_to_str, six
-mydir = %r
-signal_file = os.path.join(mydir, "output.txt")
-pid = os.fork()
-if (pid != 0):
- eventlet.Timeout(10)
- try:
- port = None
- while True:
- try:
- contents = open(signal_file, "rb").read()
- port = int(contents.split()[0])
- break
- except (IOError, IndexError, ValueError, TypeError):
- eventlet.sleep(0.1)
- eventlet.connect(('127.0.0.1', port))
- while True:
- try:
- contents = open(signal_file, "rb").read()
- result = contents.split()[1]
- break
- except (IOError, IndexError):
- eventlet.sleep(0.1)
- print('result {0}'.format(bytes_to_str(result)))
- finally:
- os.kill(pid, signal.SIGTERM)
-else:
- try:
- s = eventlet.listen(('', 0))
- fd = open(signal_file, "wb")
- fd.write(six.b(str(s.getsockname()[1])))
- fd.write(b"\\n")
- fd.flush()
- s.accept()
- fd.write(b"done")
- fd.flush()
- finally:
- fd.close()
-'''
- self.write_to_tempfile("newmod", newmod % self.tempdir)
- output, lines = self.launch_subprocess('newmod.py')
- self.assertEqual(lines[0], "result done", output)