Rewrote threaded log code to be more idiomatic.

[invirt/third/libt4.git] / paxos_protocol.h

diff --git a/paxos_protocol.h b/paxos_protocol.h
index f2bdb3f..30a3d2c 100644 (file)
--- a/paxos_protocol.h
+++ b/paxos_protocol.h
@@ -1,85 +1,40 @@
 #ifndef paxos_protocol_h
 #define paxos_protocol_h
 
 #ifndef paxos_protocol_h
 #define paxos_protocol_h
 

+#include "types.h"

 #include "rpc/rpc.h"
 
 struct prop_t {
     unsigned n;
 #include "rpc/rpc.h"
 
 struct prop_t {
     unsigned n;

-    std::string m;
-};
-
-class paxos_protocol {
-    public:
-        enum status : status_t { OK, ERR };
-        enum rpc_numbers : proc_t {
-            preparereq = 0x11001,
-            acceptreq,
-            decidereq,
-            heartbeat,
-        };
-
-        struct preparearg {
-            unsigned instance;
-            prop_t n;
-        };
-
-        struct prepareres {
-            bool oldinstance;
-            bool accept;
-            prop_t n_a;
-            std::string v_a;
-        };
-
-        struct acceptarg {
-            unsigned instance;
-            prop_t n;
-            std::string v;
-        };
+    string m;

 
 

-        struct decidearg {
-            unsigned instance;
-            std::string v;
-        };
+    MEMBERS(n, m)
+    LEXICOGRAPHIC_COMPARISON(prop_t)

 };
 
 };
 

-inline unmarshall & operator>>(unmarshall &u, prop_t &a) {
-    return u >> a.n >> a.m;
-}
+MARSHALLABLE_STRUCT(prop_t)

 
 

-inline marshall & operator<<(marshall &m, prop_t a) {
-    return m << a.n << a.m;
-}
+namespace paxos_protocol {
+    enum status : rpc_protocol::status { OK, ERR };
+    struct prepareres {
+        bool oldinstance;
+        bool accept;
+        prop_t n_a;
+        string v_a;

 
 

-inline unmarshall & operator>>(unmarshall &u, paxos_protocol::preparearg &a) {
-    return u >> a.instance >> a.n;
-}
-
-inline marshall & operator<<(marshall &m, paxos_protocol::preparearg a) {
-    return m << a.instance << a.n;
-}
+        MEMBERS(oldinstance, accept, n_a, v_a)
+    };
+    using node_t = string;
+    using nodes_t = vector<node_t>;
+    using value_t = string;

 
 

-inline unmarshall & operator>>(unmarshall &u, paxos_protocol::prepareres &r) {
-    return u >> r.oldinstance >> r.accept >> r.n_a >> r.v_a;
+    REMOTE_PROCEDURE_BASE(0x11000);
+    REMOTE_PROCEDURE(1, preparereq, (prepareres &, node_t, unsigned, prop_t));
+    REMOTE_PROCEDURE(2, acceptreq, (bool &, node_t, unsigned, prop_t, value_t));
+    REMOTE_PROCEDURE(3, decidereq, (int &, node_t, unsigned, value_t));
+    REMOTE_PROCEDURE(4, heartbeat, (int &, string, unsigned));

 }
 
 }
 

-inline marshall & operator<<(marshall &m, paxos_protocol::prepareres r) {
-    return m << r.oldinstance << r.accept << r.n_a << r.v_a;
-}
-
-inline unmarshall & operator>>(unmarshall &u, paxos_protocol::acceptarg &a) {
-    return u >> a.instance >> a.n >> a.v;
-}
-
-inline marshall & operator<<(marshall &m, paxos_protocol::acceptarg a) {
-    return m << a.instance << a.n << a.v;
-}
-
-inline unmarshall & operator>>(unmarshall &u, paxos_protocol::decidearg &a) {
-    return u >> a.instance >> a.v;
-}
-
-inline marshall & operator<<(marshall &m, paxos_protocol::decidearg a) {
-    return m << a.instance << a.v;
-}
+MARSHALLABLE_STRUCT(paxos_protocol::prepareres)

 
 #endif
 
 #endif