transport commit #2

Author: Vladimir Ershov

src/scheduler_mtm.c

@@ -553,6 +553,27 @@ Oid get_mtm_node_func_oid(void)
 	return func_oid;
 }
 
+bool mtm_check_help_byNodeId(int node_id)
+{
+	bool st = true;
+
+	if(!MTM_nodes->node[node_id-1].need_help) return false;
+	LWLockAcquire((LWLockId)&MTM_nodes->locks[0], LW_EXCLUSIVE);
+
+	if(is_mtm_node_available(node_id))
+	{
+		if(!MTM_nodes->nodes[node_id-1].avail)
+		{
+			MTM_nodes->nodes[node_id-1].avail = true;
+			MTM_nodes->nodes[node_id-1].need_help = false;
+			MTM_nodes->need_help--;
+		}
+		st = false;
+	}
+	LWLockRelease((LWLockId)&MTM_nodes->locks[0]);
+	return st;
+}
+
 bool mtm_check_if_node_need_help(char *nodename)
 {
 	char *name;
@@ -577,7 +598,7 @@ bool mtm_check_if_node_need_help(char *nodename)
 			{
 				LWLockRelease((LWLockId)&MTM_nodes->locks[0]);
 				LWLockAcquire((LWLockId)&MTM_nodes->locks[0], LW_EXCLUSIVE);
-				if(!MTM_nodes->nodes[i])->avail)
+				if(!MTM_nodes->nodes[i].avail)
 				{
 					MTM_nodes->nodes[i].avail = true;
 					MTM_nodes->nodes[i].need_help = false;