Commit22139df

authored and

committed

Change criteria of starting new dynamic worker

1 parent609a66e commit22139dfCopy full SHA for 22139df

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
`@@ -59,7 +59,8 @@ if [ "$1" = 'postgres' ]; then`
`59`	`59`	`default_transaction_isolation = 'repeatable read'`
`60`	`60`	`log_line_prefix = '%t: '`
`61`	`61`
`62`		`-multimaster.workers = 16`
	`62`	`+multimaster.workers = 4`
	`63`	`+multimaster.max_workers = 16`
`63`	`64`	`multimaster.max_nodes = 3`
`64`	`65`	`multimaster.volkswagen_mode = 1`
`65`	`66`	`multimaster.queue_size=52857600`

Comments

(0)