aboutsummaryrefslogtreecommitdiff
path: root/src/backend/utils/cache/fcache.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/backend/utils/cache/fcache.c')
-rw-r--r--src/backend/utils/cache/fcache.c254
1 files changed, 24 insertions, 230 deletions
diff --git a/src/backend/utils/cache/fcache.c b/src/backend/utils/cache/fcache.c
index 080f70b6ce8..9186f34d104 100644
--- a/src/backend/utils/cache/fcache.c
+++ b/src/backend/utils/cache/fcache.c
@@ -1,267 +1,61 @@
/*-------------------------------------------------------------------------
*
* fcache.c
- * Code for the 'function cache' used in Oper and Func nodes....
+ * Code for the 'function cache' used in Oper and Func nodes.
+ *
*
* Portions Copyright (c) 1996-2000, PostgreSQL, Inc
* Portions Copyright (c) 1994, Regents of the University of California
*
- *
* IDENTIFICATION
- * $Header: /cvsroot/pgsql/src/backend/utils/cache/Attic/fcache.c,v 1.36 2000/08/11 18:35:50 tgl Exp $
+ * $Header: /cvsroot/pgsql/src/backend/utils/cache/Attic/fcache.c,v 1.37 2000/08/24 03:29:07 tgl Exp $
*
*-------------------------------------------------------------------------
*/
#include "postgres.h"
-#include "access/heapam.h"
-#include "catalog/pg_language.h"
-#include "catalog/pg_proc.h"
-#include "catalog/pg_type.h"
-#include "parser/parsetree.h"
-#include "utils/builtins.h"
-#include "utils/fcache2.h"
-#include "utils/syscache.h"
-
-static Oid GetDynamicFuncArgType(Var *arg, ExprContext *econtext);
-static FunctionCachePtr init_fcache(Oid foid,
- List *argList,
- ExprContext *econtext);
-
-#define FuncArgTypeIsDynamic(arg) \
- (IsA(arg,Var) && ((Var*)arg)->varattno == InvalidAttrNumber)
-
-static Oid
-GetDynamicFuncArgType(Var *arg, ExprContext *econtext)
-{
- char *relname;
- int rtid;
- HeapTuple tup;
-
- Assert(IsA(arg, Var));
+#include "utils/fcache.h"
- rtid = ((Var *) arg)->varno;
- relname = (char *) getrelname(rtid, econtext->ecxt_range_table);
-
- tup = SearchSysCacheTuple(TYPENAME,
- PointerGetDatum(relname),
- 0, 0, 0);
- if (!tup)
- elog(ERROR, "Lookup failed on type tuple for class %s",
- relname);
-
- return tup->t_data->t_oid;
-}
/*-----------------------------------------------------------------
*
- * Initialize a 'FunctionCache' struct given the PG_PROC oid.
+ * Build a 'FunctionCache' struct given the PG_PROC oid.
*
*-----------------------------------------------------------------
*/
-static FunctionCachePtr
-init_fcache(Oid foid,
- List *argList,
- ExprContext *econtext)
+FunctionCachePtr
+init_fcache(Oid foid, int nargs, MemoryContext fcacheCxt)
{
- HeapTuple procedureTuple;
- HeapTuple typeTuple;
- Form_pg_proc procedureStruct;
- Form_pg_type typeStruct;
+ MemoryContext oldcontext;
FunctionCachePtr retval;
- int nargs;
- Datum tmp;
- bool isNull;
+
+ /* Switch to a context long-lived enough for the fcache entry */
+ oldcontext = MemoryContextSwitchTo(fcacheCxt);
retval = (FunctionCachePtr) palloc(sizeof(FunctionCache));
MemSet(retval, 0, sizeof(FunctionCache));
- retval->fcacheCxt = CurrentMemoryContext;
-
- /* ----------------
- * get the procedure tuple corresponding to the given functionOid
- *
- * NB: use SearchSysCacheTupleCopy to ensure tuple lives long enough
- * ----------------
- */
- procedureTuple = SearchSysCacheTupleCopy(PROCOID,
- ObjectIdGetDatum(foid),
- 0, 0, 0);
- if (!HeapTupleIsValid(procedureTuple))
- elog(ERROR, "init_fcache: Cache lookup failed for procedure %u",
- foid);
+ /* Set up the primary fmgr lookup information */
+ fmgr_info(foid, &(retval->func));
- procedureStruct = (Form_pg_proc) GETSTRUCT(procedureTuple);
+ /* Initialize unvarying fields of per-call info block */
+ retval->fcinfo.flinfo = &(retval->func);
+ retval->fcinfo.nargs = nargs;
- /* ----------------
- * get the return type from the procedure tuple
- * ----------------
- */
- typeTuple = SearchSysCacheTuple(TYPEOID,
- ObjectIdGetDatum(procedureStruct->prorettype),
- 0, 0, 0);
+ if (nargs > FUNC_MAX_ARGS)
+ elog(ERROR, "init_fcache: too many arguments");
- if (!HeapTupleIsValid(typeTuple))
- elog(ERROR, "init_fcache: Cache lookup failed for type %u",
- procedureStruct->prorettype);
-
- typeStruct = (Form_pg_type) GETSTRUCT(typeTuple);
-
- /* ----------------
- * get the type length and by-value flag from the type tuple
- * ----------------
- */
- retval->typlen = typeStruct->typlen;
- if (typeStruct->typrelid == InvalidOid)
+ /* If function returns set, prepare a resultinfo node for communication */
+ if (retval->func.fn_retset)
{
- /* The return type is not a relation, so just use byval */
- retval->typbyval = typeStruct->typbyval;
- retval->returnsTuple = false;
+ retval->fcinfo.resultinfo = (Node *) &(retval->rsinfo);
+ retval->rsinfo.type = T_ReturnSetInfo;
}
- else
- {
- /*
- * This is a hack. We assume here that any function returning a
- * tuple returns it by reference. This needs to be fixed, since
- * actually the mechanism isn't quite like return-by-reference.
- */
- retval->typbyval = false;
- retval->returnsTuple = true;
- }
- retval->foid = foid;
- retval->language = procedureStruct->prolang;
- retval->returnsSet = procedureStruct->proretset;
+ retval->argsValid = false;
retval->hasSetArg = false;
- retval->func_state = (char *) NULL;
- retval->setArg = (Datum) 0;
-
- /*
- * If we are returning exactly one result then we have to copy tuples
- * and by reference results because we have to end the execution
- * before we return the results. When you do this everything
- * allocated by the executor (i.e. slots and tuples) is freed.
- */
- if ((retval->language == SQLlanguageId) &&
- !retval->returnsSet &&
- !retval->typbyval)
- {
- TupleTableSlot *slot;
-
- slot = makeNode(TupleTableSlot);
- slot->ttc_shouldFree = true;
- slot->ttc_descIsNew = true;
- slot->ttc_tupleDescriptor = (TupleDesc) NULL;
- slot->ttc_buffer = InvalidBuffer;
- slot->ttc_whichplan = -1;
-
- retval->funcSlot = (Pointer) slot;
- }
- else
- retval->funcSlot = (Pointer) NULL;
-
- nargs = procedureStruct->pronargs;
- retval->nargs = nargs;
-
- if (nargs > 0)
- {
- Oid *argTypes;
-
- if (retval->language == SQLlanguageId)
- {
- int i;
- List *oneArg;
-
- retval->argOidVect = (Oid *) palloc(retval->nargs * sizeof(Oid));
- argTypes = procedureStruct->proargtypes;
- memmove(retval->argOidVect,
- argTypes,
- (retval->nargs) * sizeof(Oid));
- for (i = 0;
- argList;
- i++, argList = lnext(argList))
- {
- oneArg = lfirst(argList);
- if (FuncArgTypeIsDynamic(oneArg))
- retval->argOidVect[i] = GetDynamicFuncArgType((Var *) oneArg,
- econtext);
- }
- }
- else
- retval->argOidVect = (Oid *) NULL;
- }
- else
- {
- retval->argOidVect = (Oid *) NULL;
- }
-
- if (procedureStruct->prolang == SQLlanguageId)
- {
- tmp = SysCacheGetAttr(PROCOID,
- procedureTuple,
- Anum_pg_proc_prosrc,
- &isNull);
- if (isNull)
- elog(ERROR, "init_fcache: null prosrc for procedure %u",
- foid);
- retval->src = DatumGetCString(DirectFunctionCall1(textout, tmp));
- retval->bin = (char *) NULL;
- }
- else
- {
- retval->src = (char *) NULL;
- if (procedureStruct->proistrusted)
- retval->bin = (char *) NULL;
- else
- {
- tmp = SysCacheGetAttr(PROCOID,
- procedureTuple,
- Anum_pg_proc_probin,
- &isNull);
- if (isNull)
- elog(ERROR, "init_fcache: null probin for procedure %u",
- foid);
- retval->bin = DatumGetCString(DirectFunctionCall1(textout, tmp));
- }
- }
-
- if (retval->language != SQLlanguageId)
- {
- fmgr_info(foid, &(retval->func));
- retval->nargs = retval->func.fn_nargs;
- }
- else
- retval->func.fn_addr = (PGFunction) NULL;
-
- heap_freetuple(procedureTuple);
+ MemoryContextSwitchTo(oldcontext);
return retval;
}
-
-void
-setFcache(Node *node, Oid foid, List *argList, ExprContext *econtext)
-{
- MemoryContext oldcontext;
- FunctionCachePtr fcache;
-
- /* Switch to a context long-lived enough for the fcache entry */
- oldcontext = MemoryContextSwitchTo(econtext->ecxt_per_query_memory);
-
- fcache = init_fcache(foid, argList, econtext);
-
- if (IsA(node, Oper))
- {
- Oper *onode = (Oper *) node;
- onode->op_fcache = fcache;
- }
- else if (IsA(node, Func))
- {
- Func *fnode = (Func *) node;
- fnode->func_fcache = fcache;
- }
- else
- elog(ERROR, "init_fcache: node must be Oper or Func!");
-
- MemoryContextSwitchTo(oldcontext);
-}
generated by cgit v1.2.3 (git 2.25.1) at 2025-07-15 18:30:39 +0000