OMQ::AbstractParallelStream Member List

This is the complete list of members for OMQ::AbstractParallelStream, including all inherited members.

abortIo(string reason)	OMQ::AbstractParallelStream	private
abortIoWait(string reason)	OMQ::AbstractParallelStream	private
beginTransaction(OMQ::DbStreamConfig m_config)	OMQ::AbstractParallelStream	private
beginTransaction(QorusSystemRestHelper remote, string datasource, *timeout timeout_ms, *reference info)	OMQ::AbstractParallelStream	static
checkError(string cmd)	OMQ::AbstractParallelStream	private
checkStream(QorusSystemRestHelper helper, string op)	OMQ::AbstractParallelStream	static
cleanup()	Qore::Thread::AbstractThreadResource	pure virtual
cleanupBase()	OMQ::AbstractParallelStream
cnt()	OMQ::AbstractParallelStream	private
commit(OMQ::DbStreamConfig m_config)	OMQ::AbstractParallelStream	private
config()	OMQ::AbstractParallelStream	pure virtual
constructor()	Qore::Thread::AbstractThreadResource
dataq	OMQ::AbstractParallelStream	private
destructor()	OMQ::AbstractParallelStream
DO_DISCONNECT	OMQ::AbstractParallelStream
DONT_DISCONNECT	OMQ::AbstractParallelStream
getInfo()	OMQ::AbstractParallelStream
inTransaction()	OMQ::AbstractParallelStream
m_info()	OMQ::AbstractParallelStream	private
markIoComplete()	OMQ::AbstractParallelStream	private
markIoInProgress()	OMQ::AbstractParallelStream	private
objid	OMQ::AbstractParallelStream	private
rollback(OMQ::DbStreamConfig m_config)	OMQ::AbstractParallelStream	private
socketThread(*ThreadLocalData my_tld)	OMQ::AbstractParallelStream	private
socketThreadImpl()	OMQ::AbstractParallelStream	pure virtual
startStream()	OMQ::AbstractParallelStream	private
startStreamImpl()	OMQ::AbstractParallelStream	pure virtual
staticCleanup()	OMQ::AbstractParallelStream	static
StreamTerminatedError	OMQ::AbstractParallelStream	private
thread_ex	OMQ::AbstractParallelStream	private
ThreadKey	OMQ::AbstractParallelStream	private
waitIoComplete()	OMQ::AbstractParallelStream	private