Commitbdafca6

committed

Add check for proper pg_dtm initialization

1 parenta26fa2a commitbdafca6Copy full SHA for bdafca6

File tree

-2

lines changed

-2

lines changed

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -792,7 +792,9 @@ Datum`
`792`	`792`	`dtm_begin_transaction(PG_FUNCTION_ARGS)`
`793`	`793`	`{`
`794`	`794`	`Assert(!TransactionIdIsValid(DtmNextXid));`
`795`		`-`
	`795`	`+if (dtm==NULL) {`
	`796`	`+elog(ERROR,"DTM is not properly initialized, please check that pg_dtm plugin was added to shared_preload_libraries list in postgresql.conf");`
	`797`	`+ }`
`796`	`798`	`DtmNextXid=DtmGlobalStartTransaction(&DtmSnapshot,&dtm->minXid);`
`797`	`799`	`Assert(TransactionIdIsValid(DtmNextXid));`
`798`	`800`	`XTM_INFO("%d: Start global transaction %d, dtm->minXid=%d\n",getpid(),DtmNextXid,dtm->minXid);`

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -210,8 +210,9 @@ func main() {`
`210`	`210`	`vartransferWg sync.WaitGroup`
`211`	`211`	`varinspectWg sync.WaitGroup`
`212`	`212`
	`213`	`+fmt.Printf("Initialing database...\n")`
`213`	`214`	`prepare_db()`
`214`		`-`
	`215`	`+`
`215`	`216`	`cCommits:=make(chanint)`
`216`	`217`	`cAborts:=make(chanint)`
`217`	`218`	`goprogress(TRANSFER_CONNECTIONS*N_ITERATIONS,cCommits,cAborts)`

Comments

(0)