From 36d5b5bc245012627d1728ed89e22dbf4915f000 Mon Sep 17 00:00:00 2001
From: Jaime Casanova <jaime@2ndQuadrant.com>
Date: Thu, 26 Apr 2012 12:29:04 -0500
Subject: [PATCH] I need a local connection to get the master of the cluster

---
 repmgr.c | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/repmgr.c b/repmgr.c
index 3e5dd0a9..79195ec4 100644
--- a/repmgr.c
+++ b/repmgr.c
@@ -399,20 +399,29 @@ static void
 do_cluster_cleanup(void)
 {
 	int			master_id;
+	PGconn	 *conn; 
 	PGconn	 *master_conn;
 	PGresult *res;
 	char	 sqlquery[QUERY_STR_LEN];
 
+	/* I need a connection to my local db to know what node is the master */
+	log_info(_("%s connecting to database\n"), progname);
+	conn = establishDBConnection(options.conninfo, true);
+
 	/* check if there is a master in this cluster */
 	log_info(_("%s connecting to master database\n"), progname);
-	master_conn = getMasterConnection(master_conn, options.node, options.cluster_name,
+	master_conn = getMasterConnection(conn, options.node, options.cluster_name,
 	                                  &master_id, NULL);
 	if (!master_conn)
 	{
 		log_err(_("cluster cleanup: cannot connect to master\n"));
+		PQfinish(conn);
 		exit(ERR_DB_CON);
 	}
 
+	/* I don't need a local connection anymore */
+	PQfinish(conn);
+
 	if (runtime_options.keep_history > 0)
 	{
 		sqlquery_snprintf(sqlquery, "DELETE FROM %s.repl_monitor "