don't ask myself about transaction status #2

kelvich · kelvich · commit c00a3c46f07a · 2019-01-31T15:48:32.000+03:00
diff --git a/src/resolver.c b/src/resolver.c
@@ -388,12 +388,12 @@ scatter_status_requests(MtmConfig *mtm_cfg)
 	{
 		int i;
 
-		for (i = 0; i < MTM_MAX_NODES; i++)
+		for (i = 0; i < mtm_cfg->n_nodes; i++)
 		{
-			if (!BIT_CHECK(SELF_CONNECTIVITY_MASK, i) &&
-				i + 1 != mtm_cfg->my_node_id)
+			int			node_id = mtm_cfg->nodes[i].node_id;
+
+			if (!BIT_CHECK(SELF_CONNECTIVITY_MASK, node_id - 1))
 			{
-				int			node_id = i + 1;
 				MtmArbiterMessage msg;
 				DmqDestinationId dest_id;
 

Original file line number	Diff line number	Diff line change
`@@ -388,12 +388,12 @@ scatter_status_requests(MtmConfig *mtm_cfg)`
`388`	`388`	`{`
`389`	`389`	`int i;`
`390`	`390`
`391`		`- for (i = 0; i < MTM_MAX_NODES; i++)`
	`391`	`+ for (i = 0; i < mtm_cfg->n_nodes; i++)`
`392`	`392`	`{`
`393`		`- if (!BIT_CHECK(SELF_CONNECTIVITY_MASK, i) &&`
`394`		`- i + 1 != mtm_cfg->my_node_id)`
	`393`	`+ int node_id = mtm_cfg->nodes[i].node_id;`
	`394`	`+`
	`395`	`+ if (!BIT_CHECK(SELF_CONNECTIVITY_MASK, node_id - 1))`
`395`	`396`	`{`
`396`		`- int node_id = i + 1;`
`397`	`397`	`MtmArbiterMessage msg;`
`398`	`398`	`DmqDestinationId dest_id;`
`399`	`399`