public static class GMS.GmsHeader extends Header
Modifier and Type | Field and Description |
---|---|
static byte |
CANCEL_MERGE |
static short |
DELTA_VIEW |
protected Digest |
digest |
static short |
DIGEST_PRESENT |
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 |
protected JoinRsp |
join_rsp |
static byte |
JOIN_RSP |
static short |
JOIN_RSP_PRESENT |
static byte |
LEAVE_REQ |
static byte |
LEAVE_RSP |
protected Address |
mbr |
protected Collection<? extends Address> |
mbrs |
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 |
static short |
MERGE_VIEW |
static short |
READ_ADDRS |
protected byte |
type |
static short |
USE_FLUSH |
protected boolean |
useFlushIfPresent |
protected View |
view |
static byte |
VIEW |
static byte |
VIEW_ACK |
static short |
VIEW_PRESENT |
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
|
GmsHeader(byte type,
Collection<Address> mbrs) |
GmsHeader(byte type,
JoinRsp join_rsp)
Used for JOIN_RSP header
|
GmsHeader(byte type,
View view,
Digest digest) |
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(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.
|
String |
toString() |
static String |
type2String(int type) |
protected boolean |
writeAddresses() |
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 short VIEW_PRESENT
public static final short JOIN_RSP_PRESENT
public static final short DIGEST_PRESENT
public static final short MERGE_ID_PRESENT
public static final short USE_FLUSH
public static final short MERGE_REJECTED
public static final short MERGE_VIEW
public static final short DELTA_VIEW
public static final short READ_ADDRS
protected byte type
protected View view
protected Address mbr
protected Collection<? extends Address> mbrs
protected JoinRsp join_rsp
protected Digest digest
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 GmsHeader(byte type, Collection<Address> mbrs)
public GmsHeader(byte type, JoinRsp join_rsp)
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(DataOutput out) throws Exception
Streamable
Exception
public void readFrom(DataInput in) throws Exception
Streamable
Exception
public int size()
Header
protected short determineFlags()
public static String type2String(int type)
protected boolean writeAddresses()
Copyright © 2014 JBoss, a division of Red Hat. All rights reserved.