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
template<typename Data >
	QueuedSubscriber (const char *name, LockQueue< Data > &queue, Domain *domain=nullptr)
	构造函数，使用名称和带锁队列进行初始化 Constructor using a name and a locked queue
template<typename Data >
	QueuedSubscriber (Topic topic, LockQueue< Data > &queue)
	构造函数，使用 Topic 和带锁队列进行初始化 Constructor using a Topic and a locked 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 373 of file message.hpp.

Constructor & Destructor Documentation

QueuedSubscriber() [1/4]

template<typename Data , uint32_t Length>

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

inline

Definition at line 377 of file message.hpp.

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

QueuedSubscriber() [2/4]

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 391 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 List::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);
    }

QueuedSubscriber() [3/4]

template<typename Data >

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

inline

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

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)

Definition at line 424 of file message.hpp.

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

QueuedSubscriber() [4/4]

template<typename Data >

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

inline

构造函数，使用 Topic 和带锁队列进行初始化 Constructor using a Topic and a locked queue

Template Parameters

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

Parameters

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

Definition at line 437 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 List::Node<QueueBlock>;
      block->data_.type = SuberType::QUEUE;
      block->data_.queue = &queue;
      block->data_.fun = [](RawData &data, void *arg, bool in_isr)
      {
        LockQueue<Data> *queue = reinterpret_cast<LockQueue<Data> *>(arg);
        queue->PushFromCallback(*reinterpret_cast<const Data *>(data.addr_), in_isr);
      };
 
      topic.block_->data_.subers.Add(*block);
    }

---

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

• src/middleware/message.hpp