class RejectedMessage extends Entry {
private long machineid;
- private long oldseqnum;//Oldest seqnum in range
- private long newseqnum;//Newest seqnum in range (inclusive)
- private boolean equalto;//Is message sent or not sent by machineid
+ private long oldseqnum; //Oldest seqnum in range
+ private long newseqnum; //Newest seqnum in range (inclusive)
+ private boolean equalto; //Is message sent or not sent by machineid
RejectedMessage(Slot slot, long _machineid, long _oldseqnum, long _newseqnum, boolean _equalto) {
super(slot);
long getMachineID() {
return machineid;
}
-
+
static Entry decode(Slot slot, ByteBuffer bb) {
long machineid=bb.getLong();
long oldseqnum=bb.getLong();
byte equalto=bb.get();
return new RejectedMessage(slot, machineid, oldseqnum, newseqnum, equalto==1);
}
-
+
void encode(ByteBuffer bb) {
bb.put(Entry.TypeRejectedMessage);
bb.putLong(machineid);
bb.putLong(newseqnum);
bb.put(equalto?(byte)1:(byte)0);
}
-
+
int getSize() {
return 3*Long.BYTES + 2*Byte.BYTES;
}