SWC-DB  v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
SWC::Core::BufferStreamOut_ZSTD_OnAdd Class Reference

#include <swcdb/core/BufferStream.h>

+ Inheritance diagram for SWC::Core::BufferStreamOut_ZSTD_OnAdd:
+ Collaboration diagram for SWC::Core::BufferStreamOut_ZSTD_OnAdd:

Public Member Functions

 BufferStreamOut_ZSTD_OnAdd (int level=0, size_t pre_alloc=12582912, size_t commit_size=8388608)
 
 BufferStreamOut_ZSTD_OnAdd (BufferStreamOut_ZSTD_OnAdd &&)=delete
 
 BufferStreamOut_ZSTD_OnAdd (const BufferStreamOut_ZSTD_OnAdd &)=delete
 
BufferStreamOut_ZSTD_OnAddoperator= (const BufferStreamOut_ZSTD_OnAdd &)=delete
 
BufferStreamOut_ZSTD_OnAddoperator= (BufferStreamOut_ZSTD_OnAdd &&)=delete
 
virtual ~BufferStreamOut_ZSTD_OnAdd () noexcept
 
virtual bool SWC_PURE_FUNC empty () const override
 
virtual bool SWC_PURE_FUNC full () const override
 
virtual size_t SWC_PURE_FUNC available () override
 
virtual void add (const uint8_t *ptr, size_t len) override
 
virtual void get (StaticBuffer &output) override
 
- Public Member Functions inherited from SWC::Core::BufferStreamOut
SWC_CAN_INLINE BufferStreamOut (size_t a_pre_alloc=12582912, size_t a_commit_size=8388608) noexcept
 
 BufferStreamOut (BufferStreamOut &&)=delete
 
 BufferStreamOut (const BufferStreamOut &)=delete
 
BufferStreamOutoperator= (const BufferStreamOut &)=delete
 
BufferStreamOutoperator= (BufferStreamOut &&)=delete
 
virtual ~BufferStreamOut () noexcept
 

Private Attributes

ZSTD_CStream *const cstream
 
bool has_data
 
size_t plain_size
 
DynamicBuffer tmp_buff
 
ZSTD_outBuffer out_buff
 

Additional Inherited Members

- Public Attributes inherited from SWC::Core::BufferStreamOut
int error
 
- Protected Attributes inherited from SWC::Core::BufferStreamOut
size_t pre_alloc
 
size_t commit_size
 
DynamicBuffer buffer
 

Detailed Description

Definition at line 63 of file BufferStream.h.

Constructor & Destructor Documentation

◆ BufferStreamOut_ZSTD_OnAdd() [1/3]

SWC::Core::BufferStreamOut_ZSTD_OnAdd::BufferStreamOut_ZSTD_OnAdd ( int  level = 0,
size_t  pre_alloc = 12582912,
size_t  commit_size = 8388608 
)

◆ BufferStreamOut_ZSTD_OnAdd() [2/3]

SWC::Core::BufferStreamOut_ZSTD_OnAdd::BufferStreamOut_ZSTD_OnAdd ( BufferStreamOut_ZSTD_OnAdd &&  )
delete

◆ BufferStreamOut_ZSTD_OnAdd() [3/3]

SWC::Core::BufferStreamOut_ZSTD_OnAdd::BufferStreamOut_ZSTD_OnAdd ( const BufferStreamOut_ZSTD_OnAdd )
delete

◆ ~BufferStreamOut_ZSTD_OnAdd()

SWC::Core::BufferStreamOut_ZSTD_OnAdd::~BufferStreamOut_ZSTD_OnAdd ( )
virtualnoexcept

Definition at line 53 of file BufferStream.cc.

References cstream.

Member Function Documentation

◆ add()

void SWC::Core::BufferStreamOut_ZSTD_OnAdd::add ( const uint8_t *  ptr,
size_t  len 
)
overridevirtual

