Start resolver before receiver.

Trying to unstuck logical slot creation after basebackup.

Author: kelvich

src/state.c

@@ -1036,7 +1036,7 @@ MtmGetCurrentStatus()
 nodemask_t
 MtmGetConnectedNodeMask()
 {
-	return mtm_state->connected_mask;
+	return mtm_state->connected_mask & mtm_state->dmq_senders_mask;
 }
 
 nodemask_t
@@ -1582,6 +1582,10 @@ MtmMonitor(Datum arg)
 
 	dmq_stream_subscribe("txreq");
 
+	/* Launch resolver */
+	Assert(resolver == NULL);
+	resolver = ResolverStart(db_id, user_id);
+
 	for (;;)
 	{
 		int rc;
@@ -1635,11 +1639,6 @@ MtmMonitor(Datum arg)
 			config_valid = true;
 		}
 
-		/* Launch resolver after we added dmq destinations */
-		// XXX: that's because of current use of Mtm->peers[].dmq_dest_id
-		if (resolver == NULL)
-			resolver = ResolverStart(db_id, user_id);
-
 		// XXX: add tx start/stop to clear mcxt?
 		check_status_requests(mtm_cfg);
 

tests/lib/bank_client.py

@@ -88,6 +88,8 @@ def __init__(self, dsns, n_accounts=100000):
 
         self.initdb()
 
+        print('initialized')
+
         self.nodes_state_fields = ["id", "disabled", "disconnected", "catchUp", "slotLag",
             "avgTransDelay", "lastStatusChange", "oldestSnapshot", "SenderPid",
             "SenderStartTime ", "ReceiverPid", "ReceiverStartTime", "connStr"]
@@ -168,7 +170,7 @@ def create_extension(self):
         cur = conn.cursor()
         cur.execute("select mtm.init_cluster($$%s$$, $${%s}$$);" %
             ("dbname=regression user=pg host=node1",
-            '"dbname=regression user=pg host=node2"'))
+            '"dbname=regression user=pg host=node2", "dbname=regression user=pg host=node3"'))
         conn.commit()
         cur.close()
         conn.close()