Yate
JBStreamSetProcessor Class Reference

Specialized stream processor. More...

#include <yatejabber.h>

Inheritance diagram for JBStreamSetProcessor:
JBStreamSet GenObject Mutex Lockable

Protected Member Functions

 JBStreamSetProcessor (JBStreamSetList *owner)
 
virtual bool process (JBStream &stream)
 
- Protected Member Functions inherited from JBStreamSet
 JBStreamSet (JBStreamSetList *owner)
 

Additional Inherited Members

- Public Member Functions inherited from JBStreamSet
virtual ~JBStreamSet ()
 
ObjListclients ()
 
virtual bool add (JBStream *client)
 
virtual bool remove (JBStream *client, bool delObj=true)
 
unsigned int dropAll (const JabberID &local=JabberID::empty(), const JabberID &remote=JabberID::empty(), XMPPError::Type error=XMPPError::NoError, const char *reason=0)
 
void run ()
 
virtual bool start ()
 
virtual void stop ()
 
- Public Member Functions inherited from GenObject
 GenObject ()
 
virtual ~GenObject ()
 
virtual bool alive () const
 
virtual void destruct ()
 
virtual const StringtoString () const
 
virtual const StringtraceId () const
 
virtual void * getObject (const String &name) const
 
NamedCountergetObjCounter () const
 
NamedCountersetObjCounter (NamedCounter *counter)
 
- Public Member Functions inherited from Mutex
 Mutex (bool recursive=false, const char *name=0)
 
 Mutex (const Mutex &original)
 
 ~Mutex ()
 
Mutexoperator= (const Mutex &original)
 
virtual bool lock (long maxwait=-1)
 
virtual bool unlock ()
 
virtual bool locked () const
 
const char * owner () const
 
bool recursive () const
 
- Public Member Functions inherited from Lockable
virtual ~Lockable ()
 
virtual bool check (long maxwait=-1)
 
virtual bool unlockAll ()
 
- Static Public Member Functions inherited from GenObject
static void * getObject (const String &name, const GenObject *obj)
 
static bool getObjCounting ()
 
static void setObjCounting (bool enable)
 
static NamedCountergetObjCounter (const String &name, bool create=true)
 
static ObjListgetObjCounters ()
 
- Static Public Member Functions inherited from Mutex
static int count ()
 
static int locks ()
 
static bool efficientTimedLock ()
 
- Static Public Member Functions inherited from Lockable
static void wait (unsigned long maxwait)
 
static unsigned long wait ()
 
static void startUsingNow ()
 
static void enableSafety (bool safe=true)
 
static bool safety ()
 
- Protected Attributes inherited from JBStreamSet
bool m_changed
 
bool m_exiting
 
JBStreamSetListm_owner
 
ObjList m_clients
 

Detailed Description

Specialized stream processor.

This class holds a set specialized in stream processing

Constructor & Destructor Documentation

◆ JBStreamSetProcessor()

JBStreamSetProcessor ( JBStreamSetList * owner)
inlineprotected

Constructor

Parameters
ownerThe list owning this set

References JBStreamSet::JBStreamSet(), and Mutex::owner().

Member Function Documentation

◆ process()

virtual bool process ( JBStream & stream)
protectedvirtual

This method is called from run() with the list unlocked and stream's reference counter increased. Calls stream's getEvent(). Pass a generated event to the engine Remove the stream from its engine on destroy

Parameters
streamThe stream to process
Returns
True if an event was generated by the stream

Implements JBStreamSet.


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