501 static void clear_command_node_result(WDCommandNodeResult * nodeResult);
825 clear_command_node_result(WDCommandNodeResult * nodeResult)  in clear_command_node_result()  argument
827 	nodeResult->result_type = WD_NO_MESSAGE;  in clear_command_node_result()
828 	nodeResult->result_data = NULL;  in clear_command_node_result()
829 	nodeResult->result_data_len = 0;  in clear_command_node_result()
830 	nodeResult->cmdState = COMMAMD_STATE_INIT;  in clear_command_node_result()
4430 			WDCommandNodeResult *nodeResult = &ipcCommand->nodeResults[i];  in wd_command_processor_for_node_lost_event()  local
4432 			if (nodeResult->wdNode == wdLostNode)  in wd_command_processor_for_node_lost_event()
4434 				if (nodeResult->cmdState == COMMAND_STATE_SENT)  in wd_command_processor_for_node_lost_event()
4444 					nodeResult->cmdState = COMMAND_STATE_DO_NOT_SEND;  in wd_command_processor_for_node_lost_event()
4559 				WDCommandNodeResult *nodeResult = &ipcCommand->nodeResults[i];  in service_ipc_commands()  local
4561 				if (nodeResult->cmdState == COMMAND_STATE_SEND_ERROR)  in service_ipc_commands()
4563 					if (is_node_active_and_reachable(nodeResult->wdNode))  in service_ipc_commands()
4566 …(errmsg("remote node \"%s\" is reachable again, resending the command packet ", nodeResult->wdNode…  in service_ipc_commands()
4568 						if (send_message_to_node(nodeResult->wdNode, &ipcCommand->commandPacket) == true)  in service_ipc_commands()
4570 							nodeResult->cmdState = COMMAND_STATE_SENT;  in service_ipc_commands()
4606 			WDCommandNodeResult *nodeResult = &clusterCommand->nodeResults[i];  in service_internal_command()  local
4608 			if (nodeResult->cmdState == COMMAND_STATE_SEND_ERROR)  in service_internal_command()
4610 				if (is_node_active_and_reachable(nodeResult->wdNode))  in service_internal_command()
4612 					if (send_message_to_node(nodeResult->wdNode, &clusterCommand->commandPacket) == true)  in service_internal_command()
4614 						nodeResult->cmdState = COMMAND_STATE_SENT;  in service_internal_command()
4699 	WDCommandNodeResult *nodeResult = NULL;  in watchdog_internal_command_packet_processor()  local
4720 			nodeResult = nodeRes;  in watchdog_internal_command_packet_processor()
4724 	if (nodeResult == NULL)  in watchdog_internal_command_packet_processor()
4731 …(errmsg("Watchdog node \"%s\" has replied for command id %d", nodeResult->wdNode->nodeName, pkt->c…  in watchdog_internal_command_packet_processor()
4733 	nodeResult->result_type = pkt->type;  in watchdog_internal_command_packet_processor()
4734 	nodeResult->cmdState = COMMAND_STATE_REPLIED;  in watchdog_internal_command_packet_processor()
4847 			WDCommandNodeResult *nodeResult = &clusterCommand->nodeResults[i];  in issue_watchdog_internal_command()  local
4849 			clear_command_node_result(nodeResult);  in issue_watchdog_internal_command()
4850 			if (is_node_active(nodeResult->wdNode) == false)  in issue_watchdog_internal_command()
4853 …(errmsg("not sending watchdog internal command packet to DEAD %s", nodeResult->wdNode->nodeName)));  in issue_watchdog_internal_command()
4855 				nodeResult->cmdState = COMMAND_STATE_DO_NOT_SEND;  in issue_watchdog_internal_command()
4859 				if (send_message_to_node(nodeResult->wdNode, pkt) == false)  in issue_watchdog_internal_command()
4862 							(errmsg("failed to send watchdog internal command packet %s", nodeResult->wdNode->nodeName),  in issue_watchdog_internal_command()
4867 					nodeResult->cmdState = COMMAND_STATE_SEND_ERROR;  in issue_watchdog_internal_command()
4871 					nodeResult->cmdState = COMMAND_STATE_SENT;  in issue_watchdog_internal_command()
4879 		WDCommandNodeResult *nodeResult = NULL;  in issue_watchdog_internal_command()  local
4887 				nodeResult = nodeRes;  in issue_watchdog_internal_command()
4889 		if (nodeResult == NULL)  in issue_watchdog_internal_command()
4897 		if (send_message_to_node(nodeResult->wdNode, pkt) == false)  in issue_watchdog_internal_command()
4901 			nodeResult->cmdState = COMMAND_STATE_SEND_ERROR;  in issue_watchdog_internal_command()
4905 			nodeResult->cmdState = COMMAND_STATE_SENT;  in issue_watchdog_internal_command()
7173 	WDCommandNodeResult *nodeResult = NULL;  in reply_is_received_for_pgpool_replicate_command()  local
7181 		nodeResult = &ipcCommand->nodeResults[i];  in reply_is_received_for_pgpool_replicate_command()
7182 		if (nodeResult->wdNode == wdNode)  in reply_is_received_for_pgpool_replicate_command()
7184 		nodeResult = NULL;  in reply_is_received_for_pgpool_replicate_command()
7186 	if (nodeResult == NULL)  in reply_is_received_for_pgpool_replicate_command()
7193 	nodeResult->result_type = pkt->type;  in reply_is_received_for_pgpool_replicate_command()
7194 	nodeResult->cmdState = COMMAND_STATE_REPLIED;  in reply_is_received_for_pgpool_replicate_command()
7724 		WDCommandNodeResult *nodeResult = &ipcCommand->nodeResults[i];  in send_command_packet_to_remote_nodes()  local
7726 		if (ipcCommand->sendToNode != NULL && ipcCommand->sendToNode != nodeResult->wdNode)  in send_command_packet_to_remote_nodes()
7732 			nodeResult->cmdState = COMMAND_STATE_DO_NOT_SEND;  in send_command_packet_to_remote_nodes()
7734 		else if (source_included == false && ipcCommand->sourceWdNode == nodeResult->wdNode &&  in send_command_packet_to_remote_nodes()
7739 							ipcCommand->commandPacket.type, nodeResult->wdNode->nodeName)));  in send_command_packet_to_remote_nodes()
7745 			nodeResult->cmdState = COMMAND_STATE_DO_NOT_SEND;  in send_command_packet_to_remote_nodes()
7747 		else if (is_node_active(nodeResult->wdNode) == false)  in send_command_packet_to_remote_nodes()
7749 			nodeResult->cmdState = COMMAND_STATE_DO_NOT_SEND;  in send_command_packet_to_remote_nodes()
7751 		else if (is_node_reachable(nodeResult->wdNode) == false)  in send_command_packet_to_remote_nodes()
7753 			nodeResult->cmdState = COMMAND_STATE_SEND_ERROR;  in send_command_packet_to_remote_nodes()
7756 		else if (send_message_to_node(nodeResult->wdNode, &ipcCommand->commandPacket) == true)  in send_command_packet_to_remote_nodes()
7760 							ipcCommand->commandPacket.type, nodeResult->wdNode->nodeName)));  in send_command_packet_to_remote_nodes()
7762 			nodeResult->cmdState = COMMAND_STATE_SENT;  in send_command_packet_to_remote_nodes()
7767 			nodeResult->cmdState = COMMAND_STATE_SEND_ERROR;  in send_command_packet_to_remote_nodes()
7894 			WDCommandNodeResult* nodeResult = &ipcCommand->nodeResults[i];  in update_missed_beacon_count()  local
7898 			if (nodeResult->cmdState == COMMAND_STATE_SENT)  in update_missed_beacon_count()
7900 				if (nodeResult->wdNode->state == WD_STANDBY)  in update_missed_beacon_count()
7902 					nodeResult->wdNode->missed_beacon_count++;  in update_missed_beacon_count()
7903 					if (nodeResult->wdNode->missed_beacon_count > 1)  in update_missed_beacon_count()
7905 							(errmsg("remote node \"%s\" is not replying to our beacons",nodeResult->wdNode->nodeName),  in update_missed_beacon_count()
7906 							 errdetail("missed beacon reply count:%d",nodeResult->wdNode->missed_beacon_count)));  in update_missed_beacon_count()
7909 					nodeResult->wdNode->missed_beacon_count = 0;  in update_missed_beacon_count()
7911 			if (nodeResult->cmdState == COMMAND_STATE_REPLIED)  in update_missed_beacon_count()
7913 				if (nodeResult->wdNode->missed_beacon_count > 0)  in update_missed_beacon_count()
7915 …(errmsg("remote node \"%s\" is replying again after missing %d beacons",nodeResult->wdNode->nodeNa…  in update_missed_beacon_count()
7916 									nodeResult->wdNode->missed_beacon_count)));  in update_missed_beacon_count()
7917 				nodeResult->wdNode->missed_beacon_count = 0;  in update_missed_beacon_count()