|
| virtual void | set_message_observer (IMessageObserver &observer) noexcept=0 |
| | Set the message observer. More...
|
| |
| virtual void | on_locator_discovered (const protocol::GUID &guid, bool is_metatraffic, const transport::Locator &locator, const protocol::GUIDPrefix &discoverer) noexcept=0 |
| | callback on new locator discovered. More...
|
| |
| virtual void | on_group_discovered (const protocol::EndpointGroup &group, bool is_metatraffic, const transport::Locator &locator, const protocol::GUIDPrefix &discoverer) noexcept=0 |
| | callback on new group discovered. More...
|
| |
| virtual void | on_locators_unregistered (const protocol::GUID &guid, const protocol::GUIDPrefix &discoverer) noexcept=0 |
| | callback on locator not required anymore. More...
|
| |
| virtual void | on_group_unregistered (const protocol::EndpointGroup &group, const protocol::GUIDPrefix &discoverer) noexcept=0 |
| | callback on group not required anymore. More...
|
| |
| virtual ReturnCode | listen_message (memory::IMutableByteArrayView &message, transport::Locator &reception_locator, const execution::TimePoint &timepoint) noexcept=0 |
| | Receive message. More...
|
| |
| virtual ReturnCode | listen_on_locator (const transport::Locator &reception_locator) noexcept=0 |
| | Prepare transport to listen on a locator. More...
|
| |
| virtual transport::Locator | listen_on_first_available_locator (const transport::Locator &hint) noexcept=0 |
| | Prepare transport to listen on the first available locator. More...
|
| |
| virtual bool | wait_until_message_available (const execution::TimePoint &timepoint) const noexcept=0 |
| | Wait until the transport has a message available for processing. More...
|
| |
| virtual void | spin (const TimePoint &timepoint) noexcept=0 |
| | Secuential synchronization interface. More...
|
| |
| virtual bool | has_pending_work () const noexcept=0 |
| | Check if the entity has pending work. More...
|
| |
| virtual TimePoint | get_next_work_timepoint () const noexcept=0 |
| | Get next work timepoint. More...
|
| |
| virtual void | commit_message (memory::IList< MessageElement > &view_list, const GUID &origin_guid, const GUID &receiver_guid, const execution::TimePoint &timepoint) noexcept=0 |
| | Commit message to the wire protocol message sink. More...
|
| |
| virtual void | commit_message_to_group (memory::IList< MessageElement > &view_list, const GUID &origin_guid, const protocol::EndpointGroup &group, const execution::TimePoint &timepoint) noexcept=0 |
| | Commit message to a group of wire protocol message sinks. More...
|
| |
| virtual uint32_t | get_message_max_size () const noexcept=0 |
| | Returns the maximum transfer unit of the wire protocol message sink. More...
|
| |