using status = int32_t;
using rpc_sz_t = uint32_t;
+ using nonce_t = uint32_t;
+ using xid_t = int32_t;
enum : status {
timeout_failure = -1,
};
struct request_header {
- int xid;
+ xid_t xid;
proc_id_t proc;
- unsigned int clt_nonce;
- unsigned int srv_nonce;
- int xid_rep;
+ nonce_t clt_nonce;
+ nonce_t srv_nonce;
+ xid_t xid_rep;
MEMBERS(xid, proc, clt_nonce, srv_nonce, xid_rep)
};
struct reply_header {
- int xid;
+ xid_t xid;
int ret;
MEMBERS(xid, ret)
const size_t RPC_HEADER_SZ = max(sizeof(request_header), sizeof(reply_header)) + sizeof(rpc_sz_t);
const size_t DEFAULT_RPC_SZ = 1024; // size of initial buffer allocation
- const size_t MAX_PDU = 10<<20; //maximum PDF is 10M
+ const size_t MAX_PDU = 10<<20; // maximum PDF is 10M
-#define REMOTE_PROCEDURE_BASE(_base_) enum proc_no : ::rpc_protocol::proc_id_t { base = _base_ };
-#define REMOTE_PROCEDURE(_offset_, _name_, _args_) static constexpr ::rpc_protocol::proc_t<status _args_> _name_{base + _offset_};
+#define REMOTE_PROCEDURE_BASE(_base_) static constexpr rpc_protocol::proc_id_t base = _base_;
+#define REMOTE_PROCEDURE(_offset_, _name_, _args_) static constexpr rpc_protocol::proc_t<status _args_> _name_{base + _offset_};
REMOTE_PROCEDURE_BASE(0);
- REMOTE_PROCEDURE(1, bind, (unsigned int &, int)); // handler number reserved for bind
+ REMOTE_PROCEDURE(1, bind, (nonce_t &)); // handler number reserved for bind
};
ENDIAN_SWAPPABLE(rpc_protocol::request_header)