异步订阅者自己挂的数据块 / Data block owned by one asynchronous subscriber More...

#include <async.hpp>

Inheritance diagram for LibXR::Topic::ASyncBlock:

Collaboration diagram for LibXR::Topic::ASyncBlock:

Data Fields
void *	buff_addr
	长期存在的本地接收对象地址。Long-lived local receive object address.

void(*	copy_payload )(void dst, void payload_addr)
	按订阅精确类型执行负载拷贝的适配函数。Adapter that copies one payload using the subscriber's exact type.

MicrosecondTimestamp	timestamp
	最近接收的消息时间戳。Latest received message timestamp.

std::atomic< ASyncSubscriberState >	state
	当前异步订阅状态。Current async subscriber state.

Data Fields inherited from LibXR::Topic::SuberBlock
SuberType	type
	订阅块的具体种类。Concrete kind of this subscriber block.

Detailed Description

异步订阅者自己挂的数据块 / Data block owned by one asynchronous subscriber

异步订阅者挂在 topic 链表里的数据块 / Subscriber block used by one asynchronous subscriber inside the topic list

Definition at line 22 of file async.hpp.

Field Documentation

void* LibXR::Topic::ASyncBlock::buff_addr

长期存在的本地接收对象地址。Long-lived local receive object address.

Definition at line 24 of file async.hpp.

void(* LibXR::Topic::ASyncBlock::copy_payload) (void *dst, void *payload_addr)

按订阅精确类型执行负载拷贝的适配函数。Adapter that copies one payload using the subscriber's exact type.

Definition at line 25 of file async.hpp.

std::atomic<ASyncSubscriberState> LibXR::Topic::ASyncBlock::state

Initial value:

=

@ IDLE

当前没有等待，也没有待消费的新数据。No wait is pending and no unread data is buffered.

当前异步订阅状态。Current async subscriber state.

Definition at line 28 of file async.hpp.

MicrosecondTimestamp LibXR::Topic::ASyncBlock::timestamp

最近接收的消息时间戳。Latest received message timestamp.

Definition at line 27 of file async.hpp.

The documentation for this struct was generated from the following file: