Public Member Functions | |
CSortedBufferProcessor (JetByteTools::Core::ILockableObject &lock) | |
CSortedBufferProcessor (JetByteTools::Core::ILockableObject &lock, const IBuffer::SequenceNumber sequenceNumber) | |
CSortedBufferProcessor (JetByteTools::Core::ILockableObject &lock, const JetByteTools::Core::IIndexedOpaqueUserData::UserDataIndex nextBufferIndex, const IBuffer::SequenceNumber sequenceNumber=0) | |
CSortedBufferProcessor (const CSortedBufferProcessor &rhs) | |
CSortedBufferProcessor & | operator= (const CSortedBufferProcessor &rhs) |
void | SetInitialSequenceNumber (const IBuffer::SequenceNumber sequenceNumber) |
IBuffer::SequenceNumber | GetNextSequenceNumber () const |
void | Reset () |
bool | CanGetNext () const |
void | ProcessBuffer () override |
CSmartBuffer | ProcessAndGetNext (CSmartBuffer &buffer) override |
CSmartBuffer | ProcessAndGetNext () override |
void | AllowProcessingTransfer () override |
bool | CanStoreNulls () const override |
bool | IsEmpty () const override |
size_t | Size () const override |
size_t | TotalBytes () const override |
size_t | AvailableSpace () const override |
bool | HasAvailableSpace () const override |
void | GetTotalBytesAndAvailableSpace (size_t &totalBytes, size_t &availableSpace) const override |
size_t | Purge () override |
size_t | Purge (IHandlePurgedBufferRelease &purgeHandler, UserData userData) override |
void | Add (CSmartBuffer &buffer) override |
CSmartBuffer | GetNext (CSmartBuffer &buffer) override |
CSmartBuffer | GetNext () override |
bool | TryAdd (CSmartBuffer &buffer) override |
CSmartBuffer | TryGetNext (CSmartBuffer &buffer, bool &inserted) override |
CSortedBufferProcessor | ( | JetByteTools::Core::ILockableObject & | lock | ) | [inline, explicit] |
CSortedBufferProcessor | ( | JetByteTools::Core::ILockableObject & | lock, | |
const IBuffer::SequenceNumber | sequenceNumber | |||
) | [inline, explicit] |
CSortedBufferProcessor | ( | JetByteTools::Core::ILockableObject & | lock, | |
const JetByteTools::Core::IIndexedOpaqueUserData::UserDataIndex | nextBufferIndex, | |||
const IBuffer::SequenceNumber | sequenceNumber = 0 | |||
) | [inline] |
CSortedBufferProcessor | ( | const CSortedBufferProcessor & | rhs | ) |
CSortedBufferProcessor& operator= | ( | const CSortedBufferProcessor & | rhs | ) |
void SetInitialSequenceNumber | ( | const IBuffer::SequenceNumber | sequenceNumber | ) | [inline] |
IBuffer::SequenceNumber GetNextSequenceNumber | ( | ) | const [inline] |
void Reset | ( | ) | [inline] |
bool CanGetNext | ( | ) | const [inline] |
void ProcessBuffer | ( | ) | [override, virtual, inherited] |
Implements IBufferProcessor.
CSmartBuffer ProcessAndGetNext | ( | CSmartBuffer & | buffer | ) | [override, virtual, inherited] |
Implements IBufferProcessor.
CSmartBuffer ProcessAndGetNext | ( | ) | [override, virtual, inherited] |
Implements IBufferProcessor.
void AllowProcessingTransfer | ( | ) | [override, virtual, inherited] |
Implements IBufferProcessor.
bool CanStoreNulls | ( | ) | const [override, inherited] |
bool IsEmpty | ( | ) | const [override, inherited] |
size_t Size | ( | ) | const [override, inherited] |
size_t TotalBytes | ( | ) | const [override, inherited] |
size_t AvailableSpace | ( | ) | const [override, inherited] |
bool HasAvailableSpace | ( | ) | const [override, inherited] |
void GetTotalBytesAndAvailableSpace | ( | size_t & | totalBytes, | |
size_t & | availableSpace | |||
) | const [override, inherited] |
size_t Purge | ( | ) | [override, inherited] |
size_t Purge | ( | IHandlePurgedBufferRelease & | purgeHandler, | |
UserData | userData | |||
) | [override, inherited] |
void Add | ( | CSmartBuffer & | buffer | ) | [override, inherited] |
CSmartBuffer GetNext | ( | CSmartBuffer & | buffer | ) | [override, inherited] |
CSmartBuffer GetNext | ( | ) | [override, inherited] |
bool TryAdd | ( | CSmartBuffer & | buffer | ) | [override, inherited] |
CSmartBuffer TryGetNext | ( | CSmartBuffer & | buffer, | |
bool & | inserted | |||
) | [override, inherited] |