folly::EventBase::FunctionRunner Class Reference

Inheritance diagram for folly::EventBase::FunctionRunner:

Public Member Functions
void	messageAvailable (Func &&msg) noexceptoverride
Public Member Functions inherited from folly::NotificationQueue< MessageT >::Consumer
	Consumer ()
virtual void	messageAvailable (MessageT &&message) noexcept=0
void	startConsuming (EventBase *eventBase, NotificationQueue *queue)
void	startConsumingInternal (EventBase *eventBase, NotificationQueue *queue)
void	stopConsuming ()
bool	consumeUntilDrained (size_t *numConsumed=nullptr) noexcept
NotificationQueue *	getCurrentQueue () const
void	setMaxReadAtOnce (uint32_t maxAtOnce)
uint32_t	getMaxReadAtOnce () const
EventBase *	getEventBase ()
void	handlerReady (uint16_t events) noexceptoverride
template<typename TCallback >
std::unique_ptr< typename NotificationQueue< MessageT >::Consumer, DelayedDestruction::Destructor >	make (TCallback &&callback)
Public Member Functions inherited from folly::DelayedDestruction
bool	getDestroyPending () const
Public Member Functions inherited from folly::DelayedDestructionBase
virtual	~DelayedDestructionBase ()=default

Additional Inherited Members
Public Types inherited from folly::NotificationQueue< MessageT >::Consumer
enum	: uint16_t { kDefaultMaxReadAtOnce = 10 }
Static Public Member Functions inherited from folly::NotificationQueue< MessageT >::Consumer
template<typename TCallback >
static std::unique_ptr< Consumer, DelayedDestruction::Destructor >	make (TCallback &&callback)
Protected Member Functions inherited from folly::NotificationQueue< MessageT >::Consumer
void	destroy () override
	~Consumer () override
Protected Member Functions inherited from folly::DelayedDestruction
	~DelayedDestruction () override=default
	DelayedDestruction ()
Protected Member Functions inherited from folly::DelayedDestructionBase
	DelayedDestructionBase ()
uint32_t	getDestructorGuardCount () const

Detailed Description

Definition at line 42 of file EventBase.cpp.

Member Function Documentation

void folly::EventBase::FunctionRunner::messageAvailable ( Func &&  msg )

inlineoverridenoexcept

Definition at line 45 of file EventBase.cpp.

References folly::EventBase::evb_, and folly::NotificationQueue< MessageT >::Consumer::getEventBase().

                                                      {
    // In libevent2, internal events do not break the loop.
    // Most users would expect loop(), followed by runInEventBaseThread(),
    // to break the loop and check if it should exit or not.
    // To have similar bejaviour to libevent1.4, tell the loop to break here.
    // Note that loop() may still continue to loop, but it will also check the
    // stop_ flag as well as runInLoop callbacks, etc.
    event_base_loopbreak(getEventBase()->evb_);

    if (!msg) {
      // terminateLoopSoon() sends a null message just to
      // wake up the loop.  We can ignore these messages.
      return;
    }
    msg();
  }

---

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

• proxygen/folly/folly/io/async/EventBase.cpp