folly::NotificationQueue< MessageT >::Consumer Member List

This is the complete list of members for folly::NotificationQueue< MessageT >::Consumer, including all inherited members.

active_	folly::NotificationQueue< MessageT >::Consumer	private
attachEventBase(EventBase *eventBase)	folly::EventHandler	private
base_	folly::NotificationQueue< MessageT >::Consumer	private
changeHandlerFD(int fd)	folly::EventHandler	inlineprivate
changeHandlerFD(NetworkSocket fd)	folly::EventHandler	private
consumeMessages(bool isDrain, size_t *numConsumed=nullptr) noexcept	folly::NotificationQueue< MessageT >::Consumer	private
Consumer()	folly::NotificationQueue< MessageT >::Consumer	inline
consumeUntilDrained(size_t *numConsumed=nullptr) noexcept	folly::NotificationQueue< MessageT >::Consumer
DelayedDestruction()	folly::DelayedDestruction	inlineprotected
DelayedDestructionBase()	folly::DelayedDestructionBase	inlineprotected
destroy() override	folly::NotificationQueue< MessageT >::Consumer	protectedvirtual
destroyedFlagPtr_	folly::NotificationQueue< MessageT >::Consumer	private
detachEventBase()	folly::EventHandler	private
EventFlags enum name	folly::EventHandler	private
EventHandler(EventBase *eventBase, int fd)	folly::EventHandler	inlineexplicitprivate
EventHandler(EventBase *eventBase=nullptr, NetworkSocket fd=NetworkSocket())	folly::EventHandler	explicitprivate
getCurrentQueue() const	folly::NotificationQueue< MessageT >::Consumer	inline
getDestroyPending() const	folly::DelayedDestruction	inline
getDestructorGuardCount() const	folly::DelayedDestructionBase	inlineprotected
getEventBase()	folly::NotificationQueue< MessageT >::Consumer	inline
getMaxReadAtOnce() const	folly::NotificationQueue< MessageT >::Consumer	inline
getRegisteredEvents() const	folly::EventHandler	inlineprivate
handlerReady(uint16_t events) noexceptoverride	folly::NotificationQueue< MessageT >::Consumer	virtual
init(EventBase *eventBase, NotificationQueue *queue)	folly::NotificationQueue< MessageT >::Consumer	private
initHandler(EventBase *eventBase, int fd)	folly::EventHandler	inlineprivate
initHandler(EventBase *eventBase, NetworkSocket fd)	folly::EventHandler	private
isHandlerRegistered() const	folly::EventHandler	inlineprivate
isPending() const	folly::EventHandler	private
kDefaultMaxReadAtOnce enum value	folly::NotificationQueue< MessageT >::Consumer
make(TCallback &&callback)	folly::NotificationQueue< MessageT >::Consumer	static
make(TCallback &&callback)	folly::NotificationQueue< MessageT >::Consumer
maxReadAtOnce_	folly::NotificationQueue< MessageT >::Consumer	private
messageAvailable(MessageT &&message) noexcept=0	folly::NotificationQueue< MessageT >::Consumer	pure virtual
NONE enum value	folly::EventHandler	private
PERSIST enum value	folly::EventHandler	private
queue_	folly::NotificationQueue< MessageT >::Consumer	private
READ enum value	folly::EventHandler	private
READ_WRITE enum value	folly::EventHandler	private
registerHandler(uint16_t events)	folly::EventHandler	inlineprivate
registerInternalHandler(uint16_t events)	folly::EventHandler	inlineprivate
setActive(bool active, bool shouldLock=false)	folly::NotificationQueue< MessageT >::Consumer	inlineprivate
setMaxReadAtOnce(uint32_t maxAtOnce)	folly::NotificationQueue< MessageT >::Consumer	inline
startConsuming(EventBase *eventBase, NotificationQueue *queue)	folly::NotificationQueue< MessageT >::Consumer	inline
startConsumingInternal(EventBase *eventBase, NotificationQueue *queue)	folly::NotificationQueue< MessageT >::Consumer	inline
stopConsuming()	folly::NotificationQueue< MessageT >::Consumer
unregisterHandler()	folly::EventHandler	private
WRITE enum value	folly::EventHandler	private
~Consumer() override	folly::NotificationQueue< MessageT >::Consumer	inlineprotected
~DelayedDestruction() override=default	folly::DelayedDestruction	protected
~DelayedDestructionBase()=default	folly::DelayedDestructionBase	virtual
~EventHandler()	folly::EventHandler	privatevirtual