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

Function RestoreParamExecParams

src/backend/executor/execParallel.c:412–435  ·  view source on GitHub ↗

* Restore specified PARAM_EXEC parameters. */

Source from the content-addressed store, hash-verified

410 * Restore specified PARAM_EXEC parameters.
411 */
412static void
413RestoreParamExecParams(char *start_address, EState *estate)
414{
415 int nparams;
416 int i;
417 int paramid;
418
419 memcpy(&nparams, start_address, sizeof(int));
420 start_address += sizeof(int);
421
422 for (i = 0; i < nparams; i++)
423 {
424 ParamExecData *prm;
425
426 /* Read paramid */
427 memcpy(&paramid, start_address, sizeof(int));
428 start_address += sizeof(int);
429 prm = &(estate->es_param_exec_vals[paramid]);
430
431 /* Read datum/isnull. */
432 prm->value = datumRestore(&start_address, &prm->isnull);
433 prm->execPlan = NULL;
434 }
435}
436
437/*
438 * Initialize the dynamic shared memory segment that will be used to control

Callers 1

ParallelQueryMainFunction · 0.85

Calls 1

datumRestoreFunction · 0.85

Tested by

no test coverage detected