tabbing

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

diff --git a/version2/src/C/PendingTransaction.cc b/version2/src/C/PendingTransaction.cc
index 84bef5ecaec59ff6ebc451291e2f8172be2f35de..088238e93aa4d9610a2dc44beb8742aa3b1880d0 100644 (file)
--- a/version2/src/C/PendingTransaction.cc
+++ b/version2/src/C/PendingTransaction.cc
@@ -20,11 +20,11 @@ PendingTransaction::PendingTransaction(int64_t _machineId) :
  */
 void PendingTransaction::addKV(KeyValue *newKV) {
 
-       KeyValue * rmKV = NULL;
+       KeyValue *rmKV = NULL;
 
        // Make sure there are no duplicates
-       SetIterator<KeyValue *> * kvit = keyValueUpdateSet->iterator();
-       while(kvit->hasNext()) {
+       SetIterator<KeyValue *> *kvit = keyValueUpdateSet->iterator();
+       while (kvit->hasNext()) {
                KeyValue *kv = kvit->next();
                if (kv->getKey()->equals(newKV->getKey())) {
 
@@ -34,7 +34,7 @@ void PendingTransaction::addKV(KeyValue *newKV) {
                }
        }
        delete kvit;
-       
+
        // Remove key if we are adding a newer version of the same key
        if (rmKV != NULL) {
                keyValueUpdateSet->remove(rmKV);
@@ -68,13 +68,13 @@ bool PendingTransaction::checkArbitrator(int64_t arb) {
        return arb == arbitrator;
 }
 
-bool PendingTransaction::evaluateGuard(Hashtable<IoTString *, KeyValue *> * keyValTableCommitted, Hashtable<IoTString *, KeyValue *> * keyValTableSpeculative, Hashtable<IoTString *, KeyValue *> * keyValTablePendingTransSpeculative) {
-       SetIterator<KeyValue *> * kvit = keyValueGuardSet->iterator();
-       while(kvit->hasNext()) {
+bool PendingTransaction::evaluateGuard(Hashtable<IoTString *, KeyValue *> *keyValTableCommitted, Hashtable<IoTString *, KeyValue *> *keyValTableSpeculative, Hashtable<IoTString *, KeyValue *> *keyValTablePendingTransSpeculative) {
+       SetIterator<KeyValue *> *kvit = keyValueGuardSet->iterator();
+       while (kvit->hasNext()) {
                KeyValue *kvGuard = kvit->next();
 
                // First check if the key is in the speculative table, this is the value of the latest assumption
-               KeyValue * kv = keyValTablePendingTransSpeculative->get(kvGuard->getKey());
+               KeyValue *kv = keyValTablePendingTransSpeculative->get(kvGuard->getKey());
 
 
                if (kv == NULL) {
@@ -130,7 +130,7 @@ Transaction *PendingTransaction::createTransaction() {
                Array<char> *partData = new Array<char>(copySize);
                System_arraycopy(charData, currentPosition, partData, 0, copySize);
 
-               TransactionPart * part = new TransactionPart(NULL, machineId, arbitrator, clientLocalSequenceNumber, transactionPartCount, partData, isLastPart);
+               TransactionPart *part = new TransactionPart(NULL, machineId, arbitrator, clientLocalSequenceNumber, transactionPartCount, partData, isLastPart);
                newTransaction->addPartEncode(part);
 
                // Update position, count and remaining
@@ -140,16 +140,16 @@ Transaction *PendingTransaction::createTransaction() {
        }
 
        // Add the Guard Conditions
-       SetIterator<KeyValue *> * kvit = keyValueGuardSet->iterator();
-       while(kvit->hasNext()) {
+       SetIterator<KeyValue *> *kvit = keyValueGuardSet->iterator();
+       while (kvit->hasNext()) {
                KeyValue *kv = kvit->next();
                newTransaction->addGuardKV(kv);
        }
        delete kvit;
-       
+
        //  Add the updates
        kvit = keyValueUpdateSet->iterator();
-       while(kvit->hasNext()) {
+       while (kvit->hasNext()) {
                KeyValue *kv = kvit->next();
                newTransaction->addUpdateKV(kv);
        }
@@ -171,21 +171,21 @@ Array<char> *PendingTransaction::convertDataToBytes() {
        bbEncode->putInt(keyValueUpdateSet->size());
 
        // Encode all the guard conditions
-       SetIterator<KeyValue *> * kvit = keyValueGuardSet->iterator();
-       while(kvit->hasNext()) {
+       SetIterator<KeyValue *> *kvit = keyValueGuardSet->iterator();
+       while (kvit->hasNext()) {
                KeyValue *kv = kvit->next();
                kv->encode(bbEncode);
        }
        delete kvit;
-       
+
        // Encode all the updates
        kvit = keyValueUpdateSet->iterator();
-       while(kvit->hasNext()) {
+       while (kvit->hasNext()) {
                KeyValue *kv = kvit->next();
                kv->encode(bbEncode);
        }
        delete kvit;
-       
+
        return bbEncode->array();
 }