Commit141c609

Vladimir Ershov

committed

fix register bgworker context

1 parentfb99fab commit141c609Copy full SHA for 141c609

File tree

-0

lines changed

-0

lines changed

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1663,6 +1663,7 @@ int start_at_worker(scheduler_manager_ctx_t *ctx, int pos)`
`1663`	`1663`	`BgwHandleStatusstatus;`
`1664`	`1664`	`scheduler_manager_slot_t*item;`
`1665`	`1665`	`ResourceOwnerprev_owner;`
	`1666`	`+MemoryContextold;`
`1666`	`1667`
`1667`	`1668`	`prev_owner=CurrentResourceOwner;`
`1668`	`1669`	`CurrentResourceOwner=ResourceOwnerCreate(NULL,"pgpro_scheduler");`
`@@ -1699,15 +1700,18 @@ int start_at_worker(scheduler_manager_ctx_t *ctx, int pos)`
`1699`	`1700`
`1700`	`1701`	`CurrentResourceOwner=prev_owner;`
`1701`	`1702`
	`1703`	`+old=MemoryContextSwitchTo(ctx->mem_ctx);`
`1702`	`1704`	`if(!RegisterDynamicBackgroundWorker(&worker,&(item->handler)))`
`1703`	`1705`	`{`
`1704`	`1706`	`elog(LOG,"Cannot register AT executor worker for db: %s",`
`1705`	`1707`	`shm_data->database);`
`1706`	`1708`	`dsm_detach(item->shared);`
`1707`	`1709`	`pfree(item);`
`1708`	`1710`	`ctx->at.slots[pos]=NULL;`
	`1711`	`+MemoryContextSwitchTo(old);`
`1709`	`1712`	`return0;`
`1710`	`1713`	`}`
	`1714`	`+MemoryContextSwitchTo(old);`
`1711`	`1715`	`status=WaitForBackgroundWorkerStartup(item->handler,&(item->pid));`
`1712`	`1716`	`if(status!=BGWH_STARTED)`
`1713`	`1717`	`{`

Comments

(0)