Reimplemented from SWC::Core::BufferStreamOut.

Definition at line 69 of file BufferStream.cc.

References SWC::Core::BufferStreamOut::add(), SWC::Core::Buffer< T >::base, cstream, SWC::Error::ENCODER_ENCODE, SWC::Core::BufferDyn< BufferT >::ensure(), SWC::Core::BufferStreamOut::error, has_data, out_buff, plain_size, SWC::Core::Buffer< T >::size, and tmp_buff.

+ Here is the call graph for this function:

◆ available()

size_t SWC::Core::BufferStreamOut_ZSTD_OnAdd::available ( )
overridevirtual

Reimplemented from SWC::Core::BufferStreamOut.

Definition at line 65 of file BufferStream.cc.

References SWC::Core::BufferStreamOut::available(), has_data, SWC::Core::Buffer< T >::size, and tmp_buff.

+ Here is the call graph for this function:

◆ empty()

bool SWC::Core::BufferStreamOut_ZSTD_OnAdd::empty ( ) const
overridevirtual

Reimplemented from SWC::Core::BufferStreamOut.

Definition at line 57 of file BufferStream.cc.

References SWC::Core::BufferStreamOut::empty(), and has_data.

+ Here is the call graph for this function:

◆ full()

bool SWC::Core::BufferStreamOut_ZSTD_OnAdd::full ( ) const
overridevirtual

Reimplemented from SWC::Core::BufferStreamOut.

Definition at line 61 of file BufferStream.cc.

References SWC::Core::BufferStreamOut::commit_size, and plain_size.

◆ get()

void SWC::Core::BufferStreamOut_ZSTD_OnAdd::get ( StaticBuffer output)
overridevirtual

Reimplemented from SWC::Core::BufferStreamOut.

Definition at line 98 of file BufferStream.cc.

References SWC::Core::BufferStreamOut::add(), SWC::Core::Buffer< T >::base, cstream, SWC::Error::ENCODER_ENCODE, SWC::Core::BufferDyn< BufferT >::ensure(), SWC::Core::BufferStreamOut::error, SWC::Core::BufferStreamOut::get(), has_data, out_buff, plain_size, SWC::Core::Buffer< T >::size, and tmp_buff.

+ Here is the call graph for this function:

◆ operator=() [1/2]

BufferStreamOut_ZSTD_OnAdd& SWC::Core::BufferStreamOut_ZSTD_OnAdd::operator= ( BufferStreamOut_ZSTD_OnAdd &&  )
delete

◆ operator=() [2/2]

BufferStreamOut_ZSTD_OnAdd& SWC::Core::BufferStreamOut_ZSTD_OnAdd::operator= ( const BufferStreamOut_ZSTD_OnAdd )
delete

Member Data Documentation

◆ cstream

ZSTD_CStream* const SWC::Core::BufferStreamOut_ZSTD_OnAdd::cstream
private

Definition at line 90 of file BufferStream.h.

Referenced by add(), BufferStreamOut_ZSTD_OnAdd(), get(), and ~BufferStreamOut_ZSTD_OnAdd().

◆ has_data

bool SWC::Core::BufferStreamOut_ZSTD_OnAdd::has_data
private

Definition at line 91 of file BufferStream.h.

Referenced by add(), available(), empty(), and get().

◆ out_buff

ZSTD_outBuffer SWC::Core::BufferStreamOut_ZSTD_OnAdd::out_buff
private

Definition at line 94 of file BufferStream.h.

Referenced by add(), and get().

◆ plain_size

size_t SWC::Core::BufferStreamOut_ZSTD_OnAdd::plain_size
private

Definition at line 92 of file BufferStream.h.

Referenced by add(), full(), and get().

◆ tmp_buff

DynamicBuffer SWC::Core::BufferStreamOut_ZSTD_OnAdd::tmp_buff
private

Definition at line 93 of file BufferStream.h.

Referenced by add(), available(), and get().


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