Function exec_stmt_call

src/pl/plpgsql/src/pl_exec.c:2151–2236

* exec_stmt_call * * NOTE: this is used for both CALL and DO statements. */

 * NOTE: this is used for both CALL and DO statements.
 */
static int
exec_stmt_call(PLpgSQL_execstate *estate, PLpgSQL_stmt_call *stmt)
{
	PLpgSQL_expr *expr = stmt->expr;
	LocalTransactionId before_lxid;
	LocalTransactionId after_lxid;
	ParamListInfo paramLI;
	SPIExecuteOptions options;
	int			rc;

	/*
	 * Make a plan if we don't have one already.
	 */
	if (expr->plan == NULL)
		exec_prepare_plan(estate, expr, 0);

	/*
	 * A CALL or DO can never be a simple expression.
	 */
	Assert(!expr->expr_simple_expr);

	/*
	 * Also construct a DTYPE_ROW datum representing the plpgsql variables
	 * associated with the procedure's output arguments.  Then we can use
	 * exec_move_row() to do the assignments.
	 */
	if (stmt->is_call && stmt->target == NULL)
		stmt->target = make_callstmt_target(estate, expr);

	paramLI = setup_param_list(estate, expr);

	before_lxid = MyProc->lxid;

	/*
	 * If we have a procedure-lifespan resowner, use that to hold the refcount
	 * for the plan.  This avoids refcount leakage complaints if the called
	 * procedure ends the current transaction.
	 *
	 * Also, tell SPI to allow non-atomic execution.
	 */
	memset(&options, 0, sizeof(options));
	options.params = paramLI;
	options.read_only = estate->readonly_func;
	options.allow_nonatomic = true;
	options.owner = estate->procedure_resowner;

	rc = SPI_execute_plan_extended(expr->plan, &options);

	if (rc < 0)
		elog(ERROR, "SPI_execute_plan_extended failed executing query \"%s\": %s",
			 expr->query, SPI_result_code_string(rc));

	after_lxid = MyProc->lxid;

	if (before_lxid != after_lxid)
	{
		/*
		 * If we are in a new transaction after the call, we need to build new