Browse Source

quorum: integrate votequorum and ykd correctly

the problem is mostly in votequorum here, where votequorum_exec is
initialized with or without votequorum being configured as quorum
provider.

re-establish init order (regression from dropping lcrso) and make
sure we init correctly only the module configured.

ykd changes are for consistency only at this point in time.

Signed-off-by: Fabio M. Di Nitto <fdinitto@redhat.com>
Reviewed-by: Angus Salkeld <asalked@redhat.com>
Fabio M. Di Nitto 14 năm trước cách đây
mục cha
commit
3bf1ae7718
2 tập tin đã thay đổi với 22 bổ sung12 xóa
  1. 13 11
      exec/votequorum.c
  2. 9 1
      exec/vsf_ykd.c

+ 13 - 11
exec/votequorum.c

@@ -58,6 +58,7 @@ LOGSYS_DECLARE_SUBSYS ("VOTEQ");
  */
 
 static struct corosync_api_v1 *corosync_api;
+static int votequorum_configured = 0;
 
 /*
  * votequorum global config vars
@@ -221,8 +222,6 @@ static quorum_set_quorate_fn_t quorum_callback;
  * votequorum_exec handler and definitions
  */
 
-static int votequorum_exec_init_fn (struct corosync_api_v1 *api);
-
 static void message_handler_req_exec_votequorum_nodeinfo (
 	const void *message,
 	unsigned int nodeid);
@@ -329,7 +328,6 @@ static struct corosync_service_engine votequorum_service_engine = {
 	.lib_exit_fn			= quorum_lib_exit_fn,
 	.lib_engine			= quorum_lib_service,
 	.lib_engine_count		= sizeof (quorum_lib_service) / sizeof (struct corosync_lib_handler),
-	.exec_init_fn			= votequorum_exec_init_fn,
 	.exec_engine			= votequorum_exec_engine,
 	.exec_engine_count		= sizeof (votequorum_exec_engine) / sizeof (struct corosync_exec_handler),
 	.confchg_fn			= votequorum_confchg_fn,
@@ -1068,13 +1066,6 @@ static int votequorum_exec_init_fn (struct corosync_api_v1 *api)
 
 	ENTER();
 
-	corosync_api = api;
-
-	if (!api) {
-		LEAVE();
-		return (1);
-	}
-
 	list_init(&cluster_members_list);
 	list_init(&trackers_list);
 
@@ -1140,6 +1131,11 @@ static void votequorum_confchg_fn (
 
 	ENTER();
 
+	if (votequorum_configured == 0) {
+		LEAVE();
+		return;
+	}
+
 	if (member_list_entries > 1) {
 		first_trans = 0;
 	}
@@ -1205,11 +1201,17 @@ cs_error_t votequorum_init(struct corosync_api_v1 *api,
 	}
 
 	corosync_api = api;
-
 	quorum_callback = q_set_quorate_fn;
 
 	votequorum_readconfig_static();
 
+	if (votequorum_exec_init_fn(api) != 0) {
+		LEAVE();
+		return CS_ERR_NO_MEMORY;
+	}
+
+	votequorum_configured = 1;
+
 	LEAVE();
 
 	return CS_OK;

+ 9 - 1
exec/vsf_ykd.c

@@ -1,6 +1,6 @@
 /*
  * Copyright (c) 2005 MontaVista Software, Inc.
- * Copyright (c) 2006-2009 Red Hat, Inc.
+ * Copyright (c) 2006-2009, 2012 Red Hat, Inc.
  *
  * All rights reserved.
  *
@@ -146,6 +146,8 @@ hdb_handle_t schedwrk_state_send_callback_handle;
 
 static struct corosync_api_v1 *api;
 
+static int ykd_configured = 0;
+
 static void (*ykd_primary_callback_fn) (
 	const unsigned int *view_list,
 	size_t view_list_entries,
@@ -463,6 +465,10 @@ static void ykd_confchg_fn (
 {
 	int i;
 
+	if (ykd_configured == 0) {
+		return;
+	}
+
 	if (configuration_type != TOTEM_CONFIGURATION_REGULAR) {
 		return;
 	}
@@ -519,6 +525,8 @@ cs_error_t ykd_init (
 		return CS_ERR_INVALID_PARAM;
 	}
 
+	ykd_configured = 1;
+
 	api->tpg_init (
 		&ykd_group_handle,
 		ykd_deliver_fn,