Add a lock graph dumping function to multimaster sql api.

Author: kvap

multimaster--1.0.sql

@@ -40,6 +40,10 @@ CREATE FUNCTION mtm.make_table_local(relation regclass) RETURNS void
 AS 'MODULE_PATHNAME','mtm_make_table_local'
 LANGUAGE C;
 
+CREATE FUNCTION mtm.dump_lock_graph() RETURNS text
+AS 'MODULE_PATHNAME','mtm_dump_lock_graph'
+LANGUAGE C;
+
 CREATE TABLE IF NOT EXISTS mtm.ddl_log (issued timestamp with time zone not null, query text);
 
 CREATE TABLE IF NOT EXISTS mtm.local_tables(rel_schema text, rel_name text, primary key(rel_schema, rel_name));

multimaster.c

@@ -107,6 +107,7 @@ PG_FUNCTION_INFO_V1(mtm_get_snapshot);
 PG_FUNCTION_INFO_V1(mtm_get_nodes_state);
 PG_FUNCTION_INFO_V1(mtm_get_cluster_state);
 PG_FUNCTION_INFO_V1(mtm_make_table_local);
+PG_FUNCTION_INFO_V1(mtm_dump_lock_graph);
 
 static Snapshot MtmGetSnapshot(Snapshot snapshot);
 static void MtmInitialize(void);
@@ -2153,6 +2154,31 @@ Datum mtm_make_table_local(PG_FUNCTION_ARGS)
 	return false;
 }
 
+Datum mtm_dump_lock_graph(PG_FUNCTION_ARGS)
+{
+	StringInfo s = makeStringInfo();
+	int i;
+	for (i = 0; i < MtmNodes; i++)
+	{
+		size_t size;
+		char *data = RaftableGet(psprintf("lock-graph-%d", i+1), &size, NULL, true);
+		if (!data) continue;
+		GlobalTransactionId *gtid = (GlobalTransactionId *)data;
+		GlobalTransactionId *last = (GlobalTransactionId *)(data + size);
+		appendStringInfo(s, "node-%d lock graph: ", i+1);
+		while (gtid != last) { 
+			GlobalTransactionId *src = gtid++;
+			appendStringInfo(s, "%d:%d -> ", src->node, src->xid);
+			while (gtid->node != 0) {
+				GlobalTransactionId *dst = gtid++;
+				appendStringInfo(s, "%d:%d, ", dst->node, dst->xid);
+			}
+			gtid += 1;
+		}
+		appendStringInfo(s, "\n");
+	}
+	return CStringGetTextDatum(s->data);
+}
 
 /*
  * -------------------------------------------

t/002_dtmbench.pl

@@ -60,7 +60,7 @@ sub allocate_ports
 		listen_addresses = '$host'
 		unix_socket_directories = ''
 		port = $pgport
-		max_prepared_transactions = 10
+		max_prepared_transactions = 1000
 		max_worker_processes = 10
 		wal_level = logical
 		fsync = off	
@@ -103,13 +103,13 @@ sub allocate_ports
 push(@argv, '-n', 1000, '-a', 1000, '-w', 10, '-r', 1);
 
 diag("running dtmbench -i");
-if (TestLib::run_log([@argv, '-i']))
+if (!TestLib::run_log([@argv, '-i']))
 {
 	BAIL_OUT("dtmbench -i failed");
 }
 
 diag("running dtmbench");
-if (TestLib::run_log(\@argv, '>', \$out))
+if (!TestLib::run_log(\@argv, '>', \$out))
 {
 	fail("dtmbench failed");
 }

t/003_pgbench.pl

@@ -62,7 +62,7 @@ sub allocate_ports
 		listen_addresses = '$host'
 		unix_socket_directories = ''
 		port = $pgport
-		max_prepared_transactions = 10
+		max_prepared_transactions = 1000
 		max_worker_processes = 10
 		wal_level = logical
 		fsync = off