Collect in memory state of completed transactions

rescrv · Apr 18, 2017 · b42bbf3 · b42bbf3
1 parent 7b4657e
commit b42bbf3
Show file tree

Hide file tree

Showing 9 changed files with 231 additions and 49 deletions.
diff --git a/common/network_msgtype.cc b/common/network_msgtype.cc
@@ -48,6 +48,7 @@ consus :: operator << (std::ostream& lhs, network_msgtype rhs)
         STRINGIFY(TXMAN_ABORT);
         STRINGIFY(TXMAN_WOUND);
         STRINGIFY(TXMAN_HOLD_LOCK);
+        STRINGIFY(TXMAN_FINISHED);
         STRINGIFY(TXMAN_PAXOS_2A);
         STRINGIFY(TXMAN_PAXOS_2B);
         STRINGIFY(LV_VOTE_1A);

diff --git a/common/network_msgtype.h b/common/network_msgtype.h
@@ -51,6 +51,7 @@ enum network_msgtype
     TXMAN_ABORT     = 7428,
     TXMAN_WOUND     = 7429,
     TXMAN_HOLD_LOCK = 7430,
+    TXMAN_FINISHED  = 7431,
 
     TXMAN_PAXOS_2A  = 7439,
     TXMAN_PAXOS_2B  = 7433,

diff --git a/kvs/daemon.cc b/kvs/daemon.cc
@@ -628,6 +628,7 @@ daemon :: loop(size_t thread)
             case TXMAN_ABORT:
             case TXMAN_WOUND:
             case TXMAN_HOLD_LOCK:
+            case TXMAN_FINISHED:
             case TXMAN_PAXOS_2A:
             case TXMAN_PAXOS_2B:
             case LV_VOTE_1A: