folly::NotificationQueue< MessageT >::SimpleConsumer Class Reference

#include <NotificationQueue.h>

Public Member Functions
	SimpleConsumer (NotificationQueue &queue)
	~SimpleConsumer ()
int	getFd () const
template<typename F >
void	consumeUntilDrained (F &&foreach)

Private Attributes
NotificationQueue &	queue_

Detailed Description

template<typename MessageT>
class folly::NotificationQueue< MessageT >::SimpleConsumer

Definition at line 226 of file NotificationQueue.h.

Constructor & Destructor Documentation

template<typename MessageT>

folly::NotificationQueue< MessageT >::SimpleConsumer::SimpleConsumer ( NotificationQueue &  queue )

inlineexplicit

Definition at line 228 of file NotificationQueue.h.

References folly::NotificationQueue< MessageT >::queue_.

                                                      : queue_(queue) {
      ++queue_.numConsumers_;
    }

template<typename MessageT>

folly::NotificationQueue< MessageT >::SimpleConsumer::~SimpleConsumer ( )

inline

Definition at line 232 of file NotificationQueue.h.

References folly::NotificationQueue< MessageT >::queue_.

                      {
      --queue_.numConsumers_;
    }

Member Function Documentation

template<typename MessageT >

template<typename F >

void folly::NotificationQueue< MessageT >::SimpleConsumer::consumeUntilDrained

(

F &&

foreach

)

Definition at line 868 of file NotificationQueue.h.

References folly::data(), g(), folly::gen::move, folly::NotificationQueue< MessageT >::queue_, SCOPE_EXIT, and UNLIKELY.

                 {
  SCOPE_EXIT {
    queue_.syncSignalAndQueue();
  };

  queue_.checkPid();

  while (true) {
    std::unique_ptr<Node> data;
    {
      folly::SpinLockGuard g(queue_.spinlock_);

      if (UNLIKELY(queue_.queue_.empty())) {
        return;
      }

      data.reset(&queue_.queue_.front());
      queue_.queue_.pop_front();
    }

    RequestContextScopeGuard rctx(std::move(data->ctx_));
    foreach(std::move(data->msg_));
    // Make sure message destructor is called with the correct RequestContext.
    data.reset();
  }
}

template<typename MessageT>

int folly::NotificationQueue< MessageT >::SimpleConsumer::getFd ( ) const

inline

Definition at line 236 of file NotificationQueue.h.

References folly::NotificationQueue< MessageT >::queue_.

                      {
      return queue_.eventfd_ >= 0 ? queue_.eventfd_ : queue_.pipeFds_[0];
    }

Member Data Documentation

template<typename MessageT>

NotificationQueue& folly::NotificationQueue< MessageT >::SimpleConsumer::queue_

private

Definition at line 244 of file NotificationQueue.h.

---

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

• proxygen/folly/folly/io/async/NotificationQueue.h