apollo::bridge::BridgeProtoDiserializedBuf< T > 模板类 参考

#include <bridge_proto_diserialized_buf.h>

类 apollo::bridge::BridgeProtoDiserializedBuf< T > 继承关系图:

apollo::bridge::BridgeProtoDiserializedBuf< T > 的协作图:

Public 成员函数
	BridgeProtoDiserializedBuf ()
	BridgeProtoDiserializedBuf (const std::string &topic_name)
virtual	~BridgeProtoDiserializedBuf ()
virtual bool	DiserializedAndPub ()
virtual bool	Initialize (const BridgeHeader &header, std::shared_ptr< cyber::Node > node)
virtual bool	IsReadyDiserialize () const
virtual void	UpdateStatus (uint32_t frame_index)
virtual bool	IsTheProto (const BridgeHeader &header)
bool	Initialize (const BridgeHeader &header)
bool	Diserialized (std::shared_ptr< T > proto)
virtual char *	GetBuf (size_t offset)
virtual uint32_t	GetMsgID () const
virtual std::string	GetMsgName () const
Public 成员函数 继承自 apollo::bridge::ProtoDiserializedBufBase
	ProtoDiserializedBufBase ()
virtual	~ProtoDiserializedBufBase ()

详细描述

template<typename T>
class apollo::bridge::BridgeProtoDiserializedBuf< T >

在文件 bridge_proto_diserialized_buf.h 第 50 行定义.

构造及析构函数说明

BridgeProtoDiserializedBuf() [1/2]

template<typename T >

apollo::bridge::BridgeProtoDiserializedBuf< T >::BridgeProtoDiserializedBuf ( )

inline

在文件 bridge_proto_diserialized_buf.h 第 52 行定义.

{}

BridgeProtoDiserializedBuf() [2/2]

template<typename T >

apollo::bridge::BridgeProtoDiserializedBuf< T >::BridgeProtoDiserializedBuf ( const std::string &  topic_name )

inlineexplicit

在文件 bridge_proto_diserialized_buf.h 第 53 行定义.

      : topic_name_(topic_name) {}

~BridgeProtoDiserializedBuf()

template<typename T >

apollo::bridge::BridgeProtoDiserializedBuf< T >::~BridgeProtoDiserializedBuf ( )

virtual

在文件 bridge_proto_diserialized_buf.h 第 84 行定义.

                                                           {
  FREE_ARRY(proto_buf_);
}

成员函数说明

Diserialized()

template<typename T >

bool apollo::bridge::BridgeProtoDiserializedBuf< T >::Diserialized

(

std::shared_ptr< T >

proto

)

在文件 bridge_proto_diserialized_buf.h 第 89 行定义.

                                                                       {
  if (!proto_buf_ || !proto) {
    return false;
  }
  proto->ParseFromArray(proto_buf_, static_cast<int>(total_size_));
  return true;
}

DiserializedAndPub()

template<typename T >

bool apollo::bridge::BridgeProtoDiserializedBuf< T >::DiserializedAndPub ( )

virtual

实现了 apollo::bridge::ProtoDiserializedBufBase.

在文件 bridge_proto_diserialized_buf.h 第 173 行定义.

                                                       {
  auto pb_msg = std::make_shared<T>();
  if (!Diserialized(pb_msg)) {
    return false;
  }
  writer_->Write(pb_msg);
  return true;
}

GetBuf()

template<typename T >

virtual char * apollo::bridge::BridgeProtoDiserializedBuf< T >::GetBuf ( size_t  offset )

inlinevirtual

实现了 apollo::bridge::ProtoDiserializedBufBase.

在文件 bridge_proto_diserialized_buf.h 第 67 行定义.

{ return proto_buf_ + offset; }

GetMsgID()

template<typename T >

virtual uint32_t apollo::bridge::BridgeProtoDiserializedBuf< T >::GetMsgID ( ) const

inlinevirtual

实现了 apollo::bridge::ProtoDiserializedBufBase.

在文件 bridge_proto_diserialized_buf.h 第 68 行定义.

