def _get_values(self, pause_secs=2.0):
channel = grpc.insecure_channel(self.hostname)
stub = LocationServiceStub(channel)
while not self.stopped:
logger.info("Connecting to gRPC server at {0}...".format(self.hostname))
try:
client_info = ClientInfo(info="{0} client".format(socket.gethostname()))
server_info = stub.registerClient(client_info)
except BaseException as e:
logger.error("Failed to connect to gRPC server at {0} [{1}]".format(self.hostname, e))
time.sleep(pause_secs)
continue
logger.info("Connected to gRPC server at {0} [{1}]".format(self.hostname, server_info.info))
try:
for val in stub.getLocations(client_info):
with self.value_lock:
self.__currval = copy.deepcopy(val)
self._mark_ready()
except BaseException as e:
logger.info("Disconnected from gRPC server at {0} [{1}]".format(self.hostname, e))
time.sleep(pause_secs)
# Non-blocking
location_client.py 文件源码
python
阅读 22
收藏 0
点赞 0
评论 0
评论列表
文章目录