MCPcopy Create free account
hub / github.com/apache/cloudberry / ExecForeignScanInitializeWorker

Function ExecForeignScanInitializeWorker

src/backend/executor/nodeForeignscan.c:439–453  ·  view source on GitHub ↗

---------------------------------------------------------------- * ExecForeignScanInitializeWorker * * Initialization according to the parallel coordination information * ---------------------------------------------------------------- */

Source from the content-addressed store, hash-verified

437 * ----------------------------------------------------------------
438 */
439void
440ExecForeignScanInitializeWorker(ForeignScanState *node,
441 ParallelWorkerContext *pwcxt)
442{
443 FdwRoutine *fdwroutine = node->fdwroutine;
444
445 if (fdwroutine->InitializeWorkerForeignScan)
446 {
447 int plan_node_id = node->ss.ps.plan->plan_node_id;
448 void *coordinate;
449
450 coordinate = shm_toc_lookup(pwcxt->toc, plan_node_id, false);
451 fdwroutine->InitializeWorkerForeignScan(node, pwcxt->toc, coordinate);
452 }
453}
454
455/* ----------------------------------------------------------------
456 * ExecShutdownForeignScan

Callers 1

Calls 1

shm_toc_lookupFunction · 0.85

Tested by

no test coverage detected