django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2025-07-14 18:02:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

allow assigning a port in DaphneProcess

Browse Source
This commit is contained in:
Mohammed 2025-02-20 17:25:59 +00:00
parent 630caed915
commit 8d87442ed1
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
daphne/testing.py
View File

@ -126,14 +126,14 @@ class DaphneProcess(multiprocessing.Process):
port it ends up listening on back to the parent 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__() super().__init__()
self.host = host self.host = host
self.get_application = get_application self.get_application = get_application
self.kwargs = kwargs or {} self.kwargs = kwargs or {}
self.setup = setup self.setup = setup
self.teardown = teardown 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.ready = multiprocessing.Event()
self.errors = multiprocessing.Queue() self.errors = multiprocessing.Queue()
@ -153,7 +153,7 @@ class DaphneProcess(multiprocessing.Process):
try: try:
# Create the server class # 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( self.server = Server(
application=application, application=application,
endpoints=endpoints, endpoints=endpoints,