Unlock semaphore on shutdown in bgworker

knizhnik · knizhnik · commit 9ccf3f4d6c47 · 2017-03-10T14:16:16.000+03:00
diff --git a/contrib/mmts/bgwpool.c b/contrib/mmts/bgwpool.c
@@ -52,6 +52,7 @@ static void BgwPoolMainLoop(BgwPool* pool)
         PGSemaphoreLock(&pool->available);
         SpinLockAcquire(&pool->lock);
 		if (pool->shutdown) { 	
+			PGSemaphoreUnlock(&pool->available);
 			break;
 		}
         size = *(int*)&pool->queue[pool->head];

Original file line number	Diff line number	Diff line change
`@@ -52,6 +52,7 @@ static void BgwPoolMainLoop(BgwPool* pool)`
`52`	`52`	`PGSemaphoreLock(&pool->available);`
`53`	`53`	`SpinLockAcquire(&pool->lock);`
`54`	`54`	`if (pool->shutdown) {`
	`55`	`+ PGSemaphoreUnlock(&pool->available);`
`55`	`56`	`break;`
`56`	`57`	`}`
`57`	`58`	`size = (int)&pool->queue[pool->head];`