mutex rsm_client_mutex;
void primary_failure(lock & rsm_client_mutex_lock);
bool init_members(lock & rsm_client_mutex_lock);
+ rsm_protocol::status invoke(unsigned int proc, string &rep, const string &req);
+ template<class R> int call_m(unsigned int proc, R & r, const marshall & req);
public:
rsm_client(string dst);
- rsm_protocol::status invoke(unsigned int proc, string &rep, const string &req);
- template<class R, class ...Args>
- int call(unsigned int proc, R & r, const Args & ...a1);
- private:
- template<class R> int call_m(unsigned int proc, R & r, const marshall & req);
+ template<class P, class R, class ...Args>
+ int call(rpc_protocol::proc_t<P> proc, R & r, const Args & ...a1) {
+ static_assert(is_valid_call<P, R, Args...>::value, "RSM method invoked with incorrect argument types");
+ return call_m(proc.id, r, marshall{a1...});
+ }
};
inline string hexify(const string & s) {
"0x" << hex << proc << " with the wrong return type");
LOG("here's what I got: \"" << hexify(rep) << "\"");
VERIFY(0);
- return rpc_const::unmarshal_reply_failure;
+ return rpc_protocol::unmarshal_reply_failure;
}
unmarshall u1(res, false);
u1 >> r;
" with the wrong return type.");
LOG("here's what I got: \"" << hexify(res) << "\"");
VERIFY(0);
- return rpc_const::unmarshal_reply_failure;
+ return rpc_protocol::unmarshal_reply_failure;
}
return intret;
}
-template<class R, class ...Args>
-int rsm_client::call(unsigned int proc, R & r, const Args & ...a1) {
- return call_m(proc, r, marshall{a1...});
-}
-
#endif