{ return sequence_num_; }

GetMsgName()

template<typename T >

virtual std::string apollo::bridge::BridgeProtoDiserializedBuf< T >::GetMsgName ( ) const

inlinevirtual

实现了 apollo::bridge::ProtoDiserializedBufBase.

在文件 bridge_proto_diserialized_buf.h 第 69 行定义.

{ return proto_name_; }

Initialize() [1/2]

template<typename T >

bool apollo::bridge::BridgeProtoDiserializedBuf< T >::Initialize

(

const BridgeHeader &

header

)

在文件 bridge_proto_diserialized_buf.h 第 138 行定义.

                                                                         {
  total_size_ = header.GetMsgSize();
  total_frames_ = header.GetTotalFrames();
  proto_name_ = header.GetMsgName();
  sequence_num_ = header.GetMsgID();
  if (total_frames_ == 0) {
    return false;
  }
  int status_size = static_cast<int>(total_frames_ / INT_BITS +
                                     ((total_frames_ % INT_BITS) ? 1 : 0));
  if (status_list_.empty()) {
    for (int i = 0; i < status_size; i++) {
      status_list_.push_back(0);
    }
  }
 
  if (!proto_buf_) {
    try {
      proto_buf_ = new char[total_size_];
    } catch (const std::bad_alloc& e) {
      AERROR << "Memory allocation failed: " << e.what();
      return false;
    }
  }
  return true;
}

Initialize() [2/2]

template<typename T >

bool apollo::bridge::BridgeProtoDiserializedBuf< T >::Initialize ( const BridgeHeader &  header, std::shared_ptr< cyber::Node >  node  )

virtual

实现了 apollo::bridge::ProtoDiserializedBufBase.

在文件 bridge_proto_diserialized_buf.h 第 166 行定义.

                                                               {
  writer_ = node->CreateWriter<T>(topic_name_.c_str());
  return Initialize(header);
}

IsReadyDiserialize()

template<typename T >

virtual bool apollo::bridge::BridgeProtoDiserializedBuf< T >::IsReadyDiserialize ( ) const

inlinevirtual

实现了 apollo::bridge::ProtoDiserializedBufBase.

在文件 bridge_proto_diserialized_buf.h 第 61 行定义.

{ return is_ready_diser; }

IsTheProto()

template<typename T >

bool apollo::bridge::BridgeProtoDiserializedBuf< T >::IsTheProto ( const BridgeHeader &  header )

virtual

实现了 apollo::bridge::ProtoDiserializedBufBase.

在文件 bridge_proto_diserialized_buf.h 第 129 行定义.

                                                                         {
  if (strcmp(proto_name_.c_str(), header.GetMsgName().c_str()) == 0 &&
      sequence_num_ == header.GetMsgID()) {
    return true;
  }
  return false;
}

UpdateStatus()

template<typename T >

void apollo::bridge::BridgeProtoDiserializedBuf< T >::UpdateStatus ( uint32_t  frame_index )

virtual

实现了 apollo::bridge::ProtoDiserializedBufBase.

在文件 bridge_proto_diserialized_buf.h 第 98 行定义.

                                                                     {
  size_t status_size = status_list_.size();
  uint32_t status_index = frame_index / INT_BITS;
  if (status_size == 0 ||
    static_cast<std::size_t>(status_index) >= status_size) {
    is_ready_diser = false;
    return;
  }
 
  status_list_[status_index] |= (1 << (frame_index % INT_BITS));
  for (size_t i = 0; i < status_size; i++) {
    if (i == status_size - 1) {
      if (static_cast<int>(status_list_[i]) ==
          (1 << total_frames_ % INT_BITS) - 1) {
        AINFO << "diserialized is ready";
        is_ready_diser = true;
      } else {
        is_ready_diser = false;
        break;
      }
    } else {
      if (status_list_[i] != 0xffffffff) {
        is_ready_diser = false;
        break;
      }
      is_ready_diser = true;
    }
  }
}

---

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

• modules/bridge/common/bridge_proto_diserialized_buf.h