public static class GMS.GmsHeader extends Header
Modifier and Type | Field and Description |
---|---|
static byte |
CANCEL_MERGE |
static byte |
GET_CURRENT_VIEW |
static byte |
GET_DIGEST_REQ |
static byte |
GET_DIGEST_RSP |
static byte |
INSTALL_DIGEST |
static byte |
INSTALL_MERGE_VIEW |
static byte |
INSTALL_MERGE_VIEW_OK |
static byte |
JOIN_REQ |
static byte |
JOIN_REQ_WITH_STATE_TRANSFER |
static byte |
JOIN_RSP |
static byte |
LEAVE_REQ |
static byte |
LEAVE_RSP |
protected Address |
mbr |
protected MergeId |
merge_id |
static short |
MERGE_ID_PRESENT |
protected boolean |
merge_rejected |
static short |
MERGE_REJECTED |
static byte |
MERGE_REQ |
static byte |
MERGE_RSP |
protected byte |
type |
static short |
USE_FLUSH |
protected boolean |
useFlushIfPresent |
static byte |
VIEW |
static byte |
VIEW_ACK |
Constructor and Description |
---|
GmsHeader() |
GmsHeader(byte type) |
GmsHeader(byte type,
Address mbr) |
GmsHeader(byte type,
Address mbr,
boolean useFlushIfPresent)
Used for JOIN_REQ or LEAVE_REQ header
|
Modifier and Type | Method and Description |
---|---|
Supplier<? extends Header> |
create()
Creates an instance of the class implementing this interface
|
protected short |
determineFlags() |
short |
getMagicId()
Returns the magic-ID.
|
Address |
getMember() |
MergeId |
getMergeId() |
byte |
getType() |
boolean |
isMergeRejected() |
GMS.GmsHeader |
mbr(Address mbr) |
GMS.GmsHeader |
mergeId(MergeId merge_id) |
GMS.GmsHeader |
mergeRejected(boolean flag) |
void |
readFrom(DataInput in)
Read the state of the current object (including superclasses) from instream
Note that the input stream must not be closed
|
int |
serializedSize()
Returns the size (in bytes) of the marshalled object
|
void |
setMergeId(MergeId merge_id) |
GMS.GmsHeader |
setMergeRejected(boolean merge_rejected) |
String |
toString() |
static String |
type2String(int type) |
void |
writeTo(DataOutput out)
Write the entire state of the current object (including superclasses) to outstream.
|
public static final byte JOIN_REQ
public static final byte JOIN_RSP
public static final byte LEAVE_REQ
public static final byte LEAVE_RSP
public static final byte VIEW
public static final byte MERGE_REQ
public static final byte MERGE_RSP
public static final byte INSTALL_MERGE_VIEW
public static final byte CANCEL_MERGE
public static final byte VIEW_ACK
public static final byte JOIN_REQ_WITH_STATE_TRANSFER
public static final byte INSTALL_MERGE_VIEW_OK
public static final byte GET_DIGEST_REQ
public static final byte GET_DIGEST_RSP
public static final byte INSTALL_DIGEST
public static final byte GET_CURRENT_VIEW
public static final short MERGE_ID_PRESENT
public static final short USE_FLUSH
public static final short MERGE_REJECTED
protected byte type
protected Address mbr
protected MergeId merge_id
protected boolean useFlushIfPresent
protected boolean merge_rejected
public GmsHeader()
public GmsHeader(byte type)
public GmsHeader(byte type, Address mbr, boolean useFlushIfPresent)
public GmsHeader(byte type, Address mbr)
public short getMagicId()
Header
getMagicId
in class Header
public byte getType()
public GMS.GmsHeader mbr(Address mbr)
public GMS.GmsHeader mergeId(MergeId merge_id)
public GMS.GmsHeader mergeRejected(boolean flag)
public Address getMember()
public MergeId getMergeId()
public void setMergeId(MergeId merge_id)
public boolean isMergeRejected()
public GMS.GmsHeader setMergeRejected(boolean merge_rejected)
public Supplier<? extends Header> create()
Constructable
public void writeTo(DataOutput out) throws Exception
Streamable
Exception
public void readFrom(DataInput in) throws Exception
Streamable
Exception
public int serializedSize()
SizeStreamable
protected short determineFlags()
public static String type2String(int type)
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.