Skip to content

base_server

BaseServer

Bases: base_pb2_grpc.BaseServicer, ABC

Provides methods that implement functionality of base server.

start_server(addr, servicer)

Start server at the address.

Source code in iflearner/communication/base/base_server.py 
40
41
42
43
44
45
46
47
48
49
50
51
52
53
def start_server(addr: str, servicer: BaseServer) -> None:
    """Start server at the address."""
    server = grpc.server(
        futures.ThreadPoolExecutor(max_workers=10),
        options=[
            ("grpc.max_message_length", constant.MAX_MSG_LENGTH),
            ("grpc.max_send_message_length", constant.MAX_MSG_LENGTH),
            ("grpc.max_receive_message_length", constant.MAX_MSG_LENGTH),
        ],
    )
    base_pb2_grpc.add_BaseServicer_to_server(servicer, server)
    server.add_insecure_port(addr)
    server.start()
    server.wait_for_termination()