mirror of
https://github.com/postgres/postgres.git
synced 2025-05-17 06:41:24 +03:00
Avoid leaking memory while evaluating arguments for a table function.
ExecMakeTableFunctionResult evaluated the arguments for a function-in-FROM in the query-lifespan memory context. This is insignificant in simple cases where the function relation is scanned only once; but if the function is in a sub-SELECT or is on the inside of a nested loop, any memory consumed during argument evaluation can add up quickly. (The potential for trouble here had been foreseen long ago, per existing comments; but we'd not previously seen a complaint from the field about it.) To fix, create an additional temporary context just for this purpose. Per an example from MauMau. Back-patch to all active branches.
This commit is contained in:
parent
b488daf0d5
commit
1044e79a0b
@ -2002,6 +2002,7 @@ ExecMakeFunctionResultNoSets(FuncExprState *fcache,
|
|||||||
Tuplestorestate *
|
Tuplestorestate *
|
||||||
ExecMakeTableFunctionResult(ExprState *funcexpr,
|
ExecMakeTableFunctionResult(ExprState *funcexpr,
|
||||||
ExprContext *econtext,
|
ExprContext *econtext,
|
||||||
|
MemoryContext argContext,
|
||||||
TupleDesc expectedDesc,
|
TupleDesc expectedDesc,
|
||||||
bool randomAccess)
|
bool randomAccess)
|
||||||
{
|
{
|
||||||
@ -2083,12 +2084,18 @@ ExecMakeTableFunctionResult(ExprState *funcexpr,
|
|||||||
/*
|
/*
|
||||||
* Evaluate the function's argument list.
|
* Evaluate the function's argument list.
|
||||||
*
|
*
|
||||||
* Note: ideally, we'd do this in the per-tuple context, but then the
|
* We can't do this in the per-tuple context: the argument values
|
||||||
* argument values would disappear when we reset the context in the
|
* would disappear when we reset that context in the inner loop. And
|
||||||
* inner loop. So do it in caller context. Perhaps we should make a
|
* the caller's CurrentMemoryContext is typically a query-lifespan
|
||||||
* separate context just to hold the evaluated arguments?
|
* context, so we don't want to leak memory there. We require the
|
||||||
|
* caller to pass a separate memory context that can be used for this,
|
||||||
|
* and can be reset each time through to avoid bloat.
|
||||||
*/
|
*/
|
||||||
|
MemoryContextReset(argContext);
|
||||||
|
oldcontext = MemoryContextSwitchTo(argContext);
|
||||||
argDone = ExecEvalFuncArgs(&fcinfo, fcache->args, econtext);
|
argDone = ExecEvalFuncArgs(&fcinfo, fcache->args, econtext);
|
||||||
|
MemoryContextSwitchTo(oldcontext);
|
||||||
|
|
||||||
/* We don't allow sets in the arguments of the table function */
|
/* We don't allow sets in the arguments of the table function */
|
||||||
if (argDone != ExprSingleResult)
|
if (argDone != ExprSingleResult)
|
||||||
ereport(ERROR,
|
ereport(ERROR,
|
||||||
|
@ -28,6 +28,7 @@
|
|||||||
#include "nodes/nodeFuncs.h"
|
#include "nodes/nodeFuncs.h"
|
||||||
#include "parser/parsetree.h"
|
#include "parser/parsetree.h"
|
||||||
#include "utils/builtins.h"
|
#include "utils/builtins.h"
|
||||||
|
#include "utils/memutils.h"
|
||||||
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
@ -94,6 +95,7 @@ FunctionNext(FunctionScanState *node)
|
|||||||
node->funcstates[0].tstore = tstore =
|
node->funcstates[0].tstore = tstore =
|
||||||
ExecMakeTableFunctionResult(node->funcstates[0].funcexpr,
|
ExecMakeTableFunctionResult(node->funcstates[0].funcexpr,
|
||||||
node->ss.ps.ps_ExprContext,
|
node->ss.ps.ps_ExprContext,
|
||||||
|
node->argcontext,
|
||||||
node->funcstates[0].tupdesc,
|
node->funcstates[0].tupdesc,
|
||||||
node->eflags & EXEC_FLAG_BACKWARD);
|
node->eflags & EXEC_FLAG_BACKWARD);
|
||||||
|
|
||||||
@ -152,6 +154,7 @@ FunctionNext(FunctionScanState *node)
|
|||||||
fs->tstore =
|
fs->tstore =
|
||||||
ExecMakeTableFunctionResult(fs->funcexpr,
|
ExecMakeTableFunctionResult(fs->funcexpr,
|
||||||
node->ss.ps.ps_ExprContext,
|
node->ss.ps.ps_ExprContext,
|
||||||
|
node->argcontext,
|
||||||
fs->tupdesc,
|
fs->tupdesc,
|
||||||
node->eflags & EXEC_FLAG_BACKWARD);
|
node->eflags & EXEC_FLAG_BACKWARD);
|
||||||
|
|
||||||
@ -515,6 +518,19 @@ ExecInitFunctionScan(FunctionScan *node, EState *estate, int eflags)
|
|||||||
ExecAssignResultTypeFromTL(&scanstate->ss.ps);
|
ExecAssignResultTypeFromTL(&scanstate->ss.ps);
|
||||||
ExecAssignScanProjectionInfo(&scanstate->ss);
|
ExecAssignScanProjectionInfo(&scanstate->ss);
|
||||||
|
|
||||||
|
/*
|
||||||
|
* Create a memory context that ExecMakeTableFunctionResult can use to
|
||||||
|
* evaluate function arguments in. We can't use the per-tuple context for
|
||||||
|
* this because it gets reset too often; but we don't want to leak
|
||||||
|
* evaluation results into the query-lifespan context either. We just
|
||||||
|
* need one context, because we evaluate each function separately.
|
||||||
|
*/
|
||||||
|
scanstate->argcontext = AllocSetContextCreate(CurrentMemoryContext,
|
||||||
|
"Table function arguments",
|
||||||
|
ALLOCSET_DEFAULT_MINSIZE,
|
||||||
|
ALLOCSET_DEFAULT_INITSIZE,
|
||||||
|
ALLOCSET_DEFAULT_MAXSIZE);
|
||||||
|
|
||||||
return scanstate;
|
return scanstate;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -231,6 +231,7 @@ extern Datum GetAttributeByName(HeapTupleHeader tuple, const char *attname,
|
|||||||
bool *isNull);
|
bool *isNull);
|
||||||
extern Tuplestorestate *ExecMakeTableFunctionResult(ExprState *funcexpr,
|
extern Tuplestorestate *ExecMakeTableFunctionResult(ExprState *funcexpr,
|
||||||
ExprContext *econtext,
|
ExprContext *econtext,
|
||||||
|
MemoryContext argContext,
|
||||||
TupleDesc expectedDesc,
|
TupleDesc expectedDesc,
|
||||||
bool randomAccess);
|
bool randomAccess);
|
||||||
extern Datum ExecEvalExprSwitchContext(ExprState *expression, ExprContext *econtext,
|
extern Datum ExecEvalExprSwitchContext(ExprState *expression, ExprContext *econtext,
|
||||||
|
@ -1406,6 +1406,7 @@ typedef struct SubqueryScanState
|
|||||||
* nfuncs number of functions being executed
|
* nfuncs number of functions being executed
|
||||||
* funcstates per-function execution states (private in
|
* funcstates per-function execution states (private in
|
||||||
* nodeFunctionscan.c)
|
* nodeFunctionscan.c)
|
||||||
|
* argcontext memory context to evaluate function arguments in
|
||||||
* ----------------
|
* ----------------
|
||||||
*/
|
*/
|
||||||
struct FunctionScanPerFuncState;
|
struct FunctionScanPerFuncState;
|
||||||
@ -1420,6 +1421,7 @@ typedef struct FunctionScanState
|
|||||||
int nfuncs;
|
int nfuncs;
|
||||||
struct FunctionScanPerFuncState *funcstates; /* array of length
|
struct FunctionScanPerFuncState *funcstates; /* array of length
|
||||||
* nfuncs */
|
* nfuncs */
|
||||||
|
MemoryContext argcontext;
|
||||||
} FunctionScanState;
|
} FunctionScanState;
|
||||||
|
|
||||||
/* ----------------
|
/* ----------------
|
||||||
|
Loading…
x
Reference in New Issue
Block a user