#include <evs_message2.hpp>
|
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()) |
|
|
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_ |
|
Enumerator |
---|
T_USER |
User generated message
|
T_DELEGATE |
Delegate message
|
T_GAP |
Gap message
|
T_JOIN |
Join message
|
T_INSTALL |
Install message
|
T_LEAVE |
Leave message
|
gcomm::evs::Message::Message |
( |
const Message & |
msg | ) |
|
|
inline |
gcomm::evs::Message::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() |
|
) |
| |
|
inline |
seqno_t gcomm::evs::Message::aru_seq |
( |
| ) |
const |
|
inline |
Get all-received-upto sequence number associated the the message.
- Returns
- All-received-upto sequence number associated to the message.
int64_t gcomm::evs::Message::fifo_seq |
( |
| ) |
const |
|
inline |
Get fifo sequence number associated to the message. This is applicable only for messages of membership type.
- Returns
- Fifo sequence number associated to the message.
uint8_t gcomm::evs::Message::flags |
( |
| ) |
const |
|
inline |
Get message flags.
- Returns
- Message flags.
bool gcomm::evs::Message::is_membership |
( |
| ) |
const |
|
inline |
Check wheter message is of membership type
- Returns
- True if message is of membership type, otherwise false
References T_INSTALL, T_JOIN, and T_LEAVE.
Get message node list.
- Returns
- Const reference to message node list.
Order gcomm::evs::Message::order |
( |
| ) |
const |
|
inline |
Get message order type.
- Returns
- Order type of the message.
Range gcomm::evs::Message::range |
( |
| ) |
const |
|
inline |
Get range associated to the message.
- Returns
- Range associated to the message.
const UUID& gcomm::evs::Message::range_uuid |
( |
| ) |
const |
|
inline |
Get range UUID associated to the message.
- Returns
- Range UUID associated to the message.
seqno_t gcomm::evs::Message::seq |
( |
| ) |
const |
|
inline |
Get sequence number associated to the message.
- Returns
- Const reference to sequence number associated to the message.
seqno_t gcomm::evs::Message::seq_range |
( |
| ) |
const |
|
inline |
Get sequence numer range associated to the message.
- Returns
- Sequence number range associated to the message.
void gcomm::evs::Message::set_source |
( |
const UUID & |
uuid | ) |
|
|
inline |
Set message source
- Parameters
-
References F_SOURCE.
const UUID& gcomm::evs::Message::source |
( |
| ) |
const |
|
inline |
const gcomm::ViewId& gcomm::evs::Message::source_view_id |
( |
| ) |
const |
|
inline |
Get message source view id, view where the message was originated from.
- Returns
- Message source view id.
gu::datetime::Date gcomm::evs::Message::tstamp |
( |
| ) |
const |
|
inline |
Get timestamp associated to the message.
Type gcomm::evs::Message::type |
( |
| ) |
const |
|
inline |
Get type of the message
- Returns
- Message type
uint8_t gcomm::evs::Message::user_type |
( |
| ) |
const |
|
inline |
Get user type of the message. This is applicable only for messages of type T_USER.
- Returns
- User type of the message.
uint8_t gcomm::evs::Message::version |
( |
| ) |
const |
|
inline |
Get version of the message
- Returns
- Version number
const uint8_t gcomm::evs::Message::F_AGGREGATE = 0x8 |
|
static |
Message contains aggregated payload
const uint8_t gcomm::evs::Message::F_BC = 0x20 |
|
static |
Message was sent in backward compatibility mode
const uint8_t gcomm::evs::Message::F_MSG_MORE = 0x1 |
|
static |
Sender has more messages to send
const uint8_t gcomm::evs::Message::F_RETRANS = 0x2 |
|
static |
The documentation for this class was generated from the following file:
- /wrkdirs/usr/ports/databases/galera/work/galera-25.3.5-src/gcomm/src/evs_message2.hpp