|
Yate
|
Specialized stream processor. More...
#include <yatejabber.h>
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 () |
| ObjList & | clients () |
| 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 String & | toString () const |
| virtual const String & | traceId () const |
| virtual void * | getObject (const String &name) const |
| NamedCounter * | getObjCounter () const |
| NamedCounter * | setObjCounter (NamedCounter *counter) |
Public Member Functions inherited from Mutex | |
| Mutex (bool recursive=false, const char *name=0) | |
| Mutex (const Mutex &original) | |
| ~Mutex () | |
| Mutex & | operator= (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 NamedCounter * | getObjCounter (const String &name, bool create=true) |
| static ObjList & | getObjCounters () |
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 |
| JBStreamSetList * | m_owner |
| ObjList | m_clients |
Specialized stream processor.
This class holds a set specialized in stream processing
|
inlineprotected |
Constructor
| owner | The list owning this set |
References JBStreamSet::JBStreamSet(), and Mutex::owner().
|
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
| stream | The stream to process |
Implements JBStreamSet.