apollo::v2x::GrpcClientImpl类 参考

#include <grpc_client.h>

apollo::v2x::GrpcClientImpl 的协作图:

Public 成员函数
	GrpcClientImpl (std::shared_ptr< grpc::Channel > channel)
	~GrpcClientImpl ()
bool	InitFlag ()
void	SendMsgToGrpc (const std::shared_ptr<::apollo::v2x::CarStatus > &msg)

详细描述

在文件 grpc_client.h 第 39 行定义.

构造及析构函数说明

GrpcClientImpl()

apollo::v2x::GrpcClientImpl::GrpcClientImpl ( std::shared_ptr< grpc::Channel >  channel )

explicit

在文件 grpc_client.cc 第 39 行定义.

    : stub_(::apollo::v2x::CarToObu::NewStub(channel)) {
  AINFO << "GrpcClientImpl initial success";
  car_status_tv_nsec_ = (1000000000 / FLAGS_v2x_car_status_timer_frequency / 2);
  init_flag_ = true;
}

~GrpcClientImpl()

apollo::v2x::GrpcClientImpl::~GrpcClientImpl ( )

inline

在文件 grpc_client.h 第 46 行定义.

{}

成员函数说明

InitFlag()

bool apollo::v2x::GrpcClientImpl::InitFlag ( )

inline

在文件 grpc_client.h 第 48 行定义.

{ return init_flag_; }

SendMsgToGrpc()

void apollo::v2x::GrpcClientImpl::SendMsgToGrpc

(

const std::shared_ptr<::apollo::v2x::CarStatus > &

msg

)

在文件 grpc_client.cc 第 46 行定义.

                                                                      {
  if (!msg->has_localization()) {
    return;
  }
  // set timeout
  ClientContext context;
  gpr_timespec timespec;
  timespec.tv_sec = 0;
  timespec.tv_nsec = car_status_tv_nsec_;  // 80000000; // 80ms
  timespec.clock_type = GPR_TIMESPAN;
  context.set_deadline(timespec);
  UpdateStatus response;
 
  // time used statistics
  auto start = std::chrono::steady_clock::now();
  Status status = stub_->PushCarStatus(&context, *msg, &response);
  auto end = std::chrono::steady_clock::now();
  std::chrono::duration<double> time_used = end - start;
 
  // response check: error_code 4: time out; 0: success;
  AINFO << "stub PushCarStatus Time used: " << time_used.count() * 1000
        << " ms";
}

---

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

• modules/v2x/v2x_proxy/obu_interface/grpc_interface/grpc_client.h
• modules/v2x/v2x_proxy/obu_interface/grpc_interface/grpc_client.cc