clientLocalSequenceNumber = newPart->getClientLocalSequenceNumber();
machineId = newPart->getMachineId();
- TransactionPart * previoslySeenPart = parts->put(newPart->getPartNumber(), newPart);
+ TransactionPart *previoslySeenPart = parts->put(newPart->getPartNumber(), newPart);
if (previoslySeenPart != NULL) {
// Set dead the old one since the new one is a rescued version of this part
return fldisComplete;
}
-Pair<int64_t, int64_t> *Transaction::getId() {
+Pair<int64_t, int64_t> Transaction::getId() {
return transactionId;
}
// Make all the parts of this transaction dead
for (int32_t partNumber : parts->keySet()) {
- TransactionPart* part = parts->get(partNumber);
+ TransactionPart *part = parts->get(partNumber);
part->setDead();
}
}
}
// Decoder Object
- ByteBuffer* bbDecode = ByteBuffer_wrap(combinedData);
+ ByteBuffer *bbDecode = ByteBuffer_wrap(combinedData);
// Decode how many key value pairs need to be decoded
int numberOfKVGuards = bbDecode->getInt();