PostgreSQL Source Code  git master
 All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros
fastpath.c
Go to the documentation of this file.
1 /*-------------------------------------------------------------------------
2  *
3  * fastpath.c
4  * routines to handle function requests from the frontend
5  *
6  * Portions Copyright (c) 1996-2017, PostgreSQL Global Development Group
7  * Portions Copyright (c) 1994, Regents of the University of California
8  *
9  *
10  * IDENTIFICATION
11  * src/backend/tcop/fastpath.c
12  *
13  * NOTES
14  * This cruft is the server side of PQfn.
15  *
16  *-------------------------------------------------------------------------
17  */
18 #include "postgres.h"
19 
20 #include <netinet/in.h>
21 #include <arpa/inet.h>
22 
23 #include "access/htup_details.h"
24 #include "access/xact.h"
25 #include "catalog/objectaccess.h"
26 #include "catalog/pg_proc.h"
27 #include "libpq/libpq.h"
28 #include "libpq/pqformat.h"
29 #include "mb/pg_wchar.h"
30 #include "miscadmin.h"
31 #include "tcop/fastpath.h"
32 #include "tcop/tcopprot.h"
33 #include "utils/acl.h"
34 #include "utils/lsyscache.h"
35 #include "utils/snapmgr.h"
36 #include "utils/syscache.h"
37 
38 
39 /*
40  * Formerly, this code attempted to cache the function and type info
41  * looked up by fetch_fp_info, but only for the duration of a single
42  * transaction command (since in theory the info could change between
43  * commands). This was utterly useless, because postgres.c executes
44  * each fastpath call as a separate transaction command, and so the
45  * cached data could never actually have been reused. If it had worked
46  * as intended, it would have had problems anyway with dangling references
47  * in the FmgrInfo struct. So, forget about caching and just repeat the
48  * syscache fetches on each usage. They're not *that* expensive.
49  */
50 struct fp_info
51 {
53  FmgrInfo flinfo; /* function lookup info for funcid */
54  Oid namespace; /* other stuff from pg_proc */
55  Oid rettype;
57  char fname[NAMEDATALEN]; /* function name for logging */
58 };
59 
60 
61 static int16 parse_fcall_arguments(StringInfo msgBuf, struct fp_info * fip,
62  FunctionCallInfo fcinfo);
63 static int16 parse_fcall_arguments_20(StringInfo msgBuf, struct fp_info * fip,
64  FunctionCallInfo fcinfo);
65 
66 
67 /* ----------------
68  * GetOldFunctionMessage
69  *
70  * In pre-3.0 protocol, there is no length word on the message, so we have
71  * to have code that understands the message layout to absorb the message
72  * into a buffer. We want to do this before we start execution, so that
73  * we do not lose sync with the frontend if there's an error.
74  *
75  * The caller should already have initialized buf to empty.
76  * ----------------
77  */
78 int
80 {
81  int32 ibuf;
82  int nargs;
83 
84  /* Dummy string argument */
85  if (pq_getstring(buf))
86  return EOF;
87  /* Function OID */
88  if (pq_getbytes((char *) &ibuf, 4))
89  return EOF;
90  appendBinaryStringInfo(buf, (char *) &ibuf, 4);
91  /* Number of arguments */
92  if (pq_getbytes((char *) &ibuf, 4))
93  return EOF;
94  appendBinaryStringInfo(buf, (char *) &ibuf, 4);
95  nargs = ntohl(ibuf);
96  /* For each argument ... */
97  while (nargs-- > 0)
98  {
99  int argsize;
100 
101  /* argsize */
102  if (pq_getbytes((char *) &ibuf, 4))
103  return EOF;
104  appendBinaryStringInfo(buf, (char *) &ibuf, 4);
105  argsize = ntohl(ibuf);
106  if (argsize < -1)
107  {
108  /* FATAL here since no hope of regaining message sync */
109  ereport(FATAL,
110  (errcode(ERRCODE_PROTOCOL_VIOLATION),
111  errmsg("invalid argument size %d in function call message",
112  argsize)));
113  }
114  /* and arg contents */
115  if (argsize > 0)
116  {
117  /* Allocate space for arg */
118  enlargeStringInfo(buf, argsize);
119  /* And grab it */
120  if (pq_getbytes(buf->data + buf->len, argsize))
121  return EOF;
122  buf->len += argsize;
123  /* Place a trailing null per StringInfo convention */
124  buf->data[buf->len] = '\0';
125  }
126  }
127  return 0;
128 }
129 
130 /* ----------------
131  * SendFunctionResult
132  *
133  * Note: although this routine doesn't check, the format had better be 1
134  * (binary) when talking to a pre-3.0 client.
135  * ----------------
136  */
137 static void
138 SendFunctionResult(Datum retval, bool isnull, Oid rettype, int16 format)
139 {
140  bool newstyle = (PG_PROTOCOL_MAJOR(FrontendProtocol) >= 3);
142 
143  pq_beginmessage(&buf, 'V');
144 
145  if (isnull)
146  {
147  if (newstyle)
148  pq_sendint(&buf, -1, 4);
149  }
150  else
151  {
152  if (!newstyle)
153  pq_sendbyte(&buf, 'G');
154 
155  if (format == 0)
156  {
157  Oid typoutput;
158  bool typisvarlena;
159  char *outputstr;
160 
161  getTypeOutputInfo(rettype, &typoutput, &typisvarlena);
162  outputstr = OidOutputFunctionCall(typoutput, retval);
163  pq_sendcountedtext(&buf, outputstr, strlen(outputstr), false);
164  pfree(outputstr);
165  }
166  else if (format == 1)
167  {
168  Oid typsend;
169  bool typisvarlena;
170  bytea *outputbytes;
171 
172  getTypeBinaryOutputInfo(rettype, &typsend, &typisvarlena);
173  outputbytes = OidSendFunctionCall(typsend, retval);
174  pq_sendint(&buf, VARSIZE(outputbytes) - VARHDRSZ, 4);
175  pq_sendbytes(&buf, VARDATA(outputbytes),
176  VARSIZE(outputbytes) - VARHDRSZ);
177  pfree(outputbytes);
178  }
179  else
180  ereport(ERROR,
181  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
182  errmsg("unsupported format code: %d", format)));
183  }
184 
185  if (!newstyle)
186  pq_sendbyte(&buf, '0');
187 
188  pq_endmessage(&buf);
189 }
190 
191 /*
192  * fetch_fp_info
193  *
194  * Performs catalog lookups to load a struct fp_info 'fip' for the
195  * function 'func_id'.
196  */
197 static void
198 fetch_fp_info(Oid func_id, struct fp_info * fip)
199 {
200  HeapTuple func_htp;
201  Form_pg_proc pp;
202 
203  Assert(OidIsValid(func_id));
204  Assert(fip != NULL);
205 
206  /*
207  * Since the validity of this structure is determined by whether the
208  * funcid is OK, we clear the funcid here. It must not be set to the
209  * correct value until we are about to return with a good struct fp_info,
210  * since we can be interrupted (i.e., with an ereport(ERROR, ...)) at any
211  * time. [No longer really an issue since we don't save the struct
212  * fp_info across transactions anymore, but keep it anyway.]
213  */
214  MemSet(fip, 0, sizeof(struct fp_info));
215  fip->funcid = InvalidOid;
216 
217  fmgr_info(func_id, &fip->flinfo);
218 
219  func_htp = SearchSysCache1(PROCOID, ObjectIdGetDatum(func_id));
220  if (!HeapTupleIsValid(func_htp))
221  ereport(ERROR,
222  (errcode(ERRCODE_UNDEFINED_FUNCTION),
223  errmsg("function with OID %u does not exist", func_id)));
224  pp = (Form_pg_proc) GETSTRUCT(func_htp);
225 
226  /* watch out for catalog entries with more than FUNC_MAX_ARGS args */
227  if (pp->pronargs > FUNC_MAX_ARGS)
228  elog(ERROR, "function %s has more than %d arguments",
229  NameStr(pp->proname), FUNC_MAX_ARGS);
230 
231  fip->namespace = pp->pronamespace;
232  fip->rettype = pp->prorettype;
233  memcpy(fip->argtypes, pp->proargtypes.values, pp->pronargs * sizeof(Oid));
234  strlcpy(fip->fname, NameStr(pp->proname), NAMEDATALEN);
235 
236  ReleaseSysCache(func_htp);
237 
238  /*
239  * This must be last!
240  */
241  fip->funcid = func_id;
242 }
243 
244 
245 /*
246  * HandleFunctionRequest
247  *
248  * Server side of PQfn (fastpath function calls from the frontend).
249  * This corresponds to the libpq protocol symbol "F".
250  *
251  * INPUT:
252  * In protocol version 3, postgres.c has already read the message body
253  * and will pass it in msgBuf.
254  * In old protocol, the passed msgBuf is empty and we must read the
255  * message here.
256  *
257  * RETURNS:
258  * 0 if successful completion, EOF if frontend connection lost.
259  *
260  * Note: All ordinary errors result in ereport(ERROR,...). However,
261  * if we lose the frontend connection there is no one to ereport to,
262  * and no use in proceeding...
263  *
264  * Note: palloc()s done here and in the called function do not need to be
265  * cleaned up explicitly. We are called from PostgresMain() in the
266  * MessageContext memory context, which will be automatically reset when
267  * control returns to PostgresMain.
268  */
269 int
271 {
272  Oid fid;
273  AclResult aclresult;
274  FunctionCallInfoData fcinfo;
275  int16 rformat;
276  Datum retval;
277  struct fp_info my_fp;
278  struct fp_info *fip;
279  bool callit;
280  bool was_logged = false;
281  char msec_str[32];
282 
283  /*
284  * Now that we've eaten the input message, check to see if we actually
285  * want to do the function call or not. It's now safe to ereport(); we
286  * won't lose sync with the frontend.
287  */
289  ereport(ERROR,
290  (errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
291  errmsg("current transaction is aborted, "
292  "commands ignored until end of transaction block")));
293 
294  /*
295  * Now that we know we are in a valid transaction, set snapshot in case
296  * needed by function itself or one of the datatype I/O routines.
297  */
299 
300  /*
301  * Begin parsing the buffer contents.
302  */
304  (void) pq_getmsgstring(msgBuf); /* dummy string */
305 
306  fid = (Oid) pq_getmsgint(msgBuf, 4); /* function oid */
307 
308  /*
309  * There used to be a lame attempt at caching lookup info here. Now we
310  * just do the lookups on every call.
311  */
312  fip = &my_fp;
313  fetch_fp_info(fid, fip);
314 
315  /* Log as soon as we have the function OID and name */
316  if (log_statement == LOGSTMT_ALL)
317  {
318  ereport(LOG,
319  (errmsg("fastpath function call: \"%s\" (OID %u)",
320  fip->fname, fid)));
321  was_logged = true;
322  }
323 
324  /*
325  * Check permission to access and call function. Since we didn't go
326  * through a normal name lookup, we need to check schema usage too.
327  */
328  aclresult = pg_namespace_aclcheck(fip->namespace, GetUserId(), ACL_USAGE);
329  if (aclresult != ACLCHECK_OK)
331  get_namespace_name(fip->namespace));
332  InvokeNamespaceSearchHook(fip->namespace, true);
333 
334  aclresult = pg_proc_aclcheck(fid, GetUserId(), ACL_EXECUTE);
335  if (aclresult != ACLCHECK_OK)
336  aclcheck_error(aclresult, ACL_KIND_PROC,
337  get_func_name(fid));
339 
340  /*
341  * Prepare function call info block and insert arguments.
342  *
343  * Note: for now we pass collation = InvalidOid, so collation-sensitive
344  * functions can't be called this way. Perhaps we should pass
345  * DEFAULT_COLLATION_OID, instead?
346  */
347  InitFunctionCallInfoData(fcinfo, &fip->flinfo, 0, InvalidOid, NULL, NULL);
348 
350  rformat = parse_fcall_arguments(msgBuf, fip, &fcinfo);
351  else
352  rformat = parse_fcall_arguments_20(msgBuf, fip, &fcinfo);
353 
354  /* Verify we reached the end of the message where expected. */
355  pq_getmsgend(msgBuf);
356 
357  /*
358  * If func is strict, must not call it for null args.
359  */
360  callit = true;
361  if (fip->flinfo.fn_strict)
362  {
363  int i;
364 
365  for (i = 0; i < fcinfo.nargs; i++)
366  {
367  if (fcinfo.argnull[i])
368  {
369  callit = false;
370  break;
371  }
372  }
373  }
374 
375  if (callit)
376  {
377  /* Okay, do it ... */
378  retval = FunctionCallInvoke(&fcinfo);
379  }
380  else
381  {
382  fcinfo.isnull = true;
383  retval = (Datum) 0;
384  }
385 
386  /* ensure we do at least one CHECK_FOR_INTERRUPTS per function call */
388 
389  SendFunctionResult(retval, fcinfo.isnull, fip->rettype, rformat);
390 
391  /* We no longer need the snapshot */
393 
394  /*
395  * Emit duration logging if appropriate.
396  */
397  switch (check_log_duration(msec_str, was_logged))
398  {
399  case 1:
400  ereport(LOG,
401  (errmsg("duration: %s ms", msec_str)));
402  break;
403  case 2:
404  ereport(LOG,
405  (errmsg("duration: %s ms fastpath function call: \"%s\" (OID %u)",
406  msec_str, fip->fname, fid)));
407  break;
408  }
409 
410  return 0;
411 }
412 
413 /*
414  * Parse function arguments in a 3.0 protocol message
415  *
416  * Argument values are loaded into *fcinfo, and the desired result format
417  * is returned.
418  */
419 static int16
421  FunctionCallInfo fcinfo)
422 {
423  int nargs;
424  int i;
425  int numAFormats;
426  int16 *aformats = NULL;
427  StringInfoData abuf;
428 
429  /* Get the argument format codes */
430  numAFormats = pq_getmsgint(msgBuf, 2);
431  if (numAFormats > 0)
432  {
433  aformats = (int16 *) palloc(numAFormats * sizeof(int16));
434  for (i = 0; i < numAFormats; i++)
435  aformats[i] = pq_getmsgint(msgBuf, 2);
436  }
437 
438  nargs = pq_getmsgint(msgBuf, 2); /* # of arguments */
439 
440  if (fip->flinfo.fn_nargs != nargs || nargs > FUNC_MAX_ARGS)
441  ereport(ERROR,
442  (errcode(ERRCODE_PROTOCOL_VIOLATION),
443  errmsg("function call message contains %d arguments but function requires %d",
444  nargs, fip->flinfo.fn_nargs)));
445 
446  fcinfo->nargs = nargs;
447 
448  if (numAFormats > 1 && numAFormats != nargs)
449  ereport(ERROR,
450  (errcode(ERRCODE_PROTOCOL_VIOLATION),
451  errmsg("function call message contains %d argument formats but %d arguments",
452  numAFormats, nargs)));
453 
454  initStringInfo(&abuf);
455 
456  /*
457  * Copy supplied arguments into arg vector.
458  */
459  for (i = 0; i < nargs; ++i)
460  {
461  int argsize;
462  int16 aformat;
463 
464  argsize = pq_getmsgint(msgBuf, 4);
465  if (argsize == -1)
466  {
467  fcinfo->argnull[i] = true;
468  }
469  else
470  {
471  fcinfo->argnull[i] = false;
472  if (argsize < 0)
473  ereport(ERROR,
474  (errcode(ERRCODE_PROTOCOL_VIOLATION),
475  errmsg("invalid argument size %d in function call message",
476  argsize)));
477 
478  /* Reset abuf to empty, and insert raw data into it */
479  resetStringInfo(&abuf);
481  pq_getmsgbytes(msgBuf, argsize),
482  argsize);
483  }
484 
485  if (numAFormats > 1)
486  aformat = aformats[i];
487  else if (numAFormats > 0)
488  aformat = aformats[0];
489  else
490  aformat = 0; /* default = text */
491 
492  if (aformat == 0)
493  {
494  Oid typinput;
495  Oid typioparam;
496  char *pstring;
497 
498  getTypeInputInfo(fip->argtypes[i], &typinput, &typioparam);
499 
500  /*
501  * Since stringinfo.c keeps a trailing null in place even for
502  * binary data, the contents of abuf are a valid C string. We
503  * have to do encoding conversion before calling the typinput
504  * routine, though.
505  */
506  if (argsize == -1)
507  pstring = NULL;
508  else
509  pstring = pg_client_to_server(abuf.data, argsize);
510 
511  fcinfo->arg[i] = OidInputFunctionCall(typinput, pstring,
512  typioparam, -1);
513  /* Free result of encoding conversion, if any */
514  if (pstring && pstring != abuf.data)
515  pfree(pstring);
516  }
517  else if (aformat == 1)
518  {
519  Oid typreceive;
520  Oid typioparam;
521  StringInfo bufptr;
522 
523  /* Call the argument type's binary input converter */
524  getTypeBinaryInputInfo(fip->argtypes[i], &typreceive, &typioparam);
525 
526  if (argsize == -1)
527  bufptr = NULL;
528  else
529  bufptr = &abuf;
530 
531  fcinfo->arg[i] = OidReceiveFunctionCall(typreceive, bufptr,
532  typioparam, -1);
533 
534  /* Trouble if it didn't eat the whole buffer */
535  if (argsize != -1 && abuf.cursor != abuf.len)
536  ereport(ERROR,
537  (errcode(ERRCODE_INVALID_BINARY_REPRESENTATION),
538  errmsg("incorrect binary data format in function argument %d",
539  i + 1)));
540  }
541  else
542  ereport(ERROR,
543  (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
544  errmsg("unsupported format code: %d", aformat)));
545  }
546 
547  /* Return result format code */
548  return (int16) pq_getmsgint(msgBuf, 2);
549 }
550 
551 /*
552  * Parse function arguments in a 2.0 protocol message
553  *
554  * Argument values are loaded into *fcinfo, and the desired result format
555  * is returned.
556  */
557 static int16
559  FunctionCallInfo fcinfo)
560 {
561  int nargs;
562  int i;
563  StringInfoData abuf;
564 
565  nargs = pq_getmsgint(msgBuf, 4); /* # of arguments */
566 
567  if (fip->flinfo.fn_nargs != nargs || nargs > FUNC_MAX_ARGS)
568  ereport(ERROR,
569  (errcode(ERRCODE_PROTOCOL_VIOLATION),
570  errmsg("function call message contains %d arguments but function requires %d",
571  nargs, fip->flinfo.fn_nargs)));
572 
573  fcinfo->nargs = nargs;
574 
575  initStringInfo(&abuf);
576 
577  /*
578  * Copy supplied arguments into arg vector. In protocol 2.0 these are
579  * always assumed to be supplied in binary format.
580  *
581  * Note: although the original protocol 2.0 code did not have any way for
582  * the frontend to specify a NULL argument, we now choose to interpret
583  * length == -1 as meaning a NULL.
584  */
585  for (i = 0; i < nargs; ++i)
586  {
587  int argsize;
588  Oid typreceive;
589  Oid typioparam;
590 
591  getTypeBinaryInputInfo(fip->argtypes[i], &typreceive, &typioparam);
592 
593  argsize = pq_getmsgint(msgBuf, 4);
594  if (argsize == -1)
595  {
596  fcinfo->argnull[i] = true;
597  fcinfo->arg[i] = OidReceiveFunctionCall(typreceive, NULL,
598  typioparam, -1);
599  continue;
600  }
601  fcinfo->argnull[i] = false;
602  if (argsize < 0)
603  ereport(ERROR,
604  (errcode(ERRCODE_PROTOCOL_VIOLATION),
605  errmsg("invalid argument size %d in function call message",
606  argsize)));
607 
608  /* Reset abuf to empty, and insert raw data into it */
609  resetStringInfo(&abuf);
611  pq_getmsgbytes(msgBuf, argsize),
612  argsize);
613 
614  fcinfo->arg[i] = OidReceiveFunctionCall(typreceive, &abuf,
615  typioparam, -1);
616 
617  /* Trouble if it didn't eat the whole buffer */
618  if (abuf.cursor != abuf.len)
619  ereport(ERROR,
620  (errcode(ERRCODE_INVALID_BINARY_REPRESENTATION),
621  errmsg("incorrect binary data format in function argument %d",
622  i + 1)));
623  }
624 
625  /* Desired result format is always binary in protocol 2.0 */
626  return 1;
627 }
signed short int16
Definition: c.h:252
Definition: fmgr.h:53
FmgrInfo flinfo
Definition: fastpath.c:53
short fn_nargs
Definition: fmgr.h:57
void getTypeOutputInfo(Oid type, Oid *typOutput, bool *typIsVarlena)
Definition: lsyscache.c:2600
#define VARDATA(PTR)
Definition: postgres.h:305
char fname[NAMEDATALEN]
Definition: fastpath.c:57
#define GETSTRUCT(TUP)
Definition: htup_details.h:656
int GetOldFunctionMessage(StringInfo buf)
Definition: fastpath.c:79
void pq_sendbyte(StringInfo buf, int byt)
Definition: pqformat.c:105
Oid rettype
Definition: fastpath.c:54
Oid GetUserId(void)
Definition: miscinit.c:283
#define VARSIZE(PTR)
Definition: postgres.h:306
const char * pq_getmsgstring(StringInfo msg)
Definition: pqformat.c:621
#define VARHDRSZ
Definition: c.h:441
bool IsAbortedTransactionBlockState(void)
Definition: xact.c:369
int errcode(int sqlerrcode)
Definition: elog.c:575
#define MemSet(start, val, len)
Definition: c.h:853
static void SendFunctionResult(Datum retval, bool isnull, Oid rettype, int16 format)
Definition: fastpath.c:138
void PopActiveSnapshot(void)
Definition: snapmgr.c:807
#define LOG
Definition: elog.h:26
unsigned int Oid
Definition: postgres_ext.h:31
#define PG_PROTOCOL_MAJOR(v)
Definition: pqcomm.h:104
Snapshot GetTransactionSnapshot(void)
Definition: snapmgr.c:300
#define OidIsValid(objectId)
Definition: c.h:534
AclResult pg_namespace_aclcheck(Oid nsp_oid, Oid roleid, AclMode mode)
Definition: aclchk.c:4459
void pq_beginmessage(StringInfo buf, char msgtype)
Definition: pqformat.c:88
#define SearchSysCache1(cacheId, key1)
Definition: syscache.h:149
const char * pq_getmsgbytes(StringInfo msg, int datalen)
Definition: pqformat.c:550
signed int int32
Definition: c.h:253
static int16 parse_fcall_arguments_20(StringInfo msgBuf, struct fp_info *fip, FunctionCallInfo fcinfo)
Definition: fastpath.c:558
#define FUNC_MAX_ARGS
#define InvokeNamespaceSearchHook(objectId, ereport_on_violation)
Definition: objectaccess.h:174
int check_log_duration(char *msec_str, bool was_logged)
Definition: postgres.c:2100
#define NAMEDATALEN
void pfree(void *pointer)
Definition: mcxt.c:992
char * pg_client_to_server(const char *s, int len)
Definition: mbutils.c:556
#define ObjectIdGetDatum(X)
Definition: postgres.h:515
#define ERROR
Definition: elog.h:43
bool fn_strict
Definition: fmgr.h:58
char * get_func_name(Oid funcid)
Definition: lsyscache.c:1380
#define FATAL
Definition: elog.h:52
void fmgr_info(Oid functionId, FmgrInfo *finfo)
Definition: fmgr.c:159
Datum OidReceiveFunctionCall(Oid functionId, StringInfo buf, Oid typioparam, int32 typmod)
Definition: fmgr.c:2015
bytea * OidSendFunctionCall(Oid functionId, Datum val)
Definition: fmgr.c:2025
char * get_namespace_name(Oid nspid)
Definition: lsyscache.c:3006
int pq_getbytes(char *s, size_t len)
Definition: pqcomm.c:1041
#define FunctionCallInvoke(fcinfo)
Definition: fmgr.h:129
static char * buf
Definition: pg_test_fsync.c:65
void PushActiveSnapshot(Snapshot snap)
Definition: snapmgr.c:728
void aclcheck_error(AclResult aclerr, AclObjectKind objectkind, const char *objectname)
Definition: aclchk.c:3378
void enlargeStringInfo(StringInfo str, int needed)
Definition: stringinfo.c:277
void resetStringInfo(StringInfo str)
Definition: stringinfo.c:94
void pq_sendcountedtext(StringInfo buf, const char *str, int slen, bool countincludesself)
Definition: pqformat.c:131
#define ACL_USAGE
Definition: parsenodes.h:73
bool argnull[FUNC_MAX_ARGS]
Definition: fmgr.h:78
void getTypeBinaryInputInfo(Oid type, Oid *typReceive, Oid *typIOParam)
Definition: lsyscache.c:2633
void getTypeInputInfo(Oid type, Oid *typInput, Oid *typIOParam)
Definition: lsyscache.c:2567
#define ereport(elevel, rest)
Definition: elog.h:122
#define InvokeFunctionExecuteHook(objectId)
Definition: objectaccess.h:179
Oid argtypes[FUNC_MAX_ARGS]
Definition: fastpath.c:56
void initStringInfo(StringInfo str)
Definition: stringinfo.c:65
void getTypeBinaryOutputInfo(Oid type, Oid *typSend, bool *typIsVarlena)
Definition: lsyscache.c:2666
AclResult
Definition: acl.h:170
uintptr_t Datum
Definition: postgres.h:374
void ReleaseSysCache(HeapTuple tuple)
Definition: syscache.c:1083
static int16 parse_fcall_arguments(StringInfo msgBuf, struct fp_info *fip, FunctionCallInfo fcinfo)
Definition: fastpath.c:420
FormData_pg_proc * Form_pg_proc
Definition: pg_proc.h:83
#define InvalidOid
Definition: postgres_ext.h:36
Datum arg[FUNC_MAX_ARGS]
Definition: fmgr.h:77
size_t strlcpy(char *dst, const char *src, size_t siz)
Definition: strlcpy.c:45
#define HeapTupleIsValid(tuple)
Definition: htup.h:77
#define NULL
Definition: c.h:226
#define Assert(condition)
Definition: c.h:671
#define InitFunctionCallInfoData(Fcinfo, Flinfo, Nargs, Collation, Context, Resultinfo)
Definition: fmgr.h:112
int log_statement
Definition: postgres.c:91
static void fetch_fp_info(Oid func_id, struct fp_info *fip)
Definition: fastpath.c:198
void pq_sendbytes(StringInfo buf, const char *data, int datalen)
Definition: pqformat.c:115
char * OidOutputFunctionCall(Oid functionId, Datum val)
Definition: fmgr.c:2006
void * palloc(Size size)
Definition: mcxt.c:891
int errmsg(const char *fmt,...)
Definition: elog.c:797
void pq_sendint(StringInfo buf, int i, int b)
Definition: pqformat.c:236
void pq_endmessage(StringInfo buf)
Definition: pqformat.c:344
#define ACL_EXECUTE
Definition: parsenodes.h:72
AclResult pg_proc_aclcheck(Oid proc_oid, Oid roleid, AclMode mode)
Definition: aclchk.c:4421
int i
#define NameStr(name)
Definition: c.h:495
int pq_getstring(StringInfo s)
Definition: pqcomm.c:1113
Definition: c.h:435
Oid funcid
Definition: fastpath.c:52
unsigned int pq_getmsgint(StringInfo msg, int b)
Definition: pqformat.c:448
#define CHECK_FOR_INTERRUPTS()
Definition: miscadmin.h:97
static char format
Definition: pg_basebackup.c:83
#define elog
Definition: elog.h:219
void pq_getmsgend(StringInfo msg)
Definition: pqformat.c:677
Datum OidInputFunctionCall(Oid functionId, char *str, Oid typioparam, int32 typmod)
Definition: fmgr.c:1997
ProtocolVersion FrontendProtocol
Definition: globals.c:27
void appendBinaryStringInfo(StringInfo str, const char *data, int datalen)
Definition: stringinfo.c:240
int HandleFunctionRequest(StringInfo msgBuf)
Definition: fastpath.c:270