1 #include "CommitPart.h"
2 #include "ByteBuffer.h"
4 CommitPart::CommitPart(Slot *s, int64_t _machineId, int64_t _sequenceNumber, int64_t _transactionSequenceNumber, int _partNumber, Array<char> *_data, bool _isLastPart) :
7 sequenceNumber(_sequenceNumber),
8 transactionSequenceNumber(_transactionSequenceNumber),
9 partNumber(_partNumber),
10 fldisLastPart(_isLastPart),
13 partId(Pair<int64_t, int32_t>(sequenceNumber, partNumber)),
14 commitId(Pair<int64_t, int64_t>(machineId, sequenceNumber)) {
17 CommitPart::~CommitPart() {
21 int CommitPart::getSize() {
23 return (3 * sizeof(int64_t)) + (2 * sizeof(int32_t)) + (2 * sizeof(char));
25 return (3 * sizeof(int64_t)) + (2 * sizeof(int32_t)) + (2 * sizeof(char)) + data->length();
28 int CommitPart::getPartNumber() {
32 int CommitPart::getDataSize() {
33 return data->length();
36 Array<char> *CommitPart::getData() {
40 Pair<int64_t, int32_t> * CommitPart::getPartId() {
44 Pair<int64_t, int64_t> CommitPart::getCommitId() {
48 bool CommitPart::isLastPart() {
52 int64_t CommitPart::getMachineId() {
56 int64_t CommitPart::getTransactionSequenceNumber() {
57 return transactionSequenceNumber;
60 int64_t CommitPart::getSequenceNumber() {
61 return sequenceNumber;
64 Entry *CommitPart_decode(Slot *s, ByteBuffer *bb) {
65 int64_t machineId = bb->getLong();
66 int64_t sequenceNumber = bb->getLong();
67 int64_t transactionSequenceNumber = bb->getLong();
68 int partNumber = bb->getInt();
69 int dataSize = bb->getInt();
70 bool isLastPart = bb->get() == 1;
73 Array<char> *data = new Array<char>(dataSize);
76 return new CommitPart(s, machineId, sequenceNumber, transactionSequenceNumber, partNumber, data, isLastPart);
79 void CommitPart::encode(ByteBuffer *bb) {
80 bb->put(TypeCommitPart);
81 bb->putLong(machineId);
82 bb->putLong(sequenceNumber);
83 bb->putLong(transactionSequenceNumber);
84 bb->putInt(partNumber);
85 bb->putInt(data->length());
96 char CommitPart::getType() {
97 return TypeCommitPart;
100 Entry *CommitPart::getCopy(Slot *s) {
101 return new CommitPart(s, machineId, sequenceNumber, transactionSequenceNumber, partNumber, new Array<char>(data), fldisLastPart);