|
Collage
1.6.0
High-performance C++ library for developing object-oriented distributed applications.
|
|
Collage
1.6.0
High-performance C++ library for developing object-oriented distributed applications.
|
The item of the distributed queue holding the data. More...
#include <queueItem.h>
Inheritance diagram for co::QueueItem: Collaboration diagram for co::QueueItem:Public Member Functions | |
| CO_API | ~QueueItem () |
| Destruct this queue item. More... | |
| Public Member Functions inherited from co::DataOStream | |
| CO_API void | disable () |
| void | enableSave () |
| void | disableSave () |
| CO_API bool | hasSentData () const |
| CO_API const Connections & | getConnections () const |
| DataOStream & | streamDataHeader (DataOStream &os) |
| void | sendBody (ConnectionPtr connection, const void *data, const uint64_t dataSize) |
| uint64_t | getCompressedDataSize () const |
| template<class T > | |
| DataOStream & | operator<< (const T &value) |
| Write a plain data item by copying it to the stream. More... | |
| template<class T > | |
| DataOStream & | operator<< (const Array< T > array) |
| Write a C array. More... | |
| template<class T > | |
| DataOStream & | operator<< (const lunchbox::RefPtr< T > &ptr) |
| Write a lunchbox::RefPtr. More... | |
| template<class T > | |
| DataOStream & | operator<< (const lunchbox::Buffer< T > &buffer) |
| Write a lunchbox::Buffer. More... | |
| template<class T > | |
| DataOStream & | operator<< (const lunchbox::Request< T > &request) |
| Transmit a request identifier. More... | |
| template<class T > | |
| DataOStream & | operator<< (const std::vector< T > &value) |
| Write a std::vector of serializable items. More... | |
| template<class K , class V > | |
| DataOStream & | operator<< (const std::map< K, V > &value) |
| Write a std::map of serializable items. More... | |
| template<class T > | |
| DataOStream & | operator<< (const std::set< T > &value) |
| Write a std::set of serializable items. More... | |
| template<class K , class V > | |
| DataOStream & | operator<< (const stde::hash_map< K, V > &value) |
| Write a stde::hash_map of serializable items. More... | |
| template<class T > | |
| DataOStream & | operator<< (const stde::hash_set< T > &value) |
| Write a stde::hash_set of serializable items. More... | |
| template<typename C > | |
| void | serializeChildren (const std::vector< C * > &children) |
| template<> | |
| DataOStream & | operator<< (const std::string &str) |
| Write a std::string. More... | |
| template<> | |
| DataOStream & | operator<< (const Object *const &object) |
| Write an object identifier and version. More... | |
| template<> | |
| void | _writeArray (const Array< void > array, const boost::false_type &) |
| template<> | |
| DataOStream & | operator<< (const std::vector< uint8_t > &value) |
| Optimized specialization to write a std::vector of uint8_t. More... | |
| template<> | |
| DataOStream & | operator<< (const std::vector< uint16_t > &value) |
| Optimized specialization to write a std::vector of uint16_t. More... | |
| template<> | |
| DataOStream & | operator<< (const std::vector< int16_t > &value) |
| Optimized specialization to write a std::vector of int16_t. More... | |
| template<> | |
| DataOStream & | operator<< (const std::vector< uint32_t > &value) |
| Optimized specialization to write a std::vector of uint32_t. More... | |
| template<> | |
| DataOStream & | operator<< (const std::vector< int32_t > &value) |
| Optimized specialization to write a std::vector of int32_t. More... | |
| template<> | |
| DataOStream & | operator<< (const std::vector< uint64_t > &value) |
| Optimized specialization to write a std::vector of uint64_t. More... | |
| template<> | |
| DataOStream & | operator<< (const std::vector< int64_t > &value) |
| Optimized specialization to write a std::vector of int64_t. More... | |
| template<> | |
| DataOStream & | operator<< (const std::vector< float > &value) |
| Optimized specialization to write a std::vector of float. More... | |
| template<> | |
| DataOStream & | operator<< (const std::vector< double > &value) |
| Optimized specialization to write a std::vector of double. More... | |
| template<> | |
| DataOStream & | operator<< (const std::vector< ObjectVersion > &value) |
| Optimized specialization to write a std::vector of ObjectVersion. More... | |
Friends | |
| class | QueueMaster |
Additional Inherited Members | |
| Static Public Member Functions inherited from co::DataOStream | |
| static CO_API std::ostream & | printStatistics (std::ostream &) |
| static CO_API void | clearStatistics () |
| Protected Member Functions inherited from co::DataOStream | |
| DataOStream (DataOStream &rhs) | |
| CO_API lunchbox::Bufferb & | getBuffer () |
| void | _setCompressor (const pression::data::CompressorInfo &info) |
| CO_API void | _enable () |
| void | flush (const bool last) |
| void | _setupConnections (const Nodes &receivers) |
| void | _setupConnections (const Connections &connections) |
| void | _setupConnection (NodePtr node, const bool useMulticast) |
| CO_API void | _setupConnection (ConnectionPtr connection) |
| void | _resend () |
| void | _clearConnections () |
| virtual CO_API void | reset () |
The item of the distributed queue holding the data.
Each enqueued item generated by QueueMaster::push() can be enhanced with additional data in a stream-like manner. On the consumer side, the data can be retrieved via the ObjectICommand.
Definition at line 37 of file queueItem.h.
| CO_API co::QueueItem::~QueueItem | ( | ) |
Destruct this queue item.
1.8.11 
