force use fork mode to start multiprocess in tests

tests/test_all_protocols_binary_field.py

@@ -3,6 +3,7 @@
 import sys
 import time
 import traceback
+import multiprocessing
 from multiprocessing import Process
 
 import pytest
@@ -25,6 +26,7 @@
     make_client as make_rpc_client
 from thriftpy2.transport import TBufferedTransportFactory, TCyMemoryBuffer
 
+multiprocessing.set_start_method("fork", force=True)
 
 if sys.platform == "win32":
     pytest.skip("requires fork", allow_module_level=True)

tests/test_apache_json.py

@@ -4,6 +4,7 @@
 import json
 import sys
 import time
+import multiprocessing
 from multiprocessing import Process
 
 import pytest
@@ -19,6 +20,8 @@
 from thriftpy2.transport import TMemoryBuffer
 from thriftpy2.transport.buffered import TBufferedTransportFactory
 
+multiprocessing.set_start_method("fork", force=True)
+
 
 def recursive_vars(obj):
     if isinstance(obj, six.string_types):

tests/test_buffered_transport.py

@@ -19,6 +19,8 @@
 from thriftpy2._compat import CYTHON
 logging.basicConfig(level=logging.INFO)
 
+multiprocessing.set_start_method("fork", force=True)
+
 addressbook = thriftpy2.load(path.join(path.dirname(__file__),
                                        "addressbook.thrift"))
 

tests/test_http.py

@@ -18,6 +18,8 @@
 from thriftpy2.http import make_server, make_client, client_context, THttpHeaderFactory  # noqa
 from thriftpy2.thrift import TApplicationException  # noqa
 
+multiprocessing.set_start_method("fork", force=True)
+
 addressbook = thriftpy2.load(os.path.join(os.path.dirname(__file__),
                                           "addressbook.thrift"))
 

tests/test_multiplexed.py

@@ -20,6 +20,8 @@
 from thriftpy2.transport import TBufferedTransportFactory, TServerSocket
 
 
+multiprocessing.set_start_method("fork", force=True)
+
 if sys.platform == "win32":
     pytest.skip("requires fork", allow_module_level=True)
 

tests/test_oneway.py

@@ -8,6 +8,8 @@
 from thriftpy2.rpc import make_client, make_server
 
 
+multiprocessing.set_start_method("fork", force=True)
+
 if sys.platform == "win32":
     pytest.skip("requires fork", allow_module_level=True)
 

tests/test_protocol_cybinary.py

@@ -19,6 +19,8 @@
 else:
     pytest.skip("cython not enabled.", allow_module_level=True)
 
+multiprocessing.set_start_method("fork", force=True)
+
 
 class TItem(TPayload):
     thrift_spec = {

tests/test_rpc.py

@@ -19,6 +19,7 @@
 from thriftpy2.transport import TTransportException  # noqa
 from thriftpy2.thrift import TApplicationException  # noqa
 
+multiprocessing.set_start_method("fork", force=True)
 
 if sys.platform == "win32":
     pytest.skip("requires unix domain socket", allow_module_level=True)

tests/test_tracking.py

@@ -58,6 +58,7 @@
 else:
     cleanup_on_sigterm()
 
+multiprocessing.set_start_method("fork", force=True)
 
 if sys.platform == "win32":
     pytest.skip("requires fork", allow_module_level=True)