X-Git-Url: http://plrg.eecs.uci.edu/git/?a=blobdiff_plain;f=version2%2Fsrc%2FC%2FAbort.h;fp=version2%2Fsrc%2FC%2FAbort.h;h=ad54c4fd09221e545934a9ab0d76840c3c0f5e91;hb=0b9aca2b62c74f68652b170a92271a98d5b96666;hp=d03d8455f7309a203ce8c8720bbcd849fc171f29;hpb=5d76024703d601d6f7205c2cb0300ac4cbeffd1c;p=iotcloud.git diff --git a/version2/src/C/Abort.h b/version2/src/C/Abort.h index d03d845..ad54c4f 100644 --- a/version2/src/C/Abort.h +++ b/version2/src/C/Abort.h @@ -5,35 +5,35 @@ #include "Pair.h" class Abort : public Entry { - private: +private: int64_t transactionClientLocalSequenceNumber; - int64_t transactionSequenceNumber; + int64_t transactionSequenceNumber; int64_t sequenceNumber; int64_t transactionMachineId; int64_t transactionArbitrator; int64_t arbitratorLocalSequenceNumber; - Pair * abortId; - - public: - Abort(Slot * slot, int64_t _transactionClientLocalSequenceNumber, int64_t _transactionSequenceNumber , int64_t _transactionMachineId, int64_t _transactionArbitrator, int64_t _arbitratorLocalSequenceNumber); - Abort(Slot * slot, int64_t _transactionClientLocalSequenceNumber, int64_t _transactionSequenceNumber, int64_t _sequenceNumber , int64_t _transactionMachineId, int64_t _transactionArbitrator, int64_t _arbitratorLocalSequenceNumber); + Pair *abortId; + +public: + Abort(Slot *slot, int64_t _transactionClientLocalSequenceNumber, int64_t _transactionSequenceNumber, int64_t _transactionMachineId, int64_t _transactionArbitrator, int64_t _arbitratorLocalSequenceNumber); + Abort(Slot *slot, int64_t _transactionClientLocalSequenceNumber, int64_t _transactionSequenceNumber, int64_t _sequenceNumber, int64_t _transactionMachineId, int64_t _transactionArbitrator, int64_t _arbitratorLocalSequenceNumber); + + Pair *getAbortId() {return abortId;} - Pair * getAbortId() {return abortId;} - int64_t getTransactionMachineId() { return transactionMachineId; } int64_t getTransactionSequenceNumber() { return transactionSequenceNumber; } int64_t getTransactionClientLocalSequenceNumber() { return transactionClientLocalSequenceNumber; } int64_t getArbitratorLocalSequenceNumber() { return arbitratorLocalSequenceNumber; } - void setSlot(Slot * s) { parentslot = s; } - int64_t getSequenceNumber() { return sequenceNumber; } + void setSlot(Slot *s) { parentslot = s; } + int64_t getSequenceNumber() { return sequenceNumber; } void setSequenceNumber(int64_t _sequenceNumber) { sequenceNumber = _sequenceNumber; } int64_t getTransactionArbitrator() { return transactionArbitrator; } - void encode(ByteBuffer * bb); + void encode(ByteBuffer *bb); int getSize() { return (6 * sizeof(uint64_t)) + sizeof(char); } char getType() { return TypeAbort; } - Entry * getCopy(Slot * s) { return new Abort(s, transactionClientLocalSequenceNumber, transactionSequenceNumber, sequenceNumber, transactionMachineId, transactionArbitrator, arbitratorLocalSequenceNumber); } + Entry *getCopy(Slot *s) { return new Abort(s, transactionClientLocalSequenceNumber, transactionSequenceNumber, sequenceNumber, transactionMachineId, transactionArbitrator, arbitratorLocalSequenceNumber); } }; -Entry * Abortdecode(Slot * slot, ByteBuffer * bb); +Entry *Abortdecode(Slot *slot, ByteBuffer *bb); #endif