Ref counting

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

diff --git a/version2/src/C/Table.h b/version2/src/C/Table.h
index 59ba47216191b268189894ee76604287316d2599..713327736c19700a4d8831ccb0a84152c602a51e 100644 (file)
--- a/version2/src/C/Table.h
+++ b/version2/src/C/Table.h
@@ -57,7 +57,8 @@ private:
        Hashtable<Transaction *, Vector<int32_t> *> *lastTransactionPartsSent;
        Vector<Entry *> *lastPendingSendArbitrationEntriesToDelete;
        NewKey *lastNewKey;
-
+       void processTransactionList(bool handlePartial);
+       void clearSentParts();
 
        /* Data Structures  */
        Hashtable<IoTString *, KeyValue *, uintptr_t, 0, hashString, StringEquals> *committedKeyValueTable;// Table of committed key value pairs
@@ -109,7 +110,7 @@ private:
        bool fillSlot(Slot *slot, bool resize, NewKey *newKeyEntry, int & newSize, bool & insertedKey);
        void doRejectedMessages(Slot *s);
 
-       ThreeTuple<bool, bool, int64_t> doMandatoryResuce(Slot *slot, bool resize);
+       ThreeTuple<bool, bool, int64_t> doMandatoryRescue(Slot *slot, bool resize);
 
        void  doOptionalRescue(Slot *s, bool seenliveslot, int64_t seqn, bool resize);
        /**
@@ -267,7 +268,7 @@ public:
        bool update();
        bool createNewKey(IoTString *keyName, int64_t machineId);
        void startTransaction();
-       void addKV(IoTString *key, IoTString *value);
+       void put(IoTString *key, IoTString *value);
        TransactionStatus *commitTransaction();
 
        /**