X-Git-Url: http://plrg.eecs.uci.edu/git/?p=iotcloud.git;a=blobdiff_plain;f=version2%2Fsrc%2FC%2FAbort.cc;h=bd0c6a2763de1473a839ebd7cc60b5e86e2de821;hp=32dd99e834a4b21e77039ab13a327cfa85159bc7;hb=0b9aca2b62c74f68652b170a92271a98d5b96666;hpb=5d76024703d601d6f7205c2cb0300ac4cbeffd1c diff --git a/version2/src/C/Abort.cc b/version2/src/C/Abort.cc index 32dd99e..bd0c6a2 100644 --- a/version2/src/C/Abort.cc +++ b/version2/src/C/Abort.cc @@ -1,44 +1,44 @@ #include "Abort.h" #include "ByteBuffer.h" -Abort::Abort(Slot * slot, int64_t _transactionClientLocalSequenceNumber, int64_t _transactionSequenceNumber , int64_t _transactionMachineId, int64_t _transactionArbitrator, int64_t _arbitratorLocalSequenceNumber) : - Entry(slot), - transactionClientLocalSequenceNumber(_transactionClientLocalSequenceNumber), - transactionSequenceNumber(_transactionSequenceNumber), - transactionMachineId(_transactionMachineId), - transactionArbitrator(_transactionArbitrator), - arbitratorLocalSequenceNumber(_arbitratorLocalSequenceNumber), - abortId(new Pair(transactionMachineId, transactionClientLocalSequenceNumber)) { +Abort::Abort(Slot *slot, int64_t _transactionClientLocalSequenceNumber, int64_t _transactionSequenceNumber, int64_t _transactionMachineId, int64_t _transactionArbitrator, int64_t _arbitratorLocalSequenceNumber) : + Entry(slot), + transactionClientLocalSequenceNumber(_transactionClientLocalSequenceNumber), + transactionSequenceNumber(_transactionSequenceNumber), + transactionMachineId(_transactionMachineId), + transactionArbitrator(_transactionArbitrator), + arbitratorLocalSequenceNumber(_arbitratorLocalSequenceNumber), + abortId(new Pair(transactionMachineId, transactionClientLocalSequenceNumber)) { } -Abort::Abort(Slot * slot, int64_t _transactionClientLocalSequenceNumber, int64_t _transactionSequenceNumber, int64_t _sequenceNumber , int64_t _transactionMachineId, int64_t _transactionArbitrator, int64_t _arbitratorLocalSequenceNumber) : - Entry(slot), - transactionClientLocalSequenceNumber(_transactionClientLocalSequenceNumber), - transactionSequenceNumber(_transactionSequenceNumber), - sequenceNumber(_sequenceNumber), - transactionMachineId(_transactionMachineId), - transactionArbitrator(_transactionArbitrator), - arbitratorLocalSequenceNumber(_arbitratorLocalSequenceNumber), - abortId(new Pair(transactionMachineId, transactionClientLocalSequenceNumber)) { +Abort::Abort(Slot *slot, int64_t _transactionClientLocalSequenceNumber, int64_t _transactionSequenceNumber, int64_t _sequenceNumber, int64_t _transactionMachineId, int64_t _transactionArbitrator, int64_t _arbitratorLocalSequenceNumber) : + Entry(slot), + transactionClientLocalSequenceNumber(_transactionClientLocalSequenceNumber), + transactionSequenceNumber(_transactionSequenceNumber), + sequenceNumber(_sequenceNumber), + transactionMachineId(_transactionMachineId), + transactionArbitrator(_transactionArbitrator), + arbitratorLocalSequenceNumber(_arbitratorLocalSequenceNumber), + abortId(new Pair(transactionMachineId, transactionClientLocalSequenceNumber)) { } -Entry * Abortdecode(Slot * slot, ByteBuffer * bb) { - int64_t transactionClientLocalSequenceNumber = bb->getLong(); - int64_t transactionSequenceNumber = bb->getLong(); - int64_t sequenceNumber = bb->getLong(); - int64_t transactionMachineId = bb->getLong(); - int64_t transactionArbitrator = bb->getLong(); - int64_t arbitratorLocalSequenceNumber = bb->getLong(); - - return new Abort(slot, transactionClientLocalSequenceNumber, transactionSequenceNumber, sequenceNumber, transactionMachineId, transactionArbitrator, arbitratorLocalSequenceNumber); +Entry *Abortdecode(Slot *slot, ByteBuffer *bb) { + int64_t transactionClientLocalSequenceNumber = bb->getLong(); + int64_t transactionSequenceNumber = bb->getLong(); + int64_t sequenceNumber = bb->getLong(); + int64_t transactionMachineId = bb->getLong(); + int64_t transactionArbitrator = bb->getLong(); + int64_t arbitratorLocalSequenceNumber = bb->getLong(); + + return new Abort(slot, transactionClientLocalSequenceNumber, transactionSequenceNumber, sequenceNumber, transactionMachineId, transactionArbitrator, arbitratorLocalSequenceNumber); } -void Abort::encode(ByteBuffer * bb) { - bb->put(TypeAbort); - bb->putLong(transactionClientLocalSequenceNumber); - bb->putLong(transactionSequenceNumber); - bb->putLong(sequenceNumber); - bb->putLong(transactionMachineId); - bb->putLong(transactionArbitrator); - bb->putLong(arbitratorLocalSequenceNumber); +void Abort::encode(ByteBuffer *bb) { + bb->put(TypeAbort); + bb->putLong(transactionClientLocalSequenceNumber); + bb->putLong(transactionSequenceNumber); + bb->putLong(sequenceNumber); + bb->putLong(transactionMachineId); + bb->putLong(transactionArbitrator); + bb->putLong(arbitratorLocalSequenceNumber); }