Bug fixes + tabbing

[iotcloud.git] / version2 / src / C / RejectedMessage.cc

diff --git a/version2/src/C/RejectedMessage.cc b/version2/src/C/RejectedMessage.cc
index 7cbac36b82704aa38699c5885f59c3547cf24d9f..da5d574e3b0428c4fe2e50bd503e6f1c3a3ef434 100644 (file)
--- a/version2/src/C/RejectedMessage.cc
+++ b/version2/src/C/RejectedMessage.cc
@@ -9,26 +9,26 @@
  * @version 1.0
  */
 
-Entry * RejectedMessage_decode(Slot * slot, ByteBuffer * bb) {
-       int64_t sequencenum=bb.getLong();
-       int64_t machineid=bb.getLong();
-       int64_t oldseqnum=bb.getLong();
-       int64_t newseqnum=bb.getLong();
-       char equalto=bb.get();
-       return new RejectedMessage(slot,sequencenum, machineid, oldseqnum, newseqnum, equalto==1);
+Entry *RejectedMessage_decode(Slot *slot, ByteBuffer *bb) {
+       int64_t sequencenum = bb->getLong();
+       int64_t machineid = bb->getLong();
+       int64_t oldseqnum = bb->getLong();
+       int64_t newseqnum = bb->getLong();
+       char equalto = bb->get();
+       return new RejectedMessage(slot,sequencenum, machineid, oldseqnum, newseqnum, equalto == 1);
 }
 
 void RejectedMessage::removeWatcher(int64_t machineid) {
-       if (watchset.remove(machineid))
-               if (watchset.isEmpty())
+       if (watchset->remove(machineid))
+               if (watchset->isEmpty())
                        setDead();
 }
 
-void RejectedMessage::encode(ByteBuffer * bb) {
-       bb.put(TypeRejectedMessage);
+void RejectedMessage::encode(ByteBuffer *bb) {
+       bb->put(TypeRejectedMessage);
        bb->putLong(sequencenum);
        bb->putLong(machineid);
        bb->putLong(oldseqnum);
        bb->putLong(newseqnum);
-       bb->put(equalto?(char)1:(char)0);
+       bb->put(equalto ? (char)1 : (char)0);
 }