Commitcb19d6a

committed

fix replica_tests stop_lsn_null_offset

1 parent03e5dce commitcb19d6aCopy full SHA for cb19d6a

File tree

-3

lines changed

-3

lines changed

Lines changed: 4 additions & 3 deletions

Original file line number	Diff line number	Diff line change
`@@ -1658,7 +1658,7 @@ def version_to_num(self, version):`
`1658`	`1658`	`num=num*100+int(re.sub(r"[^\d]","",part))`
`1659`	`1659`	`returnnum`
`1660`	`1660`
`1661`		`-defswitch_wal_segment(self,node,sleep_seconds=1):`
	`1661`	`+defswitch_wal_segment(self,node,sleep_seconds=1,and_tx=False):`
`1662`	`1662`	`"""`
`1663`	`1663`	`Execute pg_switch_wal() in given node`
`1664`	`1664`
`@@ -1667,7 +1667,8 @@ def switch_wal_segment(self, node, sleep_seconds=1):`
`1667`	`1667`	`"""`
`1668`	`1668`	`ifisinstance(node,testgres.PostgresNode):`
`1669`	`1669`	`withnode.connect('postgres')ascon:`
`1670`		`-con.execute('select txid_current()')`
	`1670`	`+ifand_tx:`
	`1671`	`+con.execute('select txid_current()')`
`1671`	`1672`	`con.execute('select pg_switch_wal()')`
`1672`	`1673`	`else:`
`1673`	`1674`	`node.execute('select pg_switch_wal()')`
`@@ -1677,7 +1678,7 @@ def switch_wal_segment(self, node, sleep_seconds=1):`
`1677`	`1678`
`1678`	`1679`	`@contextlib.contextmanager`
`1679`	`1680`	`defswitch_wal_after(self,node,seconds):`
`1680`		`-tm=threading.Timer(seconds,self.switch_wal_segment, [node,0])`
	`1681`	`+tm=threading.Timer(seconds,self.switch_wal_segment, [node,0,True])`
`1681`	`1682`	`tm.start()`
`1682`	`1683`	`try:`
`1683`	`1684`	`yield`

Comments

(0)