gitops/patroni
1
0
Fork 0
mirror of https://github.com/outbackdingo/patroni.git synced 2026-09-01 00:59:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

compare xlog positions based on bytes since 0/000000 based on feedback

Browse Source
This commit is contained in:
Christopher Winslett
2015-05-10 19:36:59 -07:00
parent 1879b9c76a
commit 36c4c31e83
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
helpers/postgresql.py
+2 -2
View File
@@ -126,7 +126,7 @@ class Postgresql:
member_conn = psycopg2.connect(member["address"])
member_conn.autocommit = True
member_cursor = member_conn.cursor()
member_cursor.execute("SELECT '%s'::pg_lsn - pg_last_xlog_replay_location() AS bytes;" % self.xlog_position())
member_cursor.execute("SELECT %s - (pg_last_xlog_replay_location() - '0/000000'::pg_lsn) AS bytes;" % self.xlog_position())
xlog_diff = member_cursor.fetchone()[0]
logger.info([self.name, member["hostname"], xlog_diff])
if xlog_diff < 0:
@@ -181,4 +181,4 @@ recovery_target_timeline = 'latest'
self.query("CREATE USER \"%s\" WITH REPLICATION ENCRYPTED PASSWORD '%s';" % (self.replication["username"], self.replication["password"]))
def xlog_position(self):
return self.query("SELECT pg_last_xlog_replay_location();").fetchone()[0]
return self.query("SELECT pg_last_xlog_replay_location() - '0/0000000'::pg_lsn;").fetchone()[0]