Ref counting

[iotcloud.git] / version2 / src / C / CommitPart.h

diff --git a/version2/src/C/CommitPart.h b/version2/src/C/CommitPart.h
index e0a0d91b4c5f7cc659a298520acf4f761e1f3295..7b8be2e8450c76c67a8aa096be23680b73e57706 100644 (file)
--- a/version2/src/C/CommitPart.h
+++ b/version2/src/C/CommitPart.h
@@ -15,20 +15,21 @@ private:
        int64_t transactionSequenceNumber;
        int32_t partNumber;     // Parts position in the
        bool fldisLastPart;
+       int32_t refCount;
        Array<char> *data;
 
-       Pair<int64_t, int32_t> *partId;
-       Pair<int64_t, int64_t> *commitId;
+       Pair<int64_t, int32_t> partId;
+       Pair<int64_t, int64_t> commitId;
 
 public:
        CommitPart(Slot *s, int64_t _machineId, int64_t _sequenceNumber, int64_t _transactionSequenceNumber, int _partNumber, Array<char> *_data, bool _isLastPart);
+       ~CommitPart();
        int getSize();
-       void setSlot(Slot *s);
        int getPartNumber();
        int getDataSize();
        Array<char> *getData();
-       Pair<int64_t, int32_t> *getPartId();
-       Pair<int64_t, int64_t> *getCommitId();
+       Pair<int64_t, int32_t> * getPartId();
+       Pair<int64_t, int64_t> getCommitId();
        bool isLastPart();
        int64_t getMachineId();
        int64_t getTransactionSequenceNumber();
@@ -36,6 +37,8 @@ public:
        void encode(ByteBuffer *bb);
        char getType();
        Entry *getCopy(Slot *s);
+       void releaseRef() {if ((--refCount)==0) delete this;}   
+       void acquireRef() {refCount++;}
 };
 
 Entry *CommitPart_decode(Slot *s, ByteBuffer *bb);