gitops/patroni
1
0
Fork 0
mirror of https://github.com/outbackdingo/patroni.git synced 2026-08-25 14:53:37 +00:00
Code Issues Packages Projects Releases Wiki Activity

Make it possible to compare xlog location against replica (#396)

Browse Source
This commit is contained in:
Alexander Kukushkin
2017-02-16 17:07:34 +01:00
committed by GitHub
parent 3ece35c0a6
commit 0443844f65
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
patroni/scripts/wale_restore.py
+10 -2
View File
@@ -133,8 +133,16 @@ class WALERestore(object):
with psycopg2.connect(self.master_connection) as con:
con.autocommit = True
with con.cursor() as cur:
cur.execute("SELECT pg_xlog_location_diff(pg_current_xlog_location(), %s)",
(backup_start_lsn,))
cur.execute("""SELECT CASE WHEN pg_is_in_recovery()
THEN GREATEST(
pg_xlog_location_diff(COALESCE(
pg_last_xlog_receive_location(), '0/0'), %s)::bigint,
pg_xlog_location_diff(
pg_last_xlog_replay_location(), %s)::bigint)
ELSE pg_xlog_location_diff(
pg_current_xlog_location(), %s)::bigint
END""", (backup_start_lsn, backup_start_lsn, backup_start_lsn))
diff_in_bytes = int(cur.fetchone()[0])
except psycopg2.Error:
logger.exception('could not determine difference with the master location')