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

#include <bridge_proto_serialized_buf.h>

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

Public 成员函数
	BridgeProtoSerializedBuf ()
	~BridgeProtoSerializedBuf ()
char *	GetFrame (size_t index)
bool	Serialize (const std::shared_ptr< T > &proto, const std::string &msg_name)
const char *	GetSerializedBuf (size_t index) const
size_t	GetSerializedBufCount () const
size_t	GetSerializedBufSize (size_t index) const

详细描述

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

在文件 bridge_proto_serialized_buf.h 第 30 行定义.

构造及析构函数说明

BridgeProtoSerializedBuf()

template<typename T >

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

inline

在文件 bridge_proto_serialized_buf.h 第 32 行定义.

{}

~BridgeProtoSerializedBuf()

template<typename T >

apollo::bridge::BridgeProtoSerializedBuf< T >::~BridgeProtoSerializedBuf

(

)

在文件 bridge_proto_serialized_buf.h 第 57 行定义.

                                                       {
  for (auto frame : frames_) {
    FREE_ARRY(frame.buf_);
  }
}

成员函数说明

GetFrame()

template<typename T >

char * apollo::bridge::BridgeProtoSerializedBuf< T >::GetFrame

(

size_t

index

)

GetSerializedBuf()

template<typename T >

const char * apollo::bridge::BridgeProtoSerializedBuf< T >::GetSerializedBuf ( size_t  index ) const

inline

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

                                                   {
    return frames_[index].buf_;
  }

GetSerializedBufCount()

template<typename T >

size_t apollo::bridge::BridgeProtoSerializedBuf< T >::GetSerializedBufCount ( ) const

inline

在文件 bridge_proto_serialized_buf.h 第 41 行定义.

{ return frames_.size(); }

GetSerializedBufSize()

template<typename T >

size_t apollo::bridge::BridgeProtoSerializedBuf< T >::GetSerializedBufSize ( size_t  index ) const

inline

在文件 bridge_proto_serialized_buf.h 第 42 行定义.

                                                  {
    return frames_[index].buf_len_;
  }

Serialize()

template<typename T >

bool apollo::bridge::BridgeProtoSerializedBuf< T >::Serialize	(	const std::shared_ptr< T > &	proto,
		const std::string &	msg_name
	)

在文件 bridge_proto_serialized_buf.h 第 64 行定义.

                                                                       {
  bsize msg_len = static_cast<bsize>(proto->ByteSizeLong());
  char *tmp = new char[msg_len]();
  if (!proto->SerializeToArray(tmp, static_cast<int>(msg_len))) {
    FREE_ARRY(tmp);
    return false;
  }
  bsize offset = 0;
  bsize frame_index = 0;
  uint32_t total_frames = static_cast<uint32_t>(msg_len / FRAME_SIZE +
                                                (msg_len % FRAME_SIZE ? 1 : 0));
 
  while (offset < msg_len) {
    bsize left = msg_len - frame_index * FRAME_SIZE;
    bsize cpy_size = (left > FRAME_SIZE) ? FRAME_SIZE : left;
 
    BridgeHeader header;
    header.SetHeaderVer(0);
    header.SetMsgName(msg_name);
    header.SetMsgID(proto->header().sequence_num());
    header.SetTimeStamp(proto->header().timestamp_sec());
    header.SetMsgSize(msg_len);
    header.SetTotalFrames(total_frames);
    header.SetFrameSize(cpy_size);
    header.SetIndex(frame_index);
    header.SetFramePos(frame_index * FRAME_SIZE);
    hsize header_size = header.GetHeaderSize();
    Buf buf;
    buf.buf_ = new char[cpy_size + header_size];
    buf.buf_len_ = cpy_size + header_size;
    header.Serialize(buf.buf_, buf.buf_len_);
    memcpy(buf.buf_ + header_size, tmp + frame_index * FRAME_SIZE, cpy_size);
    frames_.push_back(buf);
    frame_index++;
    offset += cpy_size;
  }
  FREE_ARRY(tmp);
  return true;
}

---

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

• modules/bridge/common/bridge_proto_serialized_buf.h