}
static Entry decode(Slot s, ByteBuffer bb) {
- int64_t machineId = bb.getLong();
- int64_t sequenceNumber = bb.getLong();
- int64_t transactionSequenceNumber = bb.getLong();
- int partNumber = bb.getInt();
- int dataSize = bb.getInt();
- Boolean isLastPart = bb.get() == 1;
+ int64_t machineId = bb->getLong();
+ int64_t sequenceNumber = bb->getLong();
+ int64_t transactionSequenceNumber = bb->getLong();
+ int partNumber = bb->getInt();
+ int dataSize = bb->getInt();
+ Boolean isLastPart = bb->get() == 1;
// Get the data
char[] data = new char[dataSize];
- bb.get(data);
+ bb->get(data);
return new CommitPart(s, machineId, sequenceNumber, transactionSequenceNumber, partNumber, data, isLastPart);
}
void encode(ByteBuffer bb) {
- bb.put(Entry.TypeCommitPart);
- bb.putLong(machineId);
- bb.putLong(sequenceNumber);
- bb.putLong(transactionSequenceNumber);
- bb.putInt(partNumber);
- bb.putInt(data.length);
+ bb->put(Entry.TypeCommitPart);
+ bb->putLong(machineId);
+ bb->putLong(sequenceNumber);
+ bb->putLong(transactionSequenceNumber);
+ bb->putInt(partNumber);
+ bb->putInt(data.length);
if (isLastPart) {
- bb.put((char)1);
+ bb->put((char)1);
} else {
- bb.put((char)0);
+ bb->put((char)0);
}
- bb.put(data);
+ bb->put(data);
}
char getType() {