Searched refs:heartbeat_resp_message (Results 1 – 2 of 2) sorted by relevance
61 HeartbeatRespMessage heartbeat_resp_message; in ProcessHeartbeat() local64 heartbeat_resp_message.set_cluster_state(node_manager_.GetClusterState()); in ProcessHeartbeat()68 …*heartbeat_resp_message.mutable_servers_meta() = {servers_meta_list.begin(), servers_meta_list.end… in ProcessHeartbeat()70 heartbeat_resp_message.set_is_worker_or_server0(node_manager_.IsWorkerOrServer0()); in ProcessHeartbeat()72 …if (!server->SendMessage(conn, meta, Protos::PROTOBUF, heartbeat_resp_message.SerializeAsString().… in ProcessHeartbeat()73 heartbeat_resp_message.ByteSizeLong())) { in ProcessHeartbeat()
571 HeartbeatRespMessage heartbeat_resp_message; in ProcessHeartbeatResp() local572 CHECK_RETURN_TYPE(heartbeat_resp_message.ParseFromArray(data, SizeToInt(size))); in ProcessHeartbeatResp()574 current_cluster_state_ = heartbeat_resp_message.cluster_state(); in ProcessHeartbeatResp()579 for (const auto &it : heartbeat_resp_message.servers_meta()) { in ProcessHeartbeatResp()593 bool is_worker_or_server0 = heartbeat_resp_message.is_worker_or_server0(); in ProcessHeartbeatResp()