#include <client_channel_checker.h>

apollo::hdmap::ChannelChecker 的协作图:

Public 成员函数
	ChannelChecker (const std::string &stop_flag_file)

int	SyncStart (const std::string &record_path)

int	SyncStop ()

int	PeriodicCheck ()

int	GrpcStub (ChannelVerifyRequest request, ChannelVerifyResponse response)

详细描述

在文件 client_channel_checker.h 第 27 行定义.

构造及析构函数说明

◆ ChannelChecker()

apollo::hdmap::ChannelChecker::ChannelChecker ( const std::string & stop_flag_file )

explicit

在文件 client_channel_checker.cc 第 37 行定义.

    : stop_flag_file_(stop_flag_file) {
  YAML::Node node = YAML::LoadFile(FLAGS_client_conf_yaml);
  std::string server_addr =
      node["grpc_host_port"]["grpc_host"].as<std::string>() + ":" +
      node["grpc_host_port"]["grpc_port"].as<std::string>();
  check_period_ = node["channel_check"]["check_period"].as<int>();
  service_stub_ = CollectionCheckerService::NewStub(
      grpc::CreateChannel(server_addr, grpc::InsecureChannelCredentials()));
}

成员函数说明

◆ GrpcStub()

int apollo::hdmap::ChannelChecker::GrpcStub	(	ChannelVerifyRequest *	request,
		ChannelVerifyResponse *	response
	)

在文件 client_channel_checker.cc 第 91 行定义.

                                                              {
  grpc::ClientContext context;
  grpc::Status status;
  status = service_stub_->ServiceChannelVerify(&context, *request, response);
  if (status.error_code() == grpc::StatusCode::UNAVAILABLE) {
    AERROR << "FATAL Error. Map grpc service is UNAVAILABLE.";
    fprintf(USER_STREAM, "You should start server first\n");
    return -1;
  }
  ErrorCode error_code = response->code();
  if (error_code != ErrorCode::SUCCESS) {
    return ExceptionHandler::ExceptionHandlerFun(error_code);
  }
  return 0;
}

◆ PeriodicCheck()

int apollo::hdmap::ChannelChecker::PeriodicCheck ( )

在文件 client_channel_checker.cc 第 73 行定义.

                                  {
  int ret = 0;
  while (!boost::filesystem::exists(stop_flag_file_)) {
    ret = Check();
    if (ret != 0) {
      break;
    }
    AINFO << "channel checker sleep " << check_period_ << " seconds";
    std::this_thread::sleep_for(std::chrono::seconds(check_period_));
  }
  if (ret == 0) {
    AINFO << "detected stop flag file, periodically checking will exit";
  } else {
    AINFO << "periodically checking will exit because of some errors";
  }
  return ret;
}

◆ SyncStart()

int apollo::hdmap::ChannelChecker::SyncStart ( const std::string & record_path )

在文件 client_channel_checker.cc 第 48 行定义.

                                                          {
  if (!boost::filesystem::exists(record_path)) {
    AERROR << "record_path [" << record_path << "]does not exist";
    return -1;
  }
  int ret = Start(record_path);
  if (ret != 0) {
    AERROR << "start check channel failed, record_path [" << record_path << "]";
    return -1;
  }
  return PeriodicCheck();
}

◆ SyncStop()

int apollo::hdmap::ChannelChecker::SyncStop ( )

在文件 client_channel_checker.cc 第 61 行定义.

                             {
  // stop client
  std::ofstream ofs(stop_flag_file_);
  if (!ofs) {
    AERROR << "Create Flag File [" << stop_flag_file_ << "] Failed";
    return -1;
  }
  ofs.close();
  // stop server
  return Stop();
}

该类的文档由以下文件生成:

modules/map/tools/map_datachecker/client/client_channel_checker.h
modules/map/tools/map_datachecker/client/client_channel_checker.cc

Public 成员函数