pengine.c

linux集群服务器软件代码包

/* $Id: pengine.c,v 1.57 2005/02/19 18:11:04 andrew Exp $ */
/* 
 * Copyright (C) 2004 Andrew Beekhof <[e-mail]>
 * 
 * This program is free software; you can redistribute it and/or
 * modify it under the terms of the GNU General Public
 * License as published by the Free Software Foundation; either
 * version 2.1 of the License, or (at your option) any later version.
 * 
 * This software is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
 * General Public License for more details.
 * 
 * You should have received a copy of the GNU General Public
 * License along with this library; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */
#include <sys/param.h>

#include <crm/crm.h>
#include <crm/cib.h>
#include <crm/msg_xml.h>
#include <crm/common/xml.h>
#include <crm/common/msg.h>

#include <glib.h>

#include <pengine.h>
#include <pe_utils.h>

crm_data_t * do_calculations(crm_data_t *cib_object);
int num_synapse = 0;


gboolean
process_pe_message(HA_Message *msg, crm_data_t * xml_data, IPC_Channel *sender)
{
	const char *sys_to = cl_get_string(msg, F_CRM_SYS_TO);
	const char *op = cl_get_string(msg, F_CRM_TASK);
	const char *ref = cl_get_string(msg, XML_ATTR_REFERENCE);

	crm_verbose("Processing %s op (ref=%s)...", op, ref);
	
	if(op == NULL){
		/* error */

	} else if(strcmp(op, CRM_OP_HELLO) == 0) {
		/* ignore */
		
	} else if(safe_str_eq(cl_get_string(msg, F_CRM_MSG_TYPE),
			      XML_ATTR_RESPONSE)) {
		/* ignore */
		
	} else if(sys_to == NULL || strcmp(sys_to, CRM_SYSTEM_PENGINE) != 0) {
		crm_verbose("Bad sys-to %s", crm_str(sys_to));
		return FALSE;
		
	} else if(strcmp(op, CRM_OP_PECALC) == 0) {
		crm_data_t * output = NULL;

		crm_xml_info(xml_data, "[in ]");
		output = do_calculations(xml_data);
		crm_xml_debug(output, "[out]");

		if (send_ipc_reply(sender, msg, output) ==FALSE) {

			crm_warn("Answer could not be sent");
		}
		free_xml(output);

	} else if(strcmp(op, CRM_OP_QUIT) == 0) {
		crm_warn("Received quit message, terminating");
		exit(0);
	}
	
	return TRUE;
}

crm_data_t *
do_calculations(crm_data_t * cib_object)
{
	GListPtr resources = NULL;
	GListPtr nodes = NULL;
	GListPtr placement_constraints = NULL;
	GListPtr actions = NULL;
	GListPtr ordering_constraints = NULL;
	GListPtr stonith_list = NULL;
	GListPtr shutdown_list = NULL;

	GListPtr colors = NULL;
	GListPtr action_sets = NULL;

	crm_data_t * graph = NULL;

/*	pe_debug_on(); */
	
	crm_verbose("=#=#=#=#= Stage 0 =#=#=#=#=");
		  
	stage0(cib_object,
	       &resources,
	       &nodes,  &placement_constraints,
	       &actions,  &ordering_constraints,
	       &stonith_list, &shutdown_list);

	crm_verbose("=#=#=#=#= Stage 1 =#=#=#=#=");
	stage1(placement_constraints, nodes, resources);

	crm_verbose("=#=#=#=#= Stage 2 =#=#=#=#=");
	stage2(resources, nodes, &colors);

	crm_verbose("========= Nodes =========");
	crm_devel_action(
		slist_iter(node, node_t, nodes, lpc,
			   print_node(NULL, node, TRUE)
			)
		);
		
	crm_verbose("========= Resources =========");
	crm_devel_action(
		slist_iter(resource, resource_t, resources, lpc,
			   print_resource(NULL, resource, TRUE)
			)
		);  
  
	crm_verbose("=#=#=#=#= Stage 3 =#=#=#=#=");
	stage3(colors);

	crm_verbose("=#=#=#=#= Stage 4 =#=#=#=#=");
	stage4(colors);
	crm_verbose("========= Colors =========");
	crm_devel_action(
		slist_iter(color, color_t, colors, lpc,
		   print_color(NULL, color, FALSE)
			)
		);

	crm_verbose("=#=#=#=#= Stage 5 =#=#=#=#=");
	stage5(resources, &ordering_constraints);

	crm_verbose("=#=#=#=#= Stage 6 =#=#=#=#=");
	stage6(&actions, &ordering_constraints, nodes, resources);

	crm_verbose("========= Action List =========");
	crm_devel_action(
		slist_iter(action, action_t, actions, lpc,
			   print_action(NULL, action, TRUE)
			)
		);
	
	crm_verbose("=#=#=#=#= Stage 7 =#=#=#=#=");
	stage7(resources, actions, ordering_constraints);
	
	crm_verbose("========= Action Sets =========");

	crm_verbose("\t========= Set %d (Un-runnable) =========", -1);
	crm_devel_action(
		slist_iter(action, action_t, actions, lpc,
			   if(action->optional == FALSE
			      && action->runnable == FALSE) {
				   print_action("\t", action, TRUE);
			   }
			)
		);

	crm_devel_action(
		slist_iter(action_set, GList, action_sets, lpc,
			   crm_verbose("\t========= Set %d =========", lpc);
			   slist_iter(action, action_t, action_set, lpc2,
				      print_action("\t", action, TRUE);
				   )
			)
		);

	
	crm_verbose("========= Stonith List =========");
	crm_devel_action(
		slist_iter(node, node_t, stonith_list, lpc,
			   print_node(NULL, node, FALSE);
			)
		);
  
	crm_verbose("========= Shutdown List =========");
	crm_devel_action(
		slist_iter(node, node_t, shutdown_list, lpc,
			   print_node(NULL, node, FALSE);
			)
		);

	crm_verbose("=#=#=#=#= Stage 8 =#=#=#=#=");
	stage8(resources, actions, &graph);

	crm_verbose("=#=#=#=#= Cleanup =#=#=#=#=");

	crm_verbose("deleting node cons");
	while(placement_constraints) {
		pe_free_rsc_to_node((rsc_to_node_t*)placement_constraints->data);
		placement_constraints = placement_constraints->next;
	}
	if(placement_constraints != NULL) {
		g_list_free(placement_constraints);
	}

	crm_verbose("deleting order cons");
	pe_free_shallow(ordering_constraints);

	crm_verbose("deleting action sets");

	slist_iter(action_set, GList, action_sets, lpc,
		   pe_free_shallow_adv(action_set, FALSE);
		);
	pe_free_shallow_adv(action_sets, FALSE);
	
	crm_verbose("deleting actions");
	pe_free_actions(actions);

	crm_verbose("deleting resources");
	pe_free_resources(resources); 
	
	crm_verbose("deleting colors");
	pe_free_colors(colors);

	crm_verbose("deleting nodes");
	pe_free_nodes(nodes);

	if(shutdown_list != NULL) {
		g_list_free(shutdown_list);
	}
	if(stonith_list != NULL) {
		g_list_free(stonith_list);
	}
	
	return graph;
}