From 8d87442ed1a009439ccef9bfbfdb8e9b39252264 Mon Sep 17 00:00:00 2001 From: Mohammed Date: Thu, 20 Feb 2025 17:25:59 +0000 Subject: [PATCH 1/2] allow assigning a port in DaphneProcess --- daphne/testing.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/daphne/testing.py b/daphne/testing.py index 46787bb..28b5f84 100644 --- a/daphne/testing.py +++ b/daphne/testing.py @@ -126,14 +126,14 @@ class DaphneProcess(multiprocessing.Process): port it ends up listening on back to the parent process. """ - def __init__(self, host, get_application, kwargs=None, setup=None, teardown=None): + def __init__(self, host, get_application, kwargs=None, setup=None, teardown=None, port=None): super().__init__() self.host = host self.get_application = get_application self.kwargs = kwargs or {} self.setup = setup self.teardown = teardown - self.port = multiprocessing.Value("i") + self.port = multiprocessing.Value("i", port if port is not None else 0) self.ready = multiprocessing.Event() self.errors = multiprocessing.Queue() @@ -153,7 +153,7 @@ class DaphneProcess(multiprocessing.Process): try: # Create the server class - endpoints = build_endpoint_description_strings(host=self.host, port=0) + endpoints = build_endpoint_description_strings(host=self.host, port=self.port.value) self.server = Server( application=application, endpoints=endpoints, From 29318b745425b6faf663c8dc7300668a1dd3aa6a Mon Sep 17 00:00:00 2001 From: "pre-commit-ci[bot]" <66853113+pre-commit-ci[bot]@users.noreply.github.com> Date: Thu, 20 Feb 2025 19:34:45 +0000 Subject: [PATCH 2/2] [pre-commit.ci] auto fixes from pre-commit.com hooks for more information, see https://pre-commit.ci --- daphne/testing.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/daphne/testing.py b/daphne/testing.py index 28b5f84..9120327 100644 --- a/daphne/testing.py +++ b/daphne/testing.py @@ -126,7 +126,9 @@ class DaphneProcess(multiprocessing.Process): port it ends up listening on back to the parent process. """ - def __init__(self, host, get_application, kwargs=None, setup=None, teardown=None, port=None): + def __init__( + self, host, get_application, kwargs=None, setup=None, teardown=None, port=None + ): super().__init__() self.host = host self.get_application = get_application @@ -153,7 +155,9 @@ class DaphneProcess(multiprocessing.Process): try: # Create the server class - endpoints = build_endpoint_description_strings(host=self.host, port=self.port.value) + endpoints = build_endpoint_description_strings( + host=self.host, port=self.port.value + ) self.server = Server( application=application, endpoints=endpoints,