X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/5a5c578e2e358a121cdb9234a6cb11c4ecfbf323..f0dcb6b97d6d40f67698d1f71ac26970f1776f82:/lock_client.h diff --git a/lock_client.h b/lock_client.h index 36ee3a2..654cf4f 100644 --- a/lock_client.h +++ b/lock_client.h @@ -42,11 +42,12 @@ typedef map lock_map; // lock_revoke_server. class lock_client { private: - rpcc *cl; + unique_ptr cl; + unique_ptr rlsrpc; thread releaser_thread; - rsm_client *rsmc; - class lock_release_user *lu; - unsigned int rlock_port; + unique_ptr rsmc; + lock_release_user *lu; + in_port_t rlock_port; string hostname; string id; mutex xid_mutex; @@ -54,15 +55,15 @@ class lock_client { fifo release_fifo; mutex lock_table_lock; lock_map lock_table; - lock_state &get_lock_state(lock_protocol::lockid_t lid); + lock_state & get_lock_state(lock_protocol::lockid_t lid); public: - static unsigned int last_port; - lock_client(string xdst, class lock_release_user *l = 0); + static in_port_t last_port; + lock_client(string xdst, lock_release_user *l = 0); ~lock_client() {} lock_protocol::status acquire(lock_protocol::lockid_t); lock_protocol::status release(lock_protocol::lockid_t); int stat(lock_protocol::lockid_t); - void releaser(); + void releaser NORETURN (); rlock_protocol::status revoke_handler(int &, lock_protocol::lockid_t, lock_protocol::xid_t); rlock_protocol::status retry_handler(int &, lock_protocol::lockid_t, lock_protocol::xid_t); };