Commite5a4bfb

authored and

committed

FIX

1 parent3b66506 commite5a4bfbCopy full SHA for e5a4bfb

File tree

+16

-10

lines changed

+16

-10

lines changed

Lines changed: 14 additions & 8 deletions

Original file line number	Diff line number	Diff line change
`@@ -142,14 +142,18 @@ WaitLSNSetLatch(void)`
`142`	`142`	`void`
`143`	`143`	`WaitLSNUtility(constchar*lsn,constintdelay)`
`144`	`144`	`{`
`145`		`-XLogRecPtrtrg_lsn;`
`146`		`-XLogRecPtrcur_lsn;`
`147`		`-intlatch_events;`
`148`		`-inttdelay=delay;`
`149`		`-TimestampTztimer=GetCurrentTimestamp();`
	`145`	`+XLogRecPtrtrg_lsn;`
	`146`	`+XLogRecPtrcur_lsn;`
	`147`	`+intlatch_events;`
	`148`	`+uint_fast64_ttdelay=delay;`
	`149`	`+longsecs;`
	`150`	`+intmicrosecs;`
	`151`	`+TimestampTztimer=GetCurrentTimestamp();`
	`152`	`+`
`150`	`153`	`trg_lsn=DatumGetLSN(DirectFunctionCall1(pg_lsn_in,CStringGetDatum(lsn)));`
	`154`	`+//tdelay *= 1000;`
`151`	`155`
`152`		`-tdelay *=1000;`
	`156`	`+elog(LOG,"ACHTUNG tdelay %u",tdelay);`
`153`	`157`
`154`	`158`	`if (delay>0)`
`155`	`159`	`latch_events=WL_LATCH_SET \|WL_TIMEOUT \|WL_POSTMASTER_DEATH;`
`@@ -174,9 +178,11 @@ WaitLSNUtility(const char *lsn, const int delay)`
`174`	`178`	`/* If Delay time is over */`
`175`	`179`	`if (latch_events&WL_TIMEOUT)`
`176`	`180`	`{`
`177`		`-tdelay-= (GetCurrentTimestamp()-timer);`
`178`		`-if (tdelay <=0)`
	`181`	`+if (TimestampDifferenceExceeds(timer,GetCurrentTimestamp(),tdelay))`
`179`	`182`	`break;`
	`183`	`+TimestampDifference(timer,GetCurrentTimestamp(),&secs,&microsecs);`
	`184`	`+tdelay-= (secs*1000+microsecs/1000);`
	`185`	`+elog(LOG,"ACHTUNG tdelay %u, %d",tdelay,TimestampDifferenceExceeds(timer,GetCurrentTimestamp(),tdelay));`
`180`	`186`	`timer=GetCurrentTimestamp();`
`181`	`187`	`}`
`182`	`188`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -913,7 +913,7 @@ standard_ProcessUtility(Node *parsetree,`
`913`	`913`	`"WaitLSN")));`
`914`	`914`	`}`
`915`	`915`	`else`
`916`		`-WaitLSNUtility(stmt->lsn,*stmt->delay);`
	`916`	`+WaitLSNUtility(stmt->lsn,stmt->delay);`
`917`	`917`	`}`
`918`	`918`	`break;`
`919`	`919`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -3115,7 +3115,7 @@ typedef struct WaitLSNStmt`
`3115`	`3115`	`{`
`3116`	`3116`	`NodeTagtype;`
`3117`	`3117`	`charlsn;/ Taraget LSN to wait for */`
`3118`		`-intdelay;/ Delay to wait for LSN*/`
	`3118`	`+intdelay;/* Delay to wait for LSN*/`
`3119`	`3119`	`}WaitLSNStmt;`
`3120`	`3120`
`3121`	`3121`	`#endif/* PARSENODES_H */`

Comments

(0)