We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7e86c12 commit f7164e8Copy full SHA for f7164e8
nats-server/src/nats/server/__init__.py
@@ -386,10 +386,12 @@ async def run_cluster(
386
# Create socket pairs for each node to reserve both client and cluster ports
387
for _ in range(size):
388
client_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
389
+ client_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
390
client_sock.bind(("127.0.0.1", 0))
391
client_port = client_sock.getsockname()[1]
392
393
cluster_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
394
+ cluster_sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
395
cluster_sock.bind(("127.0.0.1", 0))
396
cluster_port = cluster_sock.getsockname()[1]
397
0 commit comments