Commitbeef2ce

committed

Replace nanosleep() with pg_usleep since Windows doesn't have it.

1 parent7f4b13e commitbeef2ceCopy full SHA for beef2ce

File tree

+13

-11

lines changed

+13

-11

lines changed

Lines changed: 13 additions & 11 deletions

Original file line number	Diff line number	Diff line change
`@@ -152,17 +152,19 @@ dtm_get_current_time()`
`152`	`152`	`staticvoid`
`153`	`153`	`dtm_sleep(timestamp_tinterval)`
`154`	`154`	`{`
`155`		`-structtimespects;`
`156`		`-structtimespecrem;`
`157`		`-`
`158`		`-ts.tv_sec=0;`
`159`		`-ts.tv_nsec=interval*1000;`
`160`		`-`
`161`		`-while (nanosleep(&ts,&rem)<0)`
	`155`	`+timestamp_twaketm=dtm_get_current_time()+interval;`
	`156`	`+while (1948)`
`162`	`157`	`{`
`163`		`-totalSleepInterrupts+=1;`
`164`		`-Assert(errno==EINTR);`
`165`		`-ts=rem;`
	`158`	`+timestamp_tsleepfor=waketm-dtm_get_current_time();`
	`159`	`+`
	`160`	`+pg_usleep(sleepfor);`
	`161`	`+if (dtm_get_current_time()<waketm)`
	`162`	`+{`
	`163`	`+totalSleepInterrupts+=1;`
	`164`	`+Assert(errno==EINTR);`
	`165`	`+continue;`
	`166`	`+}`
	`167`	`+break;`
`166`	`168`	`}`
`167`	`169`	`}`
`168`	`170`
`@@ -829,7 +831,7 @@ DtmDetectGlobalDeadLock(PGPROC *proc)`
`829`	`831`	`return true;`
`830`	`832`	`}`
`831`	`833`
`832`		`-staticsize_t`
	`834`	`+staticsize_t`
`833`	`835`	`DtmGetTransactionStateSize(void)`
`834`	`836`	`{`
`835`	`837`	`returnsizeof(dtm_tx);`

Comments

(0)