Commitfc678b8

committed

Change criteria of starting new dynamic worker

1 parentc0794c0 commitfc678b8Copy full SHA for fc678b8

File tree

-2

lines changed

-2

lines changed

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -205,7 +205,7 @@ void BgwPoolExecute(BgwPool* pool, void* work, size_t size)`
`205`	`205`	`SpinLockAcquire(&pool->lock);`
`206`	`206`	`}else {`
`207`	`207`	`pool->pending+=1;`
`208`		`-if (pool->active==pool->nWorkers) {`
	`208`	`+if (pool->active+pool->pending>pool->nWorkers) {`
`209`	`209`	`BgwStartExtraWorker(pool);`
`210`	`210`	`}`
`211`	`211`	`if (pool->lastPeakTime==0&&pool->active==pool->nWorkers&&pool->pending!=0) {`

Lines changed: 2 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -58,7 +58,8 @@ if [ "$1" = 'postgres' ]; then`
`58`	`58`	`default_transaction_isolation = 'repeatable read'`
`59`	`59`	`log_line_prefix = '%t: '`
`60`	`60`
`61`		`-multimaster.workers = 16`
	`61`	`+multimaster.workers = 4`
	`62`	`+multimaster.max_workers = 16`
`62`	`63`	`multimaster.max_nodes = 3`
`63`	`64`	`multimaster.volkswagen_mode = 1`
`64`	`65`	`multimaster.queue_size=52857600`

Comments

(0)