LibXR::Topic::QueuedSubscriber Class Reference

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

Definition at line 414 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

构造函数，自动创建队列

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)

Note

包含动态内存分配。 Contains dynamic memory allocation.

Definition at line 430 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

Note

包含动态内存分配。 Contains dynamic memory allocation.

Definition at line 447 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