#include "Entry.h"
class RejectedMessage : public Entry {
- private:
+private:
/* Sequence number */
int64_t sequencenum;
/* Machine identifier */
* equal to) the specified machine identifier. */
bool equalto;
/* Set of machines that have not received notification. */
- Hashset<int64_t> * watchset;
-
- RejectedMessage(Slot * slot, int64_t _sequencenum, int64_t _machineid, int64_t _oldseqnum, int64_t _newseqnum, bool _equalto) : Entry(slot),
+ Hashset<int64_t> *watchset;
+
+ RejectedMessage(Slot *slot, int64_t _sequencenum, int64_t _machineid, int64_t _oldseqnum, int64_t _newseqnum, bool _equalto) : Entry(slot),
sequencenum(_sequencenum),
machineid(_machineid),
oldseqnum(_oldseqnum),
newseqnum(_newseqnum),
equalto(_equalto) {
- }
+ }
int64_t getOldSeqNum() { return oldseqnum; }
int64_t getNewSeqNum() { return newseqnum; }
bool getEqual() { return equalto; }
int64_t getMachineID() { return machineid; }
- int64_t getSequenceNumber() { return sequencenum; }
- void setWatchSet(HashSet<int64_t> * _watchset) { watchset=_watchset; }
+ int64_t getSequenceNumber() { return sequencenum; }
+ void setWatchSet(HashSet<int64_t> *_watchset) { watchset = _watchset; }
void removeWatcher(int64_t machineid);
- void encode(ByteBuffer * bb);
- int getSize() { return 4*sizeof(int64_t) + 2*sizeof(char); }
+ void encode(ByteBuffer *bb);
+ int getSize() { return 4 * sizeof(int64_t) + 2 * sizeof(char); }
char getType() { return TypeRejectedMessage; }
- Entry * getCopy(Slot * s) {
+ Entry *getCopy(Slot *s) {
return new RejectedMessage(s,sequencenum, machineid, oldseqnum, newseqnum, equalto);
}
};
-Entry * RejectedMessage_decode(Slot * slot, ByteBuffer * bb);
+Entry *RejectedMessage_decode(Slot *slot, ByteBuffer *bb);
#ifndef