Skip to content

Commit

Permalink
move back to IPv6 because grpcio-tools is stupid
Browse files Browse the repository at this point in the history
  • Loading branch information
sorousherafat committed Feb 14, 2024
1 parent 4b9d914 commit ab4cc09
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion broker/broker.py
Original file line number Diff line number Diff line change
Expand Up @@ -134,7 +134,7 @@ def DropReplicaMessages(self, request, context):
server = grpc.server(ThreadPoolExecutor(max_workers=30))
broker = BrokerServer()
broker_pb2_grpc.add_BrokerServicer_to_server(broker, server)
server.add_insecure_port(f'0.0.0.0:{os.environ["BROKER_PORT"]}')
server.add_insecure_port(f'[::]:{os.environ["BROKER_PORT"]}')
server.start()
channel = grpc.insecure_channel(f'{os.environ["ZOOKEEPER_HOST"]}:{os.environ["ZOOKEEPER_PORT"]}')
stub = proto.zookeeper_pb2_grpc.ZookeeperStub(channel)
Expand Down
2 changes: 1 addition & 1 deletion zookeeper/zookeeper.py
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,6 @@ def Register(self, request, context):
manager = BrokerManager()
message_pb2_grpc.add_MessageQueueServicer_to_server(MessageQueue(manager), server)
zookeeper_pb2_grpc.add_ZookeeperServicer_to_server(Zookeeper(manager), server)
server.add_insecure_port(f"0.0.0.0:{os.getenv('ZOOKEEPER_PORT')}")
server.add_insecure_port(f"[::]:{os.getenv('ZOOKEEPER_PORT')}")
server.start()
server.wait_for_termination()

0 comments on commit ab4cc09

Please sign in to comment.