version2/src/C/CommitPart.cc

   1 #include "CommitPart.h"
   2 #include "ByteBuffer.h"
   3
   4 CommitPart::CommitPart(Slot *s, int64_t _machineId, int64_t _sequenceNumber, int64_t _transactionSequenceNumber, int _partNumber, Array<char> *_data, bool _isLastPart) :
   5         Entry(s),
   6         machineId(_machineId),
   7         sequenceNumber(_sequenceNumber),
   8         transactionSequenceNumber(_transactionSequenceNumber),
   9         partNumber(_partNumber),
  10         fldisLastPart(_isLastPart),
  11         data(_data),
  12         partId(Pair<int64_t, int32_t>(sequenceNumber, partNumber)),
  13         commitId(Pair<int64_t, int64_t>(machineId, sequenceNumber)) {
  14 }
  15
  16 CommitPart::~CommitPart() {
  17         delete data;
  18 }
  19
  20 int CommitPart::getSize() {
  21         if (data == NULL) {
  22                 return (3 * sizeof(int64_t)) + (2 * sizeof(int32_t)) + (2 * sizeof(char));
  23         }
  24         return (3 * sizeof(int64_t)) + (2 * sizeof(int32_t)) + (2 * sizeof(char)) + data->length();
  25 }
  26
  27 int CommitPart::getPartNumber() {
  28         return partNumber;
  29 }
  30
  31 int CommitPart::getDataSize() {
  32         return data->length();
  33 }
  34
  35 Array<char> *CommitPart::getData() {
  36         return data;
  37 }
  38
  39 Pair<int64_t, int32_t> * CommitPart::getPartId() {
  40         return & partId;
  41 }
  42
  43 Pair<int64_t, int64_t> CommitPart::getCommitId() {
  44         return commitId;
  45 }
  46
  47 bool CommitPart::isLastPart() {
  48         return fldisLastPart;
  49 }
  50
  51 int64_t CommitPart::getMachineId() {
  52         return machineId;
  53 }
  54
  55 int64_t CommitPart::getTransactionSequenceNumber() {
  56         return transactionSequenceNumber;
  57 }
  58
  59 int64_t CommitPart::getSequenceNumber() {
  60         return sequenceNumber;
  61 }
  62
  63 Entry *CommitPart_decode(Slot *s, ByteBuffer *bb) {
  64         int64_t machineId = bb->getLong();
  65         int64_t sequenceNumber = bb->getLong();
  66         int64_t transactionSequenceNumber = bb->getLong();
  67         int partNumber = bb->getInt();
  68         int dataSize = bb->getInt();
  69         bool isLastPart = bb->get() == 1;
  70
  71         // Get the data
  72         Array<char> *data = new Array<char>(dataSize);
  73         bb->get(data);
  74
  75         return new CommitPart(s, machineId, sequenceNumber, transactionSequenceNumber, partNumber, data, isLastPart);
  76 }
  77
  78 void CommitPart::encode(ByteBuffer *bb) {
  79         bb->put(TypeCommitPart);
  80         bb->putLong(machineId);
  81         bb->putLong(sequenceNumber);
  82         bb->putLong(transactionSequenceNumber);
  83         bb->putInt(partNumber);
  84         bb->putInt(data->length());
  85
  86         if (fldisLastPart) {
  87                 bb->put((char)1);
  88         } else {
  89                 bb->put((char)0);
  90         }
  91
  92         bb->put(data);
  93 }
  94
  95 char CommitPart::getType() {
  96         return TypeCommitPart;
  97 }
  98
  99 Entry *CommitPart::getCopy(Slot *s) {
 100         return new CommitPart(s, machineId, sequenceNumber, transactionSequenceNumber, partNumber, new Array<char>(data), fldisLastPart);
 101 }