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 short |
JOIN_RSP_PRESENT |
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 |
---|---|
protected short |
determineFlags() |
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(java.io.DataInput in)
Read the state of the current object (including superclasses) from instream
Note that the input stream must not be closed
|
void |
setMergeId(MergeId merge_id) |
void |
setMergeRejected(boolean merge_rejected) |
int |
size()
To be implemented by subclasses.
|
java.lang.String |
toString() |
static java.lang.String |
type2String(int type) |
void |
writeTo(java.io.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 JOIN_RSP_PRESENT
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 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 void setMergeRejected(boolean merge_rejected)
public void writeTo(java.io.DataOutput out) throws java.lang.Exception
Streamable
java.lang.Exception
public void readFrom(java.io.DataInput in) throws java.lang.Exception
Streamable
java.lang.Exception
public int size()
Header
protected short determineFlags()
public static java.lang.String type2String(int type)
Copyright © 1998-2020 Red Hat. All Rights Reserved.