ACE/protocols/ace/TMCast/Protocol.hpp

   1 // author    : Boris Kolpackov <boris@dre.vanderbilt.edu>
   2
   3 #ifndef TMCAST_PROTOCOL_HPP
   4 #define TMCAST_PROTOCOL_HPP
   5
   6 namespace ACE_TMCast
   7 {
   8   namespace Protocol
   9   {
  10     unsigned long const MEMBER_ID_LENGTH = 38;
  11
  12     struct MemberId
  13     {
  14       char id[MEMBER_ID_LENGTH];
  15       /*
  16         unsigned long  ip;
  17         unsigned short port;
  18       */
  19     };
  20
  21     typedef unsigned short TransactionId;
  22
  23     typedef unsigned char  TransactionStatus;
  24
  25     TransactionStatus const TS_BEGIN    = 1;
  26     TransactionStatus const TS_COMMIT   = 2;
  27     TransactionStatus const TS_ABORT    = 3;
  28     TransactionStatus const TS_COMMITED = 4;
  29     TransactionStatus const TS_ABORTED  = 5;
  30
  31     struct Transaction
  32     {
  33       TransactionId id;
  34       TransactionStatus status;
  35     };
  36
  37     // Transaction List (TL)
  38
  39     // unsigned long const TL_LENGTH = 1;
  40
  41     // typedef Transaction TransactionList[TL_LENGTH];
  42
  43
  44     struct MessageHeader
  45     {
  46       unsigned long length;
  47
  48       unsigned long check_sum;
  49
  50       MemberId member_id;
  51
  52       Transaction current;
  53
  54       //TransactionList transaction_list;
  55     };
  56
  57     unsigned long const MAX_MESSAGE_SIZE = 768;
  58
  59     unsigned long const
  60     MAX_PAYLOAD_SIZE = MAX_MESSAGE_SIZE - sizeof (MessageHeader);
  61
  62     // Protocol timing
  63     //
  64     //
  65
  66     unsigned long const SYNC_PERIOD = 30000;    // in mks
  67
  68     unsigned short const VOTING_FRAME = 4;      // in SYNC_PERIOD's
  69     unsigned short const SEPARATION_FRAME = 5;  // in SYNC_PERIOD's
  70
  71     // FATAL_SILENCE_FRAME in SYNC_PERIOD's
  72     // Generally it's a good idea to set it to < VOTING_FRAME + SEPARATION_FRAME
  73     //
  74
  75     short const FATAL_SILENCE_FRAME = VOTING_FRAME + SEPARATION_FRAME - 2;
  76
  77     // short const FATAL_SILENCE_FRAME = 10000;
  78
  79     // Helpers
  80
  81     // std::string
  82     // tslabel (Protocol::TransactionStatus s);
  83
  84     // std::ostream&
  85     // operator << (std::ostream& o, Transaction const& t);
  86   }
  87 }
  88
  89 #endif // TMCAST_PROTOCOL_HPP