Equalizer
1.4.1
|
A std::istream-like input data stream for binary data. More...
#include <dataIStream.h>
Public Member Functions | |
virtual CO_API NodePtr | getMaster ()=0 |
Internal | |
CO_API | DataIStream () |
DataIStream (const DataIStream &) | |
virtual CO_API | ~DataIStream () |
virtual size_t | nRemainingBuffers () const =0 |
Get the number of remaining buffers. | |
virtual uint128_t | getVersion () const =0 |
virtual void | reset () |
Data input | |
template<typename T > | |
DataIStream & | operator>> (T &value) |
Read a plain data item. | |
template<typename T > | |
DataIStream & | operator>> (std::vector< T > &value) |
Read a std::vector of serializable items. | |
template<typename O , typename C > | |
void | deserializeChildren (O *object, const std::vector< C * > &old, std::vector< C * > &result) |
Deserialize child objects. | |
CO_API void | read (void *data, uint64_t size) |
Read a number of bytes from the stream into a buffer. | |
CO_API const void * | getRemainingBuffer () |
Get the pointer to the remaining data in the current buffer. | |
CO_API uint64_t | getRemainingBufferSize () |
Get the size of the remaining data in the current buffer. | |
CO_API void | advanceBuffer (const uint64_t offset) |
Advance the current buffer by a number of bytes. | |
bool | hasData () |
Specialized input operators | |
template<> | |
DataIStream & | operator>> (std::string &str) |
Read a std::string. | |
template<> | |
DataIStream & | operator>> (Object *&object) |
Deserialize an object (id+version). | |
template<> | |
DataIStream & | operator>> (std::vector< uint8_t > &value) |
Optimized specialization to read a std::vector of uint8_t. | |
template<> | |
DataIStream & | operator>> (std::vector< uint16_t > &value) |
Optimized specialization to read a std::vector of uint16_t. | |
template<> | |
DataIStream & | operator>> (std::vector< int16_t > &value) |
Optimized specialization to read a std::vector of int16_t. | |
template<> | |
DataIStream & | operator>> (std::vector< uint32_t > &value) |
Optimized specialization to read a std::vector of uint32_t. | |
template<> | |
DataIStream & | operator>> (std::vector< int32_t > &value) |
Optimized specialization to read a std::vector of int32_t. | |
template<> | |
DataIStream & | operator>> (std::vector< uint64_t > &value) |
Optimized specialization to read a std::vector of uint64_t. | |
template<> | |
DataIStream & | operator>> (std::vector< int64_t > &value) |
Optimized specialization to read a std::vector of int64_t. | |
template<> | |
DataIStream & | operator>> (std::vector< float > &value) |
Optimized specialization to read a std::vector of float. | |
template<> | |
DataIStream & | operator>> (std::vector< double > &value) |
Optimized specialization to read a std::vector of double. | |
template<> | |
DataIStream & | operator>> (std::vector< ObjectVersion > &value) |
Optimized specialization to read a std::vector of ObjectVersion. | |
Protected Member Functions | |
virtual bool | getNextBuffer (uint32_t *compressor, uint32_t *nChunks, const void **chunkData, uint64_t *size)=0 |
A std::istream-like input data stream for binary data.
Definition at line 34 of file dataIStream.h.
CO_API void co::DataIStream::advanceBuffer | ( | const uint64_t | offset | ) |
Advance the current buffer by a number of bytes.
Referenced by operator>>().
void co::DataIStream::deserializeChildren | ( | O * | object, |
const std::vector< C * > & | old, | ||
std::vector< C * > & | result | ||
) |
Deserialize child objects.
Existing children are synced to the new version. New children are created by calling the void create( C** child )
method on the object, and registered or mapped to the object's session. Removed children are released by calling the void release( C* )
method on the object. The resulting child vector is created in result. The old and result vector can be the same object, the result vector is cleared and rebuild completely.
virtual CO_API NodePtr co::DataIStream::getMaster | ( | ) | [pure virtual] |
Referenced by eqPly::VertexBufferDist::applyInstanceData().
CO_API const void* co::DataIStream::getRemainingBuffer | ( | ) |
Get the pointer to the remaining data in the current buffer.
The data written by the DataOStream on the other end is bucketized, that is, it is sent in multiple blocks. The remaining buffer and its size points into one of the buffers, that is, not all the data sent is returned by this function. However, a write operation on the other end is never segmented, that is, if the application writes n bytes to the DataOStream, a symmetric read from the DataIStream has at least n bytes available.
Referenced by operator>>().
CO_API uint64_t co::DataIStream::getRemainingBufferSize | ( | ) |
Get the size of the remaining data in the current buffer.
Referenced by operator>>().
bool co::DataIStream::hasData | ( | ) | [inline] |
Definition at line 108 of file dataIStream.h.
virtual size_t co::DataIStream::nRemainingBuffers | ( | ) | const [pure virtual] |
Get the number of remaining buffers.
DataIStream& co::DataIStream::operator>> | ( | T & | value | ) | [inline] |
Read a plain data item.
Definition at line 54 of file dataIStream.h.
References read().
DataIStream& co::DataIStream::operator>> | ( | std::vector< T > & | value | ) | [inline] |
Read a std::vector of serializable items.
Definition at line 59 of file dataIStream.h.
References read().
DataIStream & co::DataIStream::operator>> | ( | std::string & | str | ) | [inline] |
Read a std::string.
Definition at line 164 of file dataIStream.h.
References advanceBuffer(), getRemainingBuffer(), getRemainingBufferSize(), and read().
DataIStream & co::DataIStream::operator>> | ( | Object *& | object | ) | [inline] |
Deserialize an object (id+version).
Definition at line 182 of file dataIStream.h.
References co::Object::getID().
DataIStream & co::DataIStream::operator>> | ( | std::vector< uint8_t > & | value | ) | [inline] |
Optimized specialization to read a std::vector of uint8_t.
Definition at line 273 of file dataIStream.h.
DataIStream & co::DataIStream::operator>> | ( | std::vector< uint16_t > & | value | ) | [inline] |
Optimized specialization to read a std::vector of uint16_t.
Definition at line 278 of file dataIStream.h.
DataIStream & co::DataIStream::operator>> | ( | std::vector< int16_t > & | value | ) | [inline] |
Optimized specialization to read a std::vector of int16_t.
Definition at line 283 of file dataIStream.h.
DataIStream & co::DataIStream::operator>> | ( | std::vector< uint32_t > & | value | ) | [inline] |
Optimized specialization to read a std::vector of uint32_t.
Definition at line 288 of file dataIStream.h.
DataIStream & co::DataIStream::operator>> | ( | std::vector< int32_t > & | value | ) | [inline] |
Optimized specialization to read a std::vector of int32_t.
Definition at line 293 of file dataIStream.h.
DataIStream & co::DataIStream::operator>> | ( | std::vector< uint64_t > & | value | ) | [inline] |
Optimized specialization to read a std::vector of uint64_t.
Definition at line 298 of file dataIStream.h.
DataIStream & co::DataIStream::operator>> | ( | std::vector< int64_t > & | value | ) | [inline] |
Optimized specialization to read a std::vector of int64_t.
Definition at line 303 of file dataIStream.h.
DataIStream & co::DataIStream::operator>> | ( | std::vector< float > & | value | ) | [inline] |
Optimized specialization to read a std::vector of float.
Definition at line 308 of file dataIStream.h.
DataIStream & co::DataIStream::operator>> | ( | std::vector< double > & | value | ) | [inline] |
Optimized specialization to read a std::vector of double.
Definition at line 313 of file dataIStream.h.
DataIStream & co::DataIStream::operator>> | ( | std::vector< ObjectVersion > & | value | ) | [inline] |
Optimized specialization to read a std::vector of ObjectVersion.
Definition at line 318 of file dataIStream.h.
CO_API void co::DataIStream::read | ( | void * | data, |
uint64_t | size | ||
) |
Read a number of bytes from the stream into a buffer.
Referenced by eqNbody::SharedDataProxy::deserialize(), eqNbody::FrameData::deserialize(), and operator>>().