Change criteria of starting new dynamic worker

knizhnik · knizhnik · commit fc678b8ebf42 · 2017-01-11T10:58:07.000+03:00
diff --git a/contrib/mmts/bgwpool.c b/contrib/mmts/bgwpool.c
@@ -205,7 +205,7 @@ void BgwPoolExecute(BgwPool* pool, void* work, size_t size)
             SpinLockAcquire(&pool->lock);
         } else {
             pool->pending += 1;
-			if (pool->active == pool->nWorkers) { 
+			if (pool->active + pool->pending > pool->nWorkers) { 
 				BgwStartExtraWorker(pool);				
 			}
 			if (pool->lastPeakTime == 0 && pool->active == pool->nWorkers && pool->pending != 0) {
diff --git a/contrib/mmts/tests2/docker-entrypoint.sh b/contrib/mmts/tests2/docker-entrypoint.sh
@@ -58,7 +58,8 @@ if [ "$1" = 'postgres' ]; then
 			default_transaction_isolation = 'repeatable read'
             log_line_prefix = '%t: '
 
-			multimaster.workers = 16
+			multimaster.workers = 4
+			multimaster.max_workers = 16
 			multimaster.max_nodes = 3
 			multimaster.volkswagen_mode = 1
 			multimaster.queue_size=52857600

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) {`