github/repmgr
1
0
Fork 0
mirror of https://github.com/EnterpriseDB/repmgr.git synced 2026-03-26 16:46:28 +00:00
Code Issues Packages Projects Releases 1 Wiki Activity

no longer use global variable for SQL query buffer

Browse Source
This commit is contained in:
Christian Kruse
2014-03-06 18:23:36 +01:00
committed by Jaime Casanova
parent b35bf3f91d
commit 8f0b9592e8
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
repmgrd.c
View File

@@ -91,8 +91,6 @@ PGconn *my_local_conn = NULL;
/* Primary info */ /* Primary info */
t_configuration_options primary_options; t_configuration_options primary_options;
char sqlquery[QUERY_STR_LEN];
PGconn *primary_conn = NULL; PGconn *primary_conn = NULL;
const char *progname; const char *progname;
@@ -501,6 +499,7 @@ witness_monitor(void)
{ {
char monitor_witness_timestamp[MAXLEN]; char monitor_witness_timestamp[MAXLEN];
PGresult *res; PGresult *res;
char sqlquery[QUERY_STR_LEN];
/* /*
* Check if the master is still available, if after 5 minutes of retries * Check if the master is still available, if after 5 minutes of retries
@@ -586,6 +585,7 @@ standby_monitor(void)
char last_wal_standby_received[MAXLEN]; char last_wal_standby_received[MAXLEN];
char last_wal_standby_applied[MAXLEN]; char last_wal_standby_applied[MAXLEN];
char last_wal_standby_applied_timestamp[MAXLEN]; char last_wal_standby_applied_timestamp[MAXLEN];
char sqlquery[QUERY_STR_LEN];
unsigned long long int lsn_primary; unsigned long long int lsn_primary;
unsigned long long int lsn_standby_received; unsigned long long int lsn_standby_received;
@@ -777,7 +777,7 @@ static void
do_failover(void) do_failover(void)
{ {
PGresult *res; PGresult *res;
char sqlquery[8192]; char sqlquery[QUERY_STR_LEN];
int total_nodes = 0; int total_nodes = 0;
int visible_nodes = 0; int visible_nodes = 0;
@@ -1219,6 +1219,7 @@ static void
check_cluster_configuration(PGconn *conn) check_cluster_configuration(PGconn *conn)
{ {
PGresult *res; PGresult *res;
char sqlquery[QUERY_STR_LEN];
log_info(_("%s Checking cluster configuration with schema '%s'\n"), log_info(_("%s Checking cluster configuration with schema '%s'\n"),
progname, repmgr_schema); progname, repmgr_schema);
@@ -1254,6 +1255,7 @@ static void
check_node_configuration(void) check_node_configuration(void)
{ {
PGresult *res; PGresult *res;
char sqlquery[QUERY_STR_LEN];
/* /*
* Check if we have my node information in repl_nodes * Check if we have my node information in repl_nodes
@@ -1396,6 +1398,7 @@ static void
update_shared_memory(char *last_wal_standby_applied) update_shared_memory(char *last_wal_standby_applied)
{ {
PGresult *res; PGresult *res;
char sqlquery[QUERY_STR_LEN];
sprintf(sqlquery, "SELECT %s.repmgr_update_standby_location('%s')", sprintf(sqlquery, "SELECT %s.repmgr_update_standby_location('%s')",
repmgr_schema, last_wal_standby_applied); repmgr_schema, last_wal_standby_applied);
@@ -1422,6 +1425,7 @@ static void
update_registration(void) update_registration(void)
{ {
PGresult *res; PGresult *res;
char sqlquery[QUERY_STR_LEN];
sqlquery_snprintf(sqlquery, "UPDATE %s.repl_nodes " sqlquery_snprintf(sqlquery, "UPDATE %s.repl_nodes "
" SET conninfo = '%s', " " SET conninfo = '%s', "