edits

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

diff --git a/version2/src/C/TransactionPart.cc b/version2/src/C/TransactionPart.cc
index b73871534a55c17e3c8a825c77f8fdf483ea23b7..2c94865e177941f8ff47dc852df221ce61cb3627 100644 (file)
--- a/version2/src/C/TransactionPart.cc
+++ b/version2/src/C/TransactionPart.cc
@@ -7,11 +7,11 @@ int TransactionPart::getSize() {
        return (4 * sizeof(int64_t)) + (2 * sizeof(int32_t)) + (2 * sizeof(char)) + data.length;
 }
 
-void TransactionPart::setSlot(Slot* s) {
+void TransactionPart::setSlot(Slot *s) {
        parentslot = s;
 }
 
-Pair<int64_t, int64_t>* TransactionPart::getTransactionId() {
+Pair<int64_t, int64_t> *TransactionPart::getTransactionId() {
        return transactionId;
 }
 
@@ -19,7 +19,7 @@ int64_t TransactionPart::getArbitratorId() {
        return arbitratorId;
 }
 
-Pair<int64_t int32_t>* TransactionPart::getPartId() {
+Pair<int64_t int32_t> *TransactionPart::getPartId() {
        return partId;
 }
 
@@ -31,7 +31,7 @@ int TransactionPart::getDataSize() {
        return data.length;
 }
 
-Array<char>* TransactionPart::getData() {
+Array<char> *TransactionPart::getData() {
        return data;
 }
 
@@ -55,7 +55,7 @@ void TransactionPart::setSequenceNumber(int64_t _sequenceNumber) {
        sequenceNumber = _sequenceNumber;
 }
 
-Entry* TransactionPart_decode(Slot* s, ByteBuffer* bb) {
+Entry *TransactionPart_decode(Slot *s, ByteBuffer *bb) {
        int64_t sequenceNumber = bb->getLong();
        int64_t machineId = bb->getLong();
        int64_t arbitratorId = bb->getLong();
@@ -64,16 +64,16 @@ Entry* TransactionPart_decode(Slot* s, ByteBuffer* bb) {
        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);
-       
+
        TransactionPart returnTransactionPart = new TransactionPart(s, machineId, arbitratorId, clientLocalSequenceNumber, partNumber, data, isLastPart);
        returnTransactionPart.setSequenceNumber(sequenceNumber);
-       
+
        return returnTransactionPart;
 }
 
-void TransactionPart::encode(ByteBuffer* bb) {
+void TransactionPart::encode(ByteBuffer *bb) {
        bb->put(Entry.TypeTransactionPart);
        bb->putLong(sequenceNumber);
        bb->putLong(machineId);
@@ -81,13 +81,13 @@ void TransactionPart::encode(ByteBuffer* bb) {
        bb->putLong(clientLocalSequenceNumber);
        bb->putInt(partNumber);
        bb->putInt(data.length);
-       
+
        if (isLastPart) {
                bb->put((char)1);
        } else {
                bb->put((char)0);
        }
-       
+
        bb->put(data);
 }
 
@@ -95,9 +95,9 @@ char TransactionPart::getType() {
        return TypeTransactionPart;
 }
 
-Entry * TransactionPart::getCopy(Slot *s) {
-       TransactionPart* copyTransaction = new TransactionPart(s, machineId, arbitratorId, clientLocalSequenceNumber, partNumber, data, isLastPart);
+Entry *TransactionPart::getCopy(Slot *s) {
+       TransactionPart *copyTransaction = new TransactionPart(s, machineId, arbitratorId, clientLocalSequenceNumber, partNumber, data, isLastPart);
        copyTransaction.setSequenceNumber(sequenceNumber);
-       
+
        return copyTransaction;
 }