/* Set of machines that have not received notification. */
Hashset<int64_t> *watchset;
+public:
RejectedMessage(Slot *slot, int64_t _sequencenum, int64_t _machineid, int64_t _oldseqnum, int64_t _newseqnum, bool _equalto) : Entry(slot),
sequencenum(_sequencenum),
machineid(_machineid),
bool getEqual() { return equalto; }
int64_t getMachineID() { return machineid; }
int64_t getSequenceNumber() { return sequencenum; }
- void setWatchSet(HashSet<int64_t> *_watchset) { watchset = _watchset; }
+ 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); }
};
Entry *RejectedMessage_decode(Slot *slot, ByteBuffer *bb);
-#ifndef
+#endif