GComm
0.2.3
|
#include <evs_message2.hpp>
Public Member Functions | |
UserMessage (const int version=-1, const UUID &source=UUID::nil(), const ViewId &source_view_id=ViewId(), const seqno_t seq=-1, const seqno_t aru_seq=-1, const seqno_t seq_range=0, const Order order=O_SAFE, const int64_t fifo_seq=-1, const uint8_t user_type=0xff, const uint8_t flags=0) | |
void | set_aru_seq (const seqno_t as) |
size_t | serialize (gu::byte_t *buf, size_t buflen, size_t offset) const |
size_t | unserialize (const gu::byte_t *buf, size_t buflen, size_t offset, bool skip_header=false) |
size_t | serial_size () const |
![]() | |
uint8_t | version () const |
Type | type () const |
bool | is_membership () const |
uint8_t | user_type () const |
Order | order () const |
seqno_t | seq () const |
seqno_t | seq_range () const |
seqno_t | aru_seq () const |
uint8_t | flags () const |
void | set_source (const UUID &uuid) |
const UUID & | source () const |
const gcomm::ViewId & | source_view_id () const |
const gcomm::ViewId & | install_view_id () const |
const UUID & | range_uuid () const |
Range | range () const |
int64_t | fifo_seq () const |
const MessageNodeList & | node_list () const |
gu::datetime::Date | tstamp () const |
size_t | unserialize (const gu::byte_t *buf, size_t buflen, size_t offset) |
bool | operator== (const Message &cmp) const |
Message (const Message &msg) | |
Message & | operator= (const Message &msg) |
Message (const uint8_t version=0, const Type type=T_NONE, const UUID &source=UUID::nil(), const ViewId &source_view_id=ViewId(), const ViewId &install_view_id=ViewId(), const uint8_t user_type=0xff, const Order order=O_DROP, const int64_t fifo_seq=-1, const seqno_t seq=-1, const seqno_t seq_range=-1, const seqno_t aru_seq=-1, const uint8_t flags=0, const UUID &range_uuid=UUID(), const Range range=Range(), const MessageNodeList &node_list=MessageNodeList()) | |
Additional Inherited Members | |
![]() | |
enum | Type { T_NONE = 0, T_USER = 1, T_DELEGATE = 2, T_GAP = 3, T_JOIN = 4, T_INSTALL = 5, T_LEAVE = 6 } |
![]() | |
static const uint8_t | F_MSG_MORE = 0x1 |
static const uint8_t | F_RETRANS = 0x2 |
static const uint8_t | F_SOURCE = 0x4 |
Message source has been set explicitly via set_source() | |
static const uint8_t | F_AGGREGATE = 0x8 |
static const uint8_t | F_COMMIT = 0x10 |
static const uint8_t | F_BC = 0x20 |
![]() | |
size_t | serialize (gu::byte_t *buf, size_t buflen, size_t offset) const |
size_t | serial_size () const |
![]() | |
uint8_t | version_ |
Type | type_ |
uint8_t | user_type_ |
Order | order_ |
seqno_t | seq_ |
seqno_t | seq_range_ |
seqno_t | aru_seq_ |
int64_t | fifo_seq_ |
uint8_t | flags_ |
UUID | source_ |
ViewId | source_view_id_ |
ViewId | install_view_id_ |
UUID | range_uuid_ |
Range | range_ |
gu::datetime::Date | tstamp_ |
MessageNodeList | node_list_ |
User message class.