LibXR::Topic::QueuedSubscriber Class Reference

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

#include <message.hpp>

Public Member Functions
template<typename Data , uint32_t Length>
	QueuedSubscriber (const char *name, LockFreeQueue< Data > &queue, Domain *domain=nullptr)
template<typename Data >
	QueuedSubscriber (Topic topic, LockFreeQueue< Data > &queue)
	构造函数，使用 Topic 和无锁队列进行初始化 Constructor using a Topic and a lock-free queue

Detailed Description

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

Template Parameters

Data	队列存储的数据类型 Data type stored in the queue
Length	队列长度 Queue length

Parameters

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

Definition at line 408 of file message.hpp.

Constructor & Destructor Documentation

QueuedSubscriber() [1/2]

template<typename Data , uint32_t Length>

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

inline

Definition at line 412 of file message.hpp.

    {
      *this = QueuedSubscriber(WaitTopic(name, UINT32_MAX, domain), queue);
    }

QueuedSubscriber() [2/2]

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

Definition at line 426 of file message.hpp.

    {
      if (topic.block_->data_.check_length)
      {
        ASSERT(topic.block_->data_.max_length == sizeof(Data));
      }
      else
      {
        ASSERT(topic.block_->data_.max_length <= sizeof(Data));
      }
 
      auto block = new LockFreeList::Node<QueueBlock>;
      block->data_.type = SuberType::QUEUE;
      block->data_.queue = &queue;
      block->data_.fun = [](RawData &data, void *arg, bool in_isr)
      {
        UNUSED(in_isr);
        LockFreeQueue<Data>* queue = reinterpret_cast<LockFreeQueue<Data>*>(arg);
        queue->Push(*reinterpret_cast<Data*>(data.addr_));
      };
 
      topic.block_->data_.subers.Add(*block);
    }

---

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

• src/middleware/message.hpp