FrontEndServer.py 文件源码

def serve():
  protoConfig = ProtoConfig.getConfig()
  server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
  sensors_pb2.add_FrontEndServicer_to_server(FrontEnd(protoConfig), server)
  port = protoConfig.ports.frontEndPort
  server.add_insecure_port('[::]:%s' % port)
  server.start()
  print('Started FrontEnd Server on Port %s ' % port)

  try:
    while True:
      time.sleep(_ONE_DAY_IN_SECONDS)
  except KeyboardInterrupt:
    server.stop(0)