char[] data = NULL;
Pair<Long, Integer> partId = NULL;
- Pair<Long, Long> commitId = NULL;
+ Pair<int64_t, int64_t> commitId = NULL;
CommitPart(Slot s, int64_t _machineId, int64_t _sequenceNumber, int64_t _transactionSequenceNumber, int _partNumber, char[] _data, Boolean _isLastPart) {
data = _data;
partId = new Pair<Long, Integer>(sequenceNumber, partNumber);
- commitId = new Pair<Long, Long>(machineId, sequenceNumber);
+ commitId = new Pair<int64_t, int64_t>(machineId, sequenceNumber);
}
int getSize() {
return partId;
}
- Pair<Long, Long> getCommitId() {
+ Pair<int64_t, int64_t> getCommitId() {
return commitId;
}
}
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() {