void Transaction::setSequenceNumber(int64_t _sequenceNumber) {
sequenceNumber = _sequenceNumber;
- for (int32_t i = 0; i < parts->size(); i++) {
+ for (uint32_t i = 0; i < parts->size(); i++) {
TransactionPart *tp = parts->get(i);
if (tp != NULL)
tp->setSequenceNumber(sequenceNumber);
return fldisComplete;
}
-Pair<int64_t, int64_t> * Transaction::getId() {
- return & transactionId;
+Pair<int64_t, int64_t> *Transaction::getId() {
+ return &transactionId;
}
void Transaction::setDead() {
// Set dead
isDead = true;
// Make all the parts of this transaction dead
- for (int32_t partNumber = 0; partNumber < parts->size(); partNumber++) {
+ for (uint32_t partNumber = 0; partNumber < parts->size(); partNumber++) {
TransactionPart *part = parts->get(partNumber);
if (part != NULL)
part->setDead();
void Transaction::decodeTransactionData() {
// Calculate the size of the data section
int dataSize = 0;
- for (int i = 0; i < parts->size(); i++) {
+ for (uint i = 0; i < parts->size(); i++) {
TransactionPart *tp = parts->get(i);
dataSize += tp->getDataSize();
}
int currentPosition = 0;
// Stitch all the data sections together
- for (int i = 0; i < parts->size(); i++) {
+ for (uint i = 0; i < parts->size(); i++) {
TransactionPart *tp = parts->get(i);
System_arraycopy(tp->getData(), 0, combinedData, currentPosition, tp->getDataSize());
currentPosition += tp->getDataSize();
}
}
-bool Transaction::evaluateGuard(Hashtable<IoTString *, KeyValue *> *committedKeyValueTable, Hashtable<IoTString *, KeyValue *> *speculatedKeyValueTable, Hashtable<IoTString *, KeyValue *> *pendingTransactionSpeculatedKeyValueTable) {
+bool Transaction::evaluateGuard(Hashtable<IoTString *, KeyValue *, uintptr_t, 0, hashString, StringEquals> *committedKeyValueTable, Hashtable<IoTString *, KeyValue *, uintptr_t, 0, hashString, StringEquals> *speculatedKeyValueTable, Hashtable<IoTString *, KeyValue *, uintptr_t, 0, hashString, StringEquals> *pendingTransactionSpeculatedKeyValueTable) {
SetIterator<KeyValue *, KeyValue *> *kvit = keyValueGuardSet->iterator();
while (kvit->hasNext()) {
KeyValue *kvGuard = kvit->next();