class RejectedMessage extends Entry {
private long machineid;
- private long seqnum;
+ private long oldseqnum;
+ private long newseqnum;
private boolean equalto;
- RejectedMessage(long _machineid, long _seqnum, boolean _equalto) {
+ RejectedMessage(long _machineid, long _oldseqnum, long _newseqnum, boolean _equalto) {
machineid=_machineid;
- seqnum=_seqnum;
+ oldseqnum=_oldseqnum;
+ newseqnum=_newseqnum;
equalto=_equalto;
}
static Entry decode(ByteBuffer bb) {
long machineid=bb.getLong();
- long seqnum=bb.getLong();
+ long oldseqnum=bb.getLong();
+ long newseqnum=bb.getLong();
byte equalto=bb.get();
- return new RejectedMessage(machineid, seqnum, equalto==1);
+ return new RejectedMessage(machineid, oldseqnum, newseqnum, equalto==1);
}
void encode(ByteBuffer bb) {
bb.put(Entry.TypeRejectedMessage);
bb.putLong(machineid);
- bb.putLong(seqnum);
+ bb.putLong(oldseqnum);
+ bb.putLong(newseqnum);
bb.put(equalto?(byte)1:(byte)0);
}
int getSize() {
- return 2*Long.BYTES + 2*Byte.BYTES;
+ return 3*Long.BYTES + 2*Byte.BYTES;
}
}