|
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