rpc/rpc_protocol.h

   1 #ifndef rpc_protocol_h
   2 #define rpc_protocol_h
   3
   4 #include "types.h"
   5
   6 namespace rpc_protocol {
   7     using proc_id_t = uint32_t;
   8
   9     using status = int32_t;
  10     using rpc_sz_t = uint32_t;
  11     using nonce_t = uint32_t;
  12     using xid_t = int32_t;
  13
  14     enum : status {
  15         timeout_failure = -1,
  16         unmarshall_args_failure = -2,
  17         unmarshall_reply_failure = -3,
  18         atmostonce_failure = -4,
  19         oldsrv_failure = -5,
  20         bind_failure = -6,
  21         cancel_failure = -7
  22     };
  23
  24     struct request_header {
  25         xid_t xid;
  26         proc_id_t proc;
  27         nonce_t clt_nonce;
  28         nonce_t srv_nonce;
  29         xid_t xid_rep;
  30
  31         MEMBERS(xid, proc, clt_nonce, srv_nonce, xid_rep)
  32     };
  33
  34     struct reply_header {
  35         xid_t xid;
  36         int ret;
  37
  38         MEMBERS(xid, ret)
  39     };
  40
  41     template <typename Signature>
  42     struct proc_t {
  43         using signature = Signature;
  44         proc_id_t id;
  45     };
  46
  47     const size_t RPC_HEADER_SZ = max(sizeof(request_header), sizeof(reply_header)) + sizeof(rpc_sz_t);
  48     const size_t DEFAULT_RPC_SZ = 1024; // size of initial buffer allocation
  49     const size_t MAX_PDU = 10<<20; // maximum PDF is 10M
  50
  51 #define REMOTE_PROCEDURE_BASE(_base_) static constexpr rpc_protocol::proc_id_t base = _base_;
  52 #define REMOTE_PROCEDURE(_offset_, _name_, _args_) static constexpr rpc_protocol::proc_t<status _args_> _name_{base + _offset_};
  53
  54     REMOTE_PROCEDURE_BASE(0);
  55     REMOTE_PROCEDURE(1, bind, (nonce_t &)); // handler number reserved for bind
  56 };
  57
  58 ENDIAN_SWAPPABLE(rpc_protocol::request_header)
  59 ENDIAN_SWAPPABLE(rpc_protocol::reply_header)
  60
  61 #endif