Commit2105d9e

authored and

committed

Fix spill to file threshold check

1 parentccac390 commit2105d9eCopy full SHA for 2105d9e

File tree

-1

lines changed

-1

lines changed

Lines changed: 2 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -504,6 +504,8 @@ MtmAdjustOldestXid(TransactionId xid)`
`504`	`504`	`MtmTransStatets,prev=NULL;`
`505`	`505`	`inti;`
`506`	`506`
	`507`	`+returnFirstNormalTransactionId;`
	`508`	`+`
`507`	`509`	`MtmLock(LW_EXCLUSIVE);`
`508`	`510`	`ts= (MtmTransState*)hash_search(MtmXid2State,&xid,HASH_FIND,NULL);`
`509`	`511`	`if (ts!=NULL&&ts->status==TRANSACTION_STATUS_COMMITTED) {`

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -47,6 +47,7 @@`
`47`	`47`	`#defineMULTIMASTER_ADMIN "mtm_admin"`
`48`	`48`
`49`	`49`	`#defineUSEC 1000000`
	`50`	`+#defineMB (1024*1024)`
`50`	`51`
`51`	`52`	`#defineUSEC_TO_MSEC(t) ((t)/1000)`
`52`	`53`	`#defineMSEC_TO_USEC(t) ((t)*1000)`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -449,7 +449,7 @@ pglogical_receiver_main(Datum main_arg)`
`449`	`449`	`{`
`450`	`450`	`stmt=copybuf+hdr_len;`
`451`	`451`
`452`		`-if (buf.used >=MtmTransSpillThreshold) {`
	`452`	`+if (buf.used >=MtmTransSpillThreshold*MB) {`
`453`	`453`	`if (spill_file<0) {`
`454`	`454`	`intfile_id;`
`455`	`455`	`spill_file=MtmCreateSpillFile(nodeId,&file_id);`

Comments

(0)