|
Collage
1.7.0
High-performance C++ library for developing object-oriented distributed applications.
|
|
Collage
1.7.0
High-performance C++ library for developing object-oriented distributed applications.
|
A class for sending commands with data to local and external nodes. More...
#include <oCommand.h>
Inheritance diagram for co::OCommand: Collaboration diagram for co::OCommand:Public Member Functions | |
| CO_API | OCommand (const Connections &receivers, const uint32_t cmd, const uint32_t type=COMMANDTYPE_NODE) |
| CO_API | OCommand (Dispatcher *const dispatcher, LocalNodePtr localNode, const uint32_t cmd, const uint32_t type=COMMANDTYPE_NODE) |
| CO_API | OCommand (const OCommand &rhs) |
| virtual CO_API | ~OCommand () |
| Send or dispatch this command during destruction. More... | |
| CO_API void | sendHeader (const uint64_t additionalSize) |
| 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 std::unordered_map< K, V > &value) |
| Write an unordered_map of serializable items. More... | |
| template<class T > | |
| DataOStream & | operator<< (const std::unordered_set< T > &value) |
| Write an unordered_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... | |
Static Public Member Functions | |
| static CO_API size_t | getSize () |
| Static Public Member Functions inherited from co::DataOStream | |
| static CO_API std::ostream & | printStatistics (std::ostream &) |
| static CO_API void | clearStatistics () |
Protected Member Functions | |
| CO_API void | sendData (const void *buffer, const uint64_t size, const bool last) override |
| Protected Member Functions inherited from co::DataOStream | |
| CO_API | DataOStream (size_t chunkSize=Global::getObjectBufferSize()) |
| 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 () |
A class for sending commands with data to local and external nodes.
The data to this command is added via the interface provided by DataOStream. The command is send or dispatched after it goes out of scope, i.e. during destruction.
Definition at line 41 of file oCommand.h.
|
virtual |
Send or dispatch this command during destruction.
1.8.11 
