|
29 | 29 | import random
|
30 | 30 | import traceback
|
31 | 31 | from http.server import BaseHTTPRequestHandler, HTTPServer
|
| 32 | +from multiprocessing.context import ForkProcess |
32 | 33 | from unittest import TestCase
|
33 | 34 | from unittest.mock import patch, MagicMock
|
34 | 35 | from threading import Thread, Event
|
35 |
| -from multiprocessing import Process |
36 | 36 | from decimal import Decimal
|
37 | 37 | import datetime as dt
|
38 | 38 | import urllib3.exceptions
|
@@ -396,7 +396,7 @@ class KeepAliveClientTest(TestCase):
|
396 | 396 |
|
397 | 397 | def __init__(self, *args, **kwargs):
|
398 | 398 | super(KeepAliveClientTest, self).__init__(*args, **kwargs)
|
399 |
| - self.server_process = Process(target=self._run_server) |
| 399 | + self.server_process = ForkProcess(target=self._run_server) |
400 | 400 |
|
401 | 401 | def setUp(self):
|
402 | 402 | super(KeepAliveClientTest, self).setUp()
|
@@ -529,8 +529,8 @@ def __init__(self, *args, **kwargs):
|
529 | 529 | super().__init__(*args, **kwargs)
|
530 | 530 | self.assertIsNotNone(self.request_handler)
|
531 | 531 | self.server_address = ('127.0.0.1', random.randint(65000, 65535))
|
532 |
| - self.server_process = Process(target=TestingHTTPServer.run_server, |
533 |
| - args=(self.server_address, self.request_handler)) |
| 532 | + self.server_process = ForkProcess(target=TestingHTTPServer.run_server, |
| 533 | + args=(self.server_address, self.request_handler)) |
534 | 534 |
|
535 | 535 | def setUp(self):
|
536 | 536 | self.server_process.start()
|
|
0 commit comments