X-Git-Url: http://demsky.eecs.uci.edu/git/?a=blobdiff_plain;f=version2%2Fsrc%2FC%2FTable.h;h=a5ea0dc9b3c4095f1c49bca3c4c36d3ed20b37e2;hb=3e54762d57367b1ce049830b42f00950055d8527;hp=3f522144e983df2ed461114f7ec91ab5df05fc5b;hpb=151413d447b9302ee57b5d3276ef73e4b297fdc0;p=iotcloud.git diff --git a/version2/src/C/Table.h b/version2/src/C/Table.h index 3f52214..a5ea0dc 100644 --- a/version2/src/C/Table.h +++ b/version2/src/C/Table.h @@ -62,15 +62,15 @@ private: Hashtable *speculatedKeyValueTable; // Table of speculated key value pairs, if there is a speculative value Hashtable *pendingTransactionSpeculatedKeyValueTable; // Table of speculated key value pairs, if there is a speculative value from the pending transactions Hashtable *liveNewKeyTable; // Table of live new keys - Hashtable *> *lastMessageTable; // Last message sent by a client machine id -> (Seq Num, Slot or LastMessage); + Hashtable > *lastMessageTable; // Last message sent by a client machine id -> (Seq Num, Slot or LastMessage); Hashtable *> *rejectedMessageWatchVectorTable; // Table of machine Ids and the set of rejected messages they have not seen yet Hashtable *arbitratorTable;// Table of keys and their arbitrators - Hashtable *, Abort *> *liveAbortTable;// Table live abort messages - Hashtable *, TransactionPart *> *> *newTransactionParts; // transaction parts that are seen in this latest round of slots from the server - Hashtable *, CommitPart *> *> *newCommitParts; // commit parts that are seen in this latest round of slots from the server + Hashtable, Abort *> *liveAbortTable;// Table live abort messages + Hashtable, TransactionPart *> *> *newTransactionParts; // transaction parts that are seen in this latest round of slots from the server + Hashtable, CommitPart *> *> *newCommitParts; // commit parts that are seen in this latest round of slots from the server Hashtable *lastArbitratedTransactionNumberByArbitratorTable; // Last transaction sequence number that an arbitrator arbitrated on Hashtable *liveTransactionBySequenceNumberTable; // live transaction grouped by the sequence number - Hashtable *, Transaction *> *liveTransactionByTransactionIdTable; // live transaction grouped by the transaction ID + Hashtable, Transaction *> *liveTransactionByTransactionIdTable; // live transaction grouped by the transaction ID Hashtable > *liveCommitsTable; Hashtable *liveCommitsByKeyTable; Hashtable *lastCommitSeenSequenceNumberByArbitratorTable; @@ -81,7 +81,7 @@ private: Hashtable *> *transactionPartsSent; Hashtable *outstandingTransactionStatus; Hashtable *liveAbortsGeneratedByLocal; - Hashset *> *offlineTransactionsCommittedAndAtServer; + Hashset > *offlineTransactionsCommittedAndAtServer; Hashtable > *localCommunicationTable; Hashtable *lastTransactionSeenFromMachineFromServer; Hashtable *lastArbitrationDataLocalSequenceNumberSeenFromArbitrator; @@ -97,11 +97,11 @@ private: bool sendToServer(NewKey *newKey); bool updateFromLocal(int64_t machineId); Pair sendTransactionToLocal(Transaction *transaction); - ThreeTuple *> *sendSlotsToServer(Slot *slot, int newSize, bool isNewKey); + ThreeTuple *> sendSlotsToServer(Slot *slot, int newSize, bool isNewKey); /** * Returns false if a resize was needed */ - ThreeTuple *fillSlot(Slot *slot, bool resize, NewKey *newKeyEntry); + ThreeTuple fillSlot(Slot *slot, bool resize, NewKey *newKeyEntry); void doRejectedMessages(Slot *s); ThreeTuple doMandatoryResuce(Slot *slot, bool resize);