#include "CommitPart.h"
+#include "ByteBuffer.h"
-
-CommitPart::CommitPart(Slot* s, int64_t _machineId, int64_t _sequenceNumber, int64_t _transactionSequenceNumber, int _partNumber, Array<char>* _data, bool _isLastPart) :
+CommitPart::CommitPart(Slot *s, int64_t _machineId, int64_t _sequenceNumber, int64_t _transactionSequenceNumber, int _partNumber, Array<char> *_data, bool _isLastPart) :
Entry(s),
machineId(_machineId),
sequenceNumber(_sequenceNumber),
transactionSequenceNumber(_transactionSequenceNumber),
partNumber(_partNumber),
- isLastPart(_isLastPart),
+ fldisLastPart(_isLastPart),
data(_data),
- partId(new Pair<int64_t int32_t>(sequenceNumber, partNumber)),
+ partId(new Pair<int64_t, int32_t>(sequenceNumber, partNumber)),
commitId(new Pair<int64_t, int64_t>(machineId, sequenceNumber)) {
}
return (3 * sizeof(int64_t)) + (2 * sizeof(int32_t)) + (2 * sizeof(char)) + data->length();
}
-void CommitPart::setSlot(Slot s) {
+void CommitPart::setSlot(Slot* s) {
parentslot = s;
}
return data->length();
}
-Array<char> * CommitPart::getData() {
+Array<char> *CommitPart::getData() {
return data;
}
-Pair<int64_t int32_t> * CommitPart::getPartId() {
+Pair<int64_t, int32_t> *CommitPart::getPartId() {
return partId;
}
}
bool CommitPart::isLastPart() {
- return isLastPart;
+ return fldisLastPart;
}
int64_t CommitPart::getMachineId() {
return sequenceNumber;
}
-Entry* CommitPart_decode(Slot* s, ByteBuffer* bb) {
+Entry *CommitPart_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();
bool isLastPart = bb->get() == 1;
-
+
// Get the data
- Array<char> * data = new Array<char>(dataSize);
+ Array<char> *data = new Array<char>(dataSize);
bb->get(data);
-
+
return new CommitPart(s, machineId, sequenceNumber, transactionSequenceNumber, partNumber, data, isLastPart);
}
-void CommitPart::encode(ByteBuffer bb) {
+void CommitPart::encode(ByteBuffer *bb) {
bb->put(TypeCommitPart);
bb->putLong(machineId);
bb->putLong(sequenceNumber);
bb->putLong(transactionSequenceNumber);
bb->putInt(partNumber);
- bb->putInt(data.length);
-
- if (isLastPart) {
+ bb->putInt(data->length());
+
+ if (fldisLastPart) {
bb->put((char)1);
} else {
bb->put((char)0);
}
-
+
bb->put(data);
}
}
Entry *CommitPart::getCopy(Slot *s) {
- return new CommitPart(s, machineId, sequenceNumber, transactionSequenceNumber, partNumber, data, isLastPart);
+ return new CommitPart(s, machineId, sequenceNumber, transactionSequenceNumber, partNumber, data, fldisLastPart);
}