A sink for messages to be sent by the process. More...
#include <message.hh>
Public Types | |
using | octree_traits = OctreeTraits |
using | morton_type = typename octree_traits::morton_type |
using | source_type = std::variant< global_state, worker_id > |
using | destination_type = std::variant< global_state, worker_id, all_workers, topic_list, closest_worker< morton_type > > |
Public Member Functions | |
writer (const writer &)=delete | |
writer (writer_type &_writer, const source_type &_default_source) | |
void | set_source (const source_type &source) |
Called internally by Aether. More... | |
void | set_destination (const destination_type dest) |
Set the destination of the message. More... | |
void | push_bytes (const void *data, size_t len) |
Sets the binary payload to be sent. More... | |
int | send () |
Sends the binary payload. More... | |
writer_type & | get_internal_writer () |
A sink for messages to be sent by the process.
OctreeTraits | |
W | - a binary writer implementation |
using aether::message::writer< OctreeTraits, W >::destination_type = std::variant< global_state, worker_id, all_workers, topic_list, closest_worker<morton_type> > |
using aether::message::writer< OctreeTraits, W >::morton_type = typename octree_traits::morton_type |
using aether::message::writer< OctreeTraits, W >::octree_traits = OctreeTraits |
using aether::message::writer< OctreeTraits, W >::source_type = std::variant<global_state, worker_id> |
|
delete |
aether::message::writer< OctreeTraits, W >::writer | ( | writer_type & | _writer, |
const source_type & | _default_source | ||
) |
writer_type& aether::message::writer< OctreeTraits, W >::get_internal_writer | ( | ) |
void aether::message::writer< OctreeTraits, W >::push_bytes | ( | const void * | data, |
size_t | len | ||
) |
Sets the binary payload to be sent.
int aether::message::writer< OctreeTraits, W >::send | ( | ) |
Sends the binary payload.
void aether::message::writer< OctreeTraits, W >::set_destination | ( | const destination_type | dest | ) |
Set the destination of the message.
void aether::message::writer< OctreeTraits, W >::set_source | ( | const source_type & | source | ) |
Called internally by Aether.
Set the source of the message.