apollo::v2x::ObuInterFaceGrpcImpl类 参考

#include <obu_interface_grpc_impl.h>

类 apollo::v2x::ObuInterFaceGrpcImpl 继承关系图:

apollo::v2x::ObuInterFaceGrpcImpl 的协作图:

Public 成员函数
	ObuInterFaceGrpcImpl ()
	~ObuInterFaceGrpcImpl ()
bool	InitialServer () override
bool	InitialClient () override
void	GetV2xTrafficLightFromObu (std::shared_ptr<::apollo::v2x::obu::ObuTrafficLight > *msg) override
void	GetV2xObstaclesFromObu (std::shared_ptr<::apollo::v2x::V2XObstacles > *msg) override
void	GetV2xRsiFromObu (std::shared_ptr<::apollo::v2x::obu::ObuRsi > *msg) override
void	SendCarStatusToObu (const std::shared_ptr<::apollo::v2x::CarStatus > &msg) override
bool	InitFlag ()
Public 成员函数 继承自 apollo::v2x::ObuInterFaceBase
	ObuInterFaceBase ()
virtual	~ObuInterFaceBase ()

详细描述

在文件 obu_interface_grpc_impl.h 第 38 行定义.

构造及析构函数说明

ObuInterFaceGrpcImpl()

apollo::v2x::ObuInterFaceGrpcImpl::ObuInterFaceGrpcImpl

(

)

在文件 obu_interface_grpc_impl.cc 第 38 行定义.

    : grpc_client_(new GrpcClientImpl(grpc::CreateChannel(
          FLAGS_grpc_client_host + ":" + FLAGS_grpc_client_port,
          grpc::InsecureChannelCredentials()))) {
  AINFO << "ObuInterFaceGrpcImpl Start Construct.";
  cli_init_ = grpc_client_->InitFlag();
  grpc_server_.reset(new GrpcServerImpl());
  srv_init_ = grpc_server_->InitFlag();
  CHECK(InitialClient());
  CHECK(InitialServer());
  init_succ_ = true;
}

~ObuInterFaceGrpcImpl()

apollo::v2x::ObuInterFaceGrpcImpl::~ObuInterFaceGrpcImpl

(

)

在文件 obu_interface_grpc_impl.cc 第 51 行定义.

                                            {
  {
    std::unique_lock<std::mutex> lck(mutex_);
    exit_flag_ = true;
  }
  condition_.notify_all();
  if (!!thread_grpc_ && thread_grpc_->joinable()) {
    thread_grpc_->join();
  }
  AINFO << "close obu interface success";
}

成员函数说明

GetV2xObstaclesFromObu()

void apollo::v2x::ObuInterFaceGrpcImpl::GetV2xObstaclesFromObu ( std::shared_ptr<::apollo::v2x::V2XObstacles > *  msg )

overridevirtual

重载 apollo::v2x::ObuInterFaceBase .

在文件 obu_interface_grpc_impl.cc 第 99 行定义.

                                               {
  grpc_server_->GetMsgFromGrpc(msg);
}

GetV2xRsiFromObu()

void apollo::v2x::ObuInterFaceGrpcImpl::GetV2xRsiFromObu ( std::shared_ptr<::apollo::v2x::obu::ObuRsi > *  msg )

overridevirtual

重载 apollo::v2x::ObuInterFaceBase .

在文件 obu_interface_grpc_impl.cc 第 104 行定义.

                                                                      {
  grpc_server_->GetMsgFromGrpc(msg);
}

GetV2xTrafficLightFromObu()

void apollo::v2x::ObuInterFaceGrpcImpl::GetV2xTrafficLightFromObu ( std::shared_ptr<::apollo::v2x::obu::ObuTrafficLight > *  msg )

overridevirtual

重载 apollo::v2x::ObuInterFaceBase .

在文件 obu_interface_grpc_impl.cc 第 94 行定义.

                                         {
  grpc_server_->GetMsgFromGrpc(msg);
}

InitFlag()

bool apollo::v2x::ObuInterFaceGrpcImpl::InitFlag ( )

inline

在文件 obu_interface_grpc_impl.h 第 71 行定义.

{ return init_succ_; }

InitialClient()

bool apollo::v2x::ObuInterFaceGrpcImpl::InitialClient ( )

overridevirtual

实现了 apollo::v2x::ObuInterFaceBase.

在文件 obu_interface_grpc_impl.cc 第 63 行定义.

{ return cli_init_; }

InitialServer()

bool apollo::v2x::ObuInterFaceGrpcImpl::InitialServer ( )

overridevirtual

实现了 apollo::v2x::ObuInterFaceBase.

在文件 obu_interface_grpc_impl.cc 第 65 行定义.

                                         {
  if (!srv_init_) {
    return false;
  }
  thread_grpc_.reset(new std::thread([this]() { this->ThreadRunServer(); }));
  return thread_grpc_ != nullptr;
}

SendCarStatusToObu()

void apollo::v2x::ObuInterFaceGrpcImpl::SendCarStatusToObu ( const std::shared_ptr<::apollo::v2x::CarStatus > &  msg )

overridevirtual

重载 apollo::v2x::ObuInterFaceBase .

在文件 obu_interface_grpc_impl.cc 第 108 行定义.

                                         {
  grpc_client_->SendMsgToGrpc(msg);
}

---

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

• modules/v2x/v2x_proxy/obu_interface/obu_interface_grpc_impl.h
• modules/v2x/v2x_proxy/obu_interface/obu_interface_grpc_impl.cc