edits

[iotcloud.git] / version2 / src / C / CommitPart.cc

diff --git a/version2/src/C/CommitPart.cc b/version2/src/C/CommitPart.cc
index fd560d9d970529379165d31745f5b500b541f92f..d137a75e1611b1e36cc02700f8baa14061355b95 100644 (file)
--- a/version2/src/C/CommitPart.cc
+++ b/version2/src/C/CommitPart.cc
@@ -1,5 +1,5 @@
 #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) :
        Entry(s),
@@ -7,9 +7,9 @@ CommitPart::CommitPart(Slot *s, int64_t _machineId, int64_t _sequenceNumber, int
        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)) {
 }
 
@@ -20,7 +20,7 @@ int CommitPart::getSize() {
        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;
 }
 
@@ -36,7 +36,7 @@ Array<char> *CommitPart::getData() {
        return data;
 }
 
-Pair<int64_t int32_t> *CommitPart::getPartId() {
+Pair<int64_t, int32_t> *CommitPart::getPartId() {
        return partId;
 }
 
@@ -45,7 +45,7 @@ Pair<int64_t, int64_t> *CommitPart::getCommitId() {
 }
 
 bool CommitPart::isLastPart() {
-       return isLastPart;
+       return fldisLastPart;
 }
 
 int64_t CommitPart::getMachineId() {
@@ -75,15 +75,15 @@ Entry *CommitPart_decode(Slot *s, ByteBuffer *bb) {
        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);
+       bb->putInt(data->length());
 
-       if (isLastPart) {
+       if (fldisLastPart) {
                bb->put((char)1);
        } else {
                bb->put((char)0);
@@ -97,5 +97,5 @@ char CommitPart::getType() {
 }
 
 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);
 }