@@ -64,6 +64,7 @@ def foo():
6464
6565 # Create a socket server to communicate with the target process
6666 server_socket = socket .socket (socket .AF_INET , socket .SOCK_STREAM )
67+ server_socket .setsockopt (socket .SOL_SOCKET , socket .SO_REUSEADDR , 1 )
6768 server_socket .bind (('localhost' , port ))
6869 server_socket .settimeout (SHORT_TIMEOUT )
6970 server_socket .listen (1 )
@@ -150,8 +151,8 @@ def new_eager_loop():
150151 ):
151152 script_dir = os .path .join (work_dir , "script_pkg" )
152153 os .mkdir (script_dir )
153-
8000
# Create a socket server to communicate with the target process
154154 server_socket = socket .socket (socket .AF_INET , socket .SOCK_STREAM )
155+ server_socket .setsockopt (socket .SOL_SOCKET , socket .SO_REUSEADDR , 1 )
155156 server_socket .bind (('localhost' , port ))
156157 server_socket .settimeout (SHORT_TIMEOUT )
157158 server_socket .listen (1 )
@@ -230,6 +231,7 @@ async def main():
230231 os .mkdir (script_dir )
231232 # Create a socket server to communicate with the target process
232233 server_socket = socket .socket (socket .AF_INET , socket .SOCK_STREAM )
234+ server_socket .setsockopt (socket .SOL_SOCKET , socket .SO_REUSEADDR , 1 )
233235 server_socket .bind (('localhost' , port ))
234236 server_socket .settimeout (SHORT_TIMEOUT )
235237 server_socket .listen (1 )
@@ -297,6 +299,7 @@ async def main():
297299 os .mkdir (script_dir )
298300 # Create a socket server to communicate with the target process
299301 server_socket = socket .socket (socket .AF_INET , socket .SOCK_STREAM )
302+ server_socket .setsockopt (socket .SOL_SOCKET , socket .SO_REUSEADDR , 1 )
300303 server_socket .bind (('localhost' , port ))
301304 server_socket .settimeout (SHORT_TIMEOUT )
302305 server_socket .listen (1 )
@@ -368,6 +371,7 @@ async def main():
368371 os .mkdir (script_dir )
369372 # Create a socket server to communicate with the target process
370373 server_socket = socket .socket (socket .AF_INET , socket .SOCK_STREAM )
374+ server_socket .setsockopt (socket .SOL_SOCKET , socket .SO_REUSEADDR , 1 )
371375 server_socket .bind (('localhost' , port ))
372376 server_socket .settimeout (SHORT_TIMEOUT )
373377 server_socket .listen (1 )
@@ -471,6 +475,7 @@ async def main():
471475 os .mkdir (script_dir )
472476 # Create a socket server to communicate with the target process
473477 server_socket = socket .socket (socket .AF_INET , socket .SOCK_STREAM )
478+ server_socket .setsockopt (socket .SOL_SOCKET , socket .SO_REUSEADDR , 1 )
474479 server_socket .bind (('localhost' , port ))
475480 server_socket .settimeout (SHORT_TIMEOUT )
476481 server_socket .listen (1 )
0 commit comments