currentDataSize(0) {
}
+PendingTransaction::~PendingTransaction() {
+ delete keyValueUpdateSet;
+ delete keyValueGuardSet;
+}
+
/**
* Add a new key value to the updates
*
*/
void PendingTransaction::addKV(KeyValue *newKV) {
-
KeyValue *rmKV = NULL;
// Make sure there are no duplicates
while (kvit->hasNext()) {
KeyValue *kv = kvit->next();
if (kv->getKey()->equals(newKV->getKey())) {
-
// Remove key if we are adding a newer version of the same key
rmKV = kv;
break;
arbitrator = arb;
return true;
}
-
return arb == arbitrator;
}
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
+ // First check if the key is in the speculative table, this is the
+ // value of the latest assumption
KeyValue *kv = keyValTablePendingTransSpeculative->get(kvGuard->getKey());
if (kv == NULL) {
- // if it is not in the pending trans table then check the speculative table and use that
- // value as our latest assumption
+ // if it is not in the pending trans table then check the
+ // speculative table and use that value as our latest assumption
kv = keyValTableSpeculative->get(kvGuard->getKey());
}
if (kv == NULL) {
- // if it is not in the speculative table then check the committed table and use that
- // value as our latest assumption
+ // if it is not in the speculative table then check the
+ // committed table and use that value as our latest assumption
kv = keyValTableCommitted->get(kvGuard->getKey());
}
Array<char> *charData = convertDataToBytes();
int currentPosition = 0;
- int remaining = charData->length();
-
- while (remaining > 0) {
-
+ for(int remaining = charData->length(); remaining > 0;) {
bool isLastPart = false;
// determine how much to copy
int copySize = TransactionPart_MAX_NON_HEADER_SIZE;
if (remaining <= TransactionPart_MAX_NON_HEADER_SIZE) {
copySize = remaining;
- isLastPart = true;// last bit of data so last part
+ isLastPart = true;//last bit of data so last part
}
-
+
// Copy to a smaller version
Array<char> *partData = new Array<char>(copySize);
System_arraycopy(charData, currentPosition, partData, 0, copySize);
return bbEncode->array();
}
-