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

repmgrd: catch corner cases where monitoring data is not available

Browse Source
This commit is contained in:
Ian Barwick
2017-11-09 22:27:09 +09:00
parent fed17d49e3
commit de577adc67
1 changed files with 16 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
repmgrd-physical.c
View File

@@ -1176,14 +1176,25 @@ update_monitoring_history(void)
return; return;
} }
/*
* this can be the case when a standby is starting up after following
* a new primary
*/
if (replication_info.receiving_streamed_wal == false) if (replication_info.receiving_streamed_wal == false)
{ {
log_verbose(LOG_DEBUG, _("standby %i not connected to streaming replication"), log_verbose(LOG_WARNING, _("standby %i not connected to streaming replication"),
local_node_info.node_id); local_node_info.node_id);
return;
} }
primary_last_wal_location = get_current_wal_lsn(primary_conn); primary_last_wal_location = get_current_wal_lsn(primary_conn);
if (primary_last_wal_location == InvalidXLogRecPtr)
{
log_warning(_("unable to retrieve primary's current LSN"));
return;
}
/* calculate apply lag in bytes */ /* calculate apply lag in bytes */
if (replication_info.last_wal_receive_lsn >= replication_info.last_wal_replay_lsn) if (replication_info.last_wal_receive_lsn >= replication_info.last_wal_replay_lsn)
{ {
@@ -1548,7 +1559,8 @@ notify_followers(NodeInfoList *standby_nodes, int follow_node_id)
{ {
NodeInfoListCell *cell; NodeInfoListCell *cell;
log_debug("notify_followers(): %i followers to notify", standby_nodes->node_count); log_verbose(LOG_NOTICE, "%i followers to notify",
standby_nodes->node_count);
for (cell = standby_nodes->head; cell; cell = cell->next) for (cell = standby_nodes->head; cell; cell = cell->next)
{ {
@@ -1567,8 +1579,8 @@ notify_followers(NodeInfoList *standby_nodes, int follow_node_id)
continue; continue;
} }
log_debug("notifying node %i to follow node %i", log_verbose(LOG_NOTICE, "notifying node %i to follow node %i",
cell->node_info->node_id, follow_node_id); cell->node_info->node_id, follow_node_id);
notify_follow_primary(cell->node_info->conn, follow_node_id); notify_follow_primary(cell->node_info->conn, follow_node_id);
} }
} }