Commitb017b97

committed

Insert CHECK_FOR_INTERRUPTS in sleep

1 parent15475f6 commitb017b97Copy full SHA for b017b97

File tree

-1

lines changed

-1

lines changed

Lines changed: 1 addition & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -342,6 +342,7 @@ void MtmSleep(timestamp_t interval)`
`342`	`342`
`343`	`343`	`while (nanosleep(&ts,&rem)<0) {`
`344`	`344`	`Assert(errno==EINTR);`
	`345`	`+CHECK_FOR_INTERRUPTS();`
`345`	`346`	`ts=rem;`
`346`	`347`	`}`
`347`	`348`	`}`

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -714,7 +714,9 @@ void MtmStartReceiver(int nodeId, bool dynamic)`
`714`	`714`	`worker.bgw_main_arg=Int32GetDatum(nodeId);`
`715`	`715`	`if (dynamic) {`
`716`	`716`	`BackgroundWorkerHandle*handle;`
`717`		`-RegisterDynamicBackgroundWorker(&worker,&handle);`
	`717`	`+if (!RegisterDynamicBackgroundWorker(&worker,&handle)) {`
	`718`	`+elog(WARNING,"Failed to start background worker, please increase max_worker_processes configuration parameter (current value is %d)",max_worker_processes);`
	`719`	`+}`
`718`	`720`	`}else {`
`719`	`721`	`RegisterBackgroundWorker(&worker);`
`720`	`722`	`}`

Comments

(0)