Commitac1ac79

authored and

committed

Avoid long transactions in inspect task

1 parentc7f8cde commitac1ac79Copy full SHA for ac1ac79

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -529,7 +529,7 @@ MtmAdjustOldestXid(TransactionId xid)`
`529`	`529`	`if (prev!=NULL) {`
`530`	`530`	`Mtm->transListHead=prev;`
`531`	`531`	`Mtm->oldestXid=xid=prev->xid;`
`532`		`-MTM_LOG2("%d: MtmAdjustOldestXid: oldestXid=%d,olderstSnapshot=%ld",MyProcPid,xid,oldestSnapshot);`
	`532`	`+MTM_LOG2("%d: MtmAdjustOldestXid: oldestXid=%d,oldestSnapshot=%ld",MyProcPid,xid,oldestSnapshot);`
`533`	`533`	`}elseif (TransactionIdPrecedes(Mtm->oldestXid,xid)) {`
`534`	`534`	`xid=Mtm->oldestXid;`
`535`	`535`	`}`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -102,6 +102,7 @@ def check_total(self):`
`102`	`102`	`deftx(conn,cur):`
`103`	`103`	`cur.execute('select sum(amount) from bank_test')`
`104`	`104`	`res=cur.fetchone()`
	`105`	`+conn.commit()`
`105`	`106`	`ifres[0]!=0:`
`106`	`107`	`print("Isolation error, total = %d"% (res[0],))`
`107`	`108`	`raiseBaseException`

Comments

(0)