|
_DoItDone
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
_dst
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
_inputAvailable
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
_inputFinished
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
_outputAvailable
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
_returnErrorVar
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
_seg_count
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
_seg_pos
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
_src
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
_thread
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
AppendStream
(const Block< const SRCTYPE > &src, WritableArrayInterface< DSTTYPE > &dst, Bool inputFinished)
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
|
|
CollectorThread
class
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
friend
|
|
DoIt
()=0
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
protected
pure virtual
|
|
EndOfStreamReached
()
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
|
|
GetCurrentPosition
()
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
|
|
GetDst
()
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
|
|
读取
(SRCTYPE *buf, Int count)
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
|
|
ReadEOS
(SRCTYPE *buf, Int maxCount)
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
|
|
SignalCollectorThreadToContinue
()
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
SignalEmitterThreadToContinue
()
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
private
|
|
Skip
(Int count)
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
|
|
Write
(DSTTYPE *buf, Int count)
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
|
|
WriteWithOffset
(DSTTYPE *buf, Int count, Int offset)
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
|
|
~StreamConversionHelper
()
|
StreamConversionHelper< SRCTYPE, DSTTYPE >
|
protected
virtual
|
