pcxt = CreateParallelContext("postgres", "_bt_parallel_build_main",
request);
- /* If no DSM segment was available, back out (do serial build) */
- if (pcxt->seg == NULL)
- {
- DestroyParallelContext(pcxt);
- ExitParallelMode();
- return;
- }
-
scantuplesortstates = leaderparticipates ? request + 1 : request;
/*
/* Everyone's had a chance to ask for space, so now create the DSM */
InitializeParallelDSM(pcxt);
+ /* If no DSM segment was available, back out (do serial build) */
+ if (pcxt->seg == NULL)
+ {
+ if (IsMVCCSnapshot(snapshot))
+ UnregisterSnapshot(snapshot);
+ DestroyParallelContext(pcxt);
+ ExitParallelMode();
+ return;
+ }
+
/* Store shared build state, for which we reserved space */
btshared = (BTShared *) shm_toc_allocate(pcxt->toc, estbtshared);
/* Initialize immutable state */