LibXR::Topic::QueuedSubscriber Class Reference

Collaboration diagram for LibXR::Topic::QueuedSubscriber:

Public Member Functions
template<typename Data >
	QueuedSubscriber (const char *name, LockFreeQueue< Data > &queue, Domain *domain=nullptr)
	构造函数，自动创建队列
template<typename Data >
	QueuedSubscriber (const char *name, LockFreeQueue< Message< Data > > &queue, Domain *domain=nullptr)
	构造函数，使用 Topic 和无锁队列进行初始化 Constructor using a Topic and a lock-free queue
template<typename Data >
	QueuedSubscriber (Topic topic, LockFreeQueue< Data > &queue)
	构造函数，使用 Topic 和无锁队列进行初始化 Constructor using a Topic and a lock-free queue
template<typename Data >
	QueuedSubscriber (Topic topic, LockFreeQueue< Message< Data > > &queue)
	构造函数，使用 Topic 和带时间戳消息队列进行初始化 Constructor using a Topic and a timestamped message queue
	QueuedSubscriber (const QueuedSubscriber &)=delete
QueuedSubscriber &	operator= (const QueuedSubscriber &)=delete
	QueuedSubscriber (QueuedSubscriber &&other) noexcept
QueuedSubscriber &	operator= (QueuedSubscriber &&other) noexcept

Private Attributes
LockFreeList::Node< QueueBlock > *	block_ = nullptr

Detailed Description

Definition at line 312 of file subscriber.hpp.

Constructor & Destructor Documentation

QueuedSubscriber() [1/5]

template<typename Data >

LibXR::Topic::QueuedSubscriber::QueuedSubscriber ( const char * name, LockFreeQueue< Data > & queue, Domain * domain = nullptr )

inline

构造函数，自动创建队列

Template Parameters

Data	队列存储的数据类型 Data type stored in the queue

Parameters

name	订阅的主题名称 Name of the subscribed topic
queue	订阅的数据队列 Subscribed data queue
domain	可选的域指针 Optional domain pointer (default: nullptr)

Note

包含初始化期动态内存分配，订阅者应长期存在。 Contains initialization-time dynamic allocation; subscribers are expected to be long-lived.

Definition at line 328 of file subscriber.hpp.

      : QueuedSubscriber(Topic(WaitTopic(name, UINT32_MAX, domain)), queue)
  {
  }

QueuedSubscriber() [2/5]

template<typename Data >

LibXR::Topic::QueuedSubscriber::QueuedSubscriber ( const char * name, LockFreeQueue< Message< Data > > & queue, Domain * domain = nullptr )

inline

构造函数，使用 Topic 和无锁队列进行初始化 Constructor using a Topic and a lock-free queue

Template Parameters

Data	队列消息的数据类型 Data type stored in the queue message

Parameters

name	订阅的主题名称 Name of the subscribed topic
queue	订阅的消息队列 Subscribed message queue
domain	可选的域指针 Optional domain pointer (default: nullptr)

Definition at line 342 of file subscriber.hpp.

      : QueuedSubscriber(Topic(WaitTopic(name, UINT32_MAX, domain)), queue)
  {
  }

QueuedSubscriber() [3/5]

template<typename Data >

LibXR::Topic::QueuedSubscriber::QueuedSubscriber ( Topic topic, LockFreeQueue< Data > & queue )

inline

构造函数，使用 Topic 和无锁队列进行初始化 Constructor using a Topic and a lock-free queue

Template Parameters

Data	队列存储的数据类型 Data type stored in the queue

Parameters

topic	订阅的主题 Subscribed topic
queue	订阅的数据队列 Subscribed data queue

Note

包含初始化期动态内存分配，订阅者应长期存在。 Contains initialization-time dynamic allocation; subscribers are expected to be long-lived.

Definition at line 360 of file subscriber.hpp.

  {
    CheckSubscriberDataSize<Data>(topic);
 
    block_ = new LockFreeList::Node<QueueBlock>;
    block_->data_.type = SuberType::QUEUE;
    block_->data_.queue = &queue;
    block_->data_.fun = [](MicrosecondTimestamp, RawData data, QueueBlock& block)
    {
      LockFreeQueue<Data>* queue = reinterpret_cast<LockFreeQueue<Data>*>(block.queue);
      (void)queue->Push(*reinterpret_cast<Data*>(data.addr_));
    };
 
    topic.block_->data_.subers.Add(*block_);
  }

QueuedSubscriber() [4/5]

template<typename Data >

LibXR::Topic::QueuedSubscriber::QueuedSubscriber ( Topic topic, LockFreeQueue< Message< Data > > & queue )

inline

构造函数，使用 Topic 和带时间戳消息队列进行初始化 Constructor using a Topic and a timestamped message queue

Definition at line 381 of file subscriber.hpp.

  {
    CheckSubscriberDataSize<Data>(topic);
 
    block_ = new LockFreeList::Node<QueueBlock>;
    block_->data_.type = SuberType::QUEUE;
    block_->data_.queue = &queue;
    block_->data_.fun =
        [](MicrosecondTimestamp timestamp, RawData data, QueueBlock& block)
    {
      LockFreeQueue<Message<Data>>* queue =
          reinterpret_cast<LockFreeQueue<Message<Data>>*>(block.queue);
      (void)queue->Push(Message<Data>{timestamp, *reinterpret_cast<Data*>(data.addr_)});
    };
 
    topic.block_->data_.subers.Add(*block_);
  }

QueuedSubscriber() [5/5]

LibXR::Topic::QueuedSubscriber::QueuedSubscriber ( QueuedSubscriber && other )

inlinenoexcept

Definition at line 402 of file subscriber.hpp.

                                                      : block_(other.block_)
  {
    other.block_ = nullptr;
  }

Member Function Documentation

operator=()

QueuedSubscriber & LibXR::Topic::QueuedSubscriber::operator= ( QueuedSubscriber && other )

inlinenoexcept

Definition at line 407 of file subscriber.hpp.

  {
    if (this != &other)
    {
      block_ = other.block_;
      other.block_ = nullptr;
    }
    return *this;
  }

Field Documentation

block_

LockFreeList::Node<QueueBlock>* LibXR::Topic::QueuedSubscriber::block_ = nullptr

private

Definition at line 418 of file subscriber.hpp.

---

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

• src/middleware/message/subscriber.hpp