X-Git-Url: http://xvm.mit.edu/gitweb/invirt/third/libt4.git/blobdiff_plain/16e7c282c6fcec8189425bd15ec9e8a4a0ee857d..f0dcb6b97d6d40f67698d1f71ac26970f1776f82:/config.h diff --git a/config.h b/config.h index 73940a0..895de1b 100644 --- a/config.h +++ b/config.h @@ -20,29 +20,27 @@ class config : public paxos_change { vector mems; mutex cfg_mutex; cond config_cond; - paxos_protocol::status heartbeat(int &r, string m, unsigned instance); - string value(const vector &mems) const; - vector members(const string &v) const; - void get_view(unsigned instance, vector &m, lock &cfg_mutex_lock); - bool remove(const string &, lock &cfg_mutex_lock); - void reconstruct(lock &cfg_mutex_lock); + paxos_protocol::status heartbeat(int & r, string m, unsigned instance); + void get_view(unsigned instance, vector & m, lock & cfg_mutex_lock); + bool remove(const string &, lock & cfg_mutex_lock); + void reconstruct(lock & cfg_mutex_lock); typedef enum { OK, // response and same view # VIEWERR, // response but different view # FAILURE, // no response } heartbeat_t; - heartbeat_t doheartbeat(const string &m, lock &cfg_mutex_lock); + heartbeat_t doheartbeat(const string & m, lock & cfg_mutex_lock); public: - config(const string &_first, const string &_me, config_view_change *_vc); + config(const string & _first, const string & _me, config_view_change *_vc); unsigned view_id() { return my_view_id; } - const string &myaddr() const { return me; } + const string & myaddr() const { return me; } string dump() { return paxos.dump(); } - void get_view(unsigned instance, vector &m); - void restore(const string &s); + void get_view(unsigned instance, vector & m); + void restore(const string & s); bool add(const string &, unsigned view_id); - bool ismember(const string &m, unsigned view_id); - void heartbeater(void); - void paxos_commit(unsigned instance, const string &v); + bool ismember(const string & m, unsigned view_id); + void heartbeater NORETURN (); + void paxos_commit(unsigned instance, const string & v); rpcs *get_rpcs() { return paxos.get_rpcs(); } void breakpoint(int b) { paxos.breakpoint(b); } };