merge

Author: kelvich

contrib/mmts/tests2/docker-entrypoint.sh

@@ -73,6 +73,7 @@ if [ "$1" = 'postgres' ]; then
 			max_replication_slots = 10
 			max_wal_senders = 10
 			shared_preload_libraries = 'raftable,multimaster'
+            		default_transaction_isolation = 'repeatable read'
 			log_checkpoints = on
 			log_autovacuum_min_duration = 0
 

contrib/mmts/tests2/lib/event_history.py

@@ -1,3 +1,4 @@
+from __future__ import print_function
 import time
 import datetime
 import uuid

contrib/raftable/raft/include/util.h

@@ -48,6 +48,7 @@ struct timeval ms2tv(int ms);
 
 #define shout(...) \
 	do { \
+		fprintf(stderr, "RAFT: "); \
 		fprintf(stderr, __VA_ARGS__); \
 		fflush(stderr); \
 	} while (0)

contrib/raftable/raft/src/raft.c

@@ -649,7 +649,7 @@ void raft_tick(raft_t r, int msec) {
 	if (r->timer < 0) {
 		switch (r->role) {
 			case FOLLOWER:
-				debug(
+				shout(
 					"lost the leader,"
 					" claiming leadership\n"
 				);
@@ -659,7 +659,7 @@ void raft_tick(raft_t r, int msec) {
 				raft_claim(r);
 				break;
 			case CANDIDATE:
-				debug(
+				shout(
 					"the vote failed,"
 					" claiming leadership\n"
 				);
@@ -1055,6 +1055,7 @@ static void raft_handle_claim(raft_t r, raft_msg_claim_t *m) {
 		reply.granted = true;
 	}
 finish:
+	shout("voting %s\n", reply.granted ? "yes" : "no");
 	raft_send(r, candidate, &reply, sizeof(reply));
 }