31#include <valgrind/valgrind.h>
196static unsigned int old_valgrind_error_count;
206 unsigned int valgrind_error_count = VALGRIND_COUNT_ERRORS;
208 if (
unlikely(valgrind_error_count != old_valgrind_error_count) &&
210 VALGRIND_PRINTF(
"Valgrind detected %u error(s) during execution of \"%s\"\n",
211 valgrind_error_count - old_valgrind_error_count,
216#define valgrind_report_error_query(query) ((void) 0)
261 if (inBuf->
len > 1 &&
262 inBuf->
data[inBuf->
len - 1] ==
'\n' &&
263 inBuf->
data[inBuf->
len - 2] ==
';')
275 if (inBuf->
len > 0 &&
276 inBuf->
data[inBuf->
len - 1] ==
'\\')
279 inBuf->
data[--inBuf->
len] =
'\0';
297 if (
c == EOF && inBuf->
len == 0)
368 (
errcode(ERRCODE_CONNECTION_FAILURE),
369 errmsg(
"unexpected EOF on client connection with an open transaction")));
379 (
errcode(ERRCODE_CONNECTION_DOES_NOT_EXIST),
454 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
455 errmsg(
"invalid frontend message type %d", qtype)));
503 int save_errno = errno;
549 int save_errno = errno;
605 List *raw_parsetree_list;
607 TRACE_POSTGRESQL_QUERY_PARSE_START(query_string);
617#ifdef DEBUG_NODE_TESTS_ENABLED
620 if (Debug_copy_parse_plan_trees)
626 elog(
WARNING,
"copyObject() failed to produce an equal raw parse tree");
635 if (Debug_write_read_parse_plan_trees)
643 elog(
WARNING,
"outfuncs/readfuncs failed to produce an equal raw parse tree");
650 TRACE_POSTGRESQL_QUERY_PARSE_DONE(query_string);
652 return raw_parsetree_list;
666 const char *query_string,
667 const Oid *paramTypes,
672 List *querytree_list;
674 TRACE_POSTGRESQL_QUERY_REWRITE_START(query_string);
693 TRACE_POSTGRESQL_QUERY_REWRITE_DONE(query_string);
695 return querytree_list;
705 const char *query_string,
711 List *querytree_list;
713 TRACE_POSTGRESQL_QUERY_REWRITE_START(query_string);
727 for (
int i = 0;
i < *numParams;
i++)
729 Oid ptype = (*paramTypes)[
i];
731 if (ptype ==
InvalidOid || ptype == UNKNOWNOID)
733 (
errcode(ERRCODE_INDETERMINATE_DATATYPE),
734 errmsg(
"could not determine data type of parameter $%d",
746 TRACE_POSTGRESQL_QUERY_REWRITE_DONE(query_string);
748 return querytree_list;
759 const char *query_string,
761 void *parserSetupArg,
765 List *querytree_list;
767 TRACE_POSTGRESQL_QUERY_REWRITE_START(query_string);
786 TRACE_POSTGRESQL_QUERY_REWRITE_DONE(query_string);
788 return querytree_list;
800 List *querytree_list;
823#ifdef DEBUG_NODE_TESTS_ENABLED
826 if (Debug_copy_parse_plan_trees)
833 elog(
WARNING,
"copyObject() failed to produce an equal rewritten parse tree");
839 if (Debug_write_read_parse_plan_trees)
844 foreach(lc, querytree_list)
848 Query *new_query = stringToNodeWithLocations(
str);
854 new_query->queryId = curr_query->queryId;
862 elog(
WARNING,
"outfuncs/readfuncs failed to produce an equal rewritten parse tree");
873 return querytree_list;
894 TRACE_POSTGRESQL_QUERY_PLAN_START();
905#ifdef DEBUG_NODE_TESTS_ENABLED
908 if (Debug_copy_parse_plan_trees)
919 elog(
WARNING,
"copyObject() failed to produce an equal plan tree");
926 if (Debug_write_read_parse_plan_trees)
932 new_plan = stringToNodeWithLocations(
str);
942 elog(
WARNING,
"outfuncs/readfuncs failed to produce an equal plan tree");
956 TRACE_POSTGRESQL_QUERY_PLAN_DONE();
976 foreach(query_list, querytrees)
986 stmt->canSetTag = query->canSetTag;
989 stmt->stmt_len = query->stmt_len;
990 stmt->queryId = query->queryId;
1015 List *parsetree_list;
1018 bool was_logged =
false;
1019 bool use_implicit_block;
1029 TRACE_POSTGRESQL_QUERY_START(query_string);
1035 if (save_log_statement_stats)
1070 (
errmsg(
"statement: %s", query_string),
1089 use_implicit_block = (
list_length(parsetree_list) > 1);
1094 foreach(parsetree_item, parsetree_list)
1097 bool snapshot_set =
false;
1101 List *querytree_list,
1106 const char *cmdtagname;
1135 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
1136 errmsg(
"current transaction is aborted, "
1137 "commands ignored until end of transaction block"),
1150 if (use_implicit_block)
1162 snapshot_set =
true;
1177 if (
lnext(parsetree_list, parsetree_item) != NULL)
1179 per_parsetree_context =
1181 "per-parsetree message context",
1284 if (
lnext(parsetree_list, parsetree_item) == NULL)
1295 if (use_implicit_block)
1339 if (per_parsetree_context)
1353 if (!parsetree_list)
1363 (
errmsg(
"duration: %s ms", msec_str),
1368 (
errmsg(
"duration: %s ms statement: %s",
1369 msec_str, query_string),
1375 if (save_log_statement_stats)
1378 TRACE_POSTGRESQL_QUERY_DONE(query_string);
1390 const char *stmt_name,
1396 List *parsetree_list;
1398 List *querytree_list;
1413 if (save_log_statement_stats)
1418 *stmt_name ? stmt_name :
"<unnamed>",
1442 is_named = (stmt_name[0] !=
'\0');
1453 unnamed_stmt_context =
1455 "unnamed prepared statement",
1473 (
errcode(ERRCODE_SYNTAX_ERROR),
1474 errmsg(
"cannot insert multiple commands into a prepared statement")));
1476 if (parsetree_list !=
NIL)
1478 bool snapshot_set =
false;
1493 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
1494 errmsg(
"current transaction is aborted, "
1495 "commands ignored until end of transaction block"),
1511 snapshot_set =
true;
1532 raw_parse_tree = NULL;
1535 querytree_list =
NIL;
1544 if (unnamed_stmt_context)
1550 unnamed_stmt_context,
1599 (
errmsg(
"duration: %s ms", msec_str),
1604 (
errmsg(
"duration: %s ms parse %s: %s",
1606 *stmt_name ? stmt_name :
"<unnamed>",
1612 if (save_log_statement_stats)
1626 const char *portal_name;
1627 const char *stmt_name;
1629 int16 *pformats = NULL;
1632 int16 *rformats = NULL;
1637 char *saved_stmt_name;
1641 bool snapshot_set =
false;
1653 *portal_name ? portal_name :
"<unnamed>",
1654 *stmt_name ? stmt_name :
"<unnamed>")));
1657 if (stmt_name[0] !=
'\0')
1670 (
errcode(ERRCODE_UNDEFINED_PSTATEMENT),
1671 errmsg(
"unnamed prepared statement does not exist")));
1694 if (save_log_statement_stats)
1710 if (numPFormats > 0)
1713 for (
int i = 0;
i < numPFormats;
i++)
1720 if (numPFormats > 1 && numPFormats != numParams)
1722 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
1723 errmsg(
"bind message has %d parameter formats but %d parameters",
1724 numPFormats, numParams)));
1728 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
1729 errmsg(
"bind message supplies %d parameters, but prepared statement \"%s\" requires %d",
1745 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
1746 errmsg(
"current transaction is aborted, "
1747 "commands ignored until end of transaction block"),
1754 if (portal_name[0] ==
'\0')
1772 saved_stmt_name =
pstrdup(stmt_name);
1774 saved_stmt_name = NULL;
1783 if (numParams > 0 ||
1788 snapshot_set =
true;
1796 char **knownTextValues = NULL;
1808 params_errcxt.
arg = &one_param_data;
1813 for (
int paramno = 0; paramno < numParams; paramno++)
1823 one_param_data.
paramno = paramno;
1827 isNull = (plength == -1);
1841 csave = pvalue[plength];
1842 pvalue[plength] =
'\0';
1851 if (numPFormats > 1)
1852 pformat = pformats[paramno];
1853 else if (numPFormats > 0)
1854 pformat = pformats[0];
1895 if (knownTextValues == NULL)
1899 knownTextValues[paramno] =
pstrdup(pstring);
1909 knownTextValues[paramno] =
1917 if (pstring != pbuf.
data)
1921 else if (pformat == 1)
1942 (
errcode(ERRCODE_INVALID_BINARY_REPRESENTATION),
1943 errmsg(
"incorrect binary data format in bind parameter %d",
1949 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1950 errmsg(
"unsupported format code: %d",
1957 pbuf.
data[plength] = csave;
1995 params_data.
params = params;
1998 params_errcxt.
arg = ¶ms_data;
2003 if (numRFormats > 0)
2006 for (
int i = 0;
i < numRFormats;
i++)
2066 (
errmsg(
"duration: %s ms", msec_str),
2071 (
errmsg(
"duration: %s ms bind %s%s%s: %s",
2073 *stmt_name ? stmt_name :
"<unnamed>",
2074 *portal_name ?
"/" :
"",
2075 *portal_name ? portal_name :
"",
2082 if (save_log_statement_stats)
2103 const char *sourceText;
2104 const char *prepStmtName;
2107 bool is_xact_command;
2108 bool execute_is_fetch;
2109 bool was_logged =
false;
2113 const char *cmdtagname;
2125 (
errcode(ERRCODE_UNDEFINED_CURSOR),
2126 errmsg(
"portal \"%s\" does not exist", portal_name)));
2152 prepStmtName =
"<unnamed>";
2162 foreach(lc, portal->
stmts)
2177 if (save_log_statement_stats)
2202 execute_is_fetch = !portal->
atStart;
2210 _(
"execute fetch from") :
2213 *portal_name ?
"/" :
"",
2214 *portal_name ? portal_name :
"",
2228 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
2229 errmsg(
"current transaction is aborted, "
2230 "commands ignored until end of transaction block"),
2241 params_data.
params = portalParams;
2244 params_errcxt.
arg = ¶ms_data;
2281 portalParams = NULL;
2327 (
errmsg(
"duration: %s ms", msec_str),
2332 (
errmsg(
"duration: %s ms %s %s%s%s: %s",
2335 _(
"execute fetch from") :
2338 *portal_name ?
"/" :
"",
2339 *portal_name ? portal_name :
"",
2346 if (save_log_statement_stats)
2347 ShowUsage(
"EXECUTE MESSAGE STATISTICS");
2372 foreach(stmt_item, stmt_list)
2409 bool exceeded_duration;
2410 bool exceeded_sample_duration;
2411 bool in_sample =
false;
2416 msecs = usecs / 1000;
2438 if (exceeded_sample_duration)
2446 secs * 1000 + msecs, usecs % 1000);
2447 if ((exceeded_duration || in_sample ||
xact_is_sampled) && !was_logged)
2468 foreach(parsetree_item, raw_parsetree_list)
2480 errdetail(
"prepare: %s", pstmt->plansource->query_string);
2504 if (
str &&
str[0] !=
'\0')
2520 errdetail(
"Abort reason: recovery conflict");
2536 errdetail(
"User was holding shared buffer pin for too long.");
2539 errdetail(
"User was holding a relation lock for too long.");
2542 errdetail(
"User was or might have been using tablespace that must be dropped.");
2545 errdetail(
"User query might have needed to see row versions that must be removed.");
2548 errdetail(
"User was using a logical replication slot that must be invalidated.");
2551 errdetail(
"User transaction caused buffer deadlock with recovery.");
2554 errdetail(
"User was connected to a database that must be dropped.");
2576 if (
data->paramno < 0)
2585 quotedval =
buf.data;
2590 if (
data->portalName &&
data->portalName[0] !=
'\0')
2593 errcontext(
"portal \"%s\" parameter $%d = %s",
2594 data->portalName,
data->paramno + 1, quotedval);
2597 data->portalName,
data->paramno + 1);
2602 errcontext(
"unnamed portal parameter $%d = %s",
2603 data->paramno + 1, quotedval);
2633 if (stmt_name[0] !=
'\0')
2646 (
errcode(ERRCODE_UNDEFINED_PSTATEMENT),
2647 errmsg(
"unnamed prepared statement does not exist")));
2665 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
2666 errmsg(
"current transaction is aborted, "
2667 "commands ignored until end of transaction block"),
2728 (
errcode(ERRCODE_UNDEFINED_CURSOR),
2729 errmsg(
"portal \"%s\" does not exist", portal_name)));
2742 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
2743 errmsg(
"current transaction is aborted, "
2744 "commands ignored until end of transaction block"),
2812#ifdef MEMORY_CONTEXT_CHECKING
2818#ifdef SHOW_MEMORY_STATS
2910 sigprocmask(SIG_SETMASK, &
BlockSig, NULL);
2959 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
2960 errmsg(
"terminating connection because of unexpected SIGQUIT signal")));
2965 (
errcode(ERRCODE_CRASH_SHUTDOWN),
2966 errmsg(
"terminating connection because of crash of another server process"),
2967 errdetail(
"The postmaster has commanded this server process to roll back"
2968 " the current transaction and exit, because another"
2969 " server process exited abnormally and possibly corrupted"
2971 errhint(
"In a moment you should be able to reconnect to the"
2972 " database and repeat your command.")));
2977 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
2978 errmsg(
"terminating connection due to immediate shutdown command")));
3055 (
errcode(ERRCODE_FLOATING_POINT_EXCEPTION),
3056 errmsg(
"floating-point exception"),
3057 errdetail(
"An invalid floating-point operation was signaled. "
3058 "This probably means an out-of-range result or an "
3059 "invalid operation, such as division by zero.")));
3201 errmsg(
"canceling statement due to conflict with recovery"),
3220 ERRCODE_DATABASE_DROPPED :
3222 errmsg(
"terminating connection due to conflict with recovery"),
3224 errhint(
"In a moment you should be able to reconnect to the"
3225 " database and repeat your command.")));
3229 elog(
FATAL,
"unrecognized conflict mode: %d", (
int) reason);
3293 (
errcode(ERRCODE_QUERY_CANCELED),
3294 errmsg(
"canceling authentication due to timeout")));
3297 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3298 errmsg(
"terminating autovacuum process due to administrator command")));
3301 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3302 errmsg(
"terminating logical replication worker due to administrator command")));
3316 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3317 errmsg(
"terminating background worker \"%s\" due to administrator command",
3322 (
errmsg_internal(
"io worker shutting down due to administrator command")));
3328 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3329 errmsg(
"terminating connection due to administrator command")));
3359 (
errcode(ERRCODE_CONNECTION_FAILURE),
3360 errmsg(
"connection to client lost")));
3385 bool lock_timeout_occurred;
3386 bool stmt_timeout_occurred;
3403 if (lock_timeout_occurred && stmt_timeout_occurred &&
3405 lock_timeout_occurred =
false;
3407 if (lock_timeout_occurred)
3411 (
errcode(ERRCODE_LOCK_NOT_AVAILABLE),
3412 errmsg(
"canceling statement due to lock timeout")));
3414 if (stmt_timeout_occurred)
3418 (
errcode(ERRCODE_QUERY_CANCELED),
3419 errmsg(
"canceling statement due to statement timeout")));
3425 (
errcode(ERRCODE_QUERY_CANCELED),
3426 errmsg(
"canceling autovacuum task")));
3438 (
errcode(ERRCODE_QUERY_CANCELED),
3439 errmsg(
"canceling statement due to user request")));
3459 (
errcode(ERRCODE_IDLE_IN_TRANSACTION_SESSION_TIMEOUT),
3460 errmsg(
"terminating connection due to idle-in-transaction timeout")));
3472 (
errcode(ERRCODE_TRANSACTION_TIMEOUT),
3473 errmsg(
"terminating connection due to transaction timeout")));
3485 (
errcode(ERRCODE_IDLE_SESSION_TIMEOUT),
3486 errmsg(
"terminating connection due to idle-session timeout")));
3522 GUC_check_errdetail(
"\"client_connection_check_interval\" must be set to 0 on this platform.");
3559 "\"log_parser_stats\", \"log_planner_stats\", "
3560 "or \"log_executor_stats\" is true.");
3606 foreach(l, elemlist)
3608 char *tok = (
char *)
lfirst(l);
3628 *((
int *) *extra) = flags;
3639 int *flags = (
int *) extra;
3657 sprintf(debugstr,
"debug%d", debug_flag);
3668 if (debug_flag >= 2)
3670 if (debug_flag >= 3)
3672 if (debug_flag >= 4)
3674 if (debug_flag >= 5)
3682 const char *tmp = NULL;
3687 tmp =
"enable_seqscan";
3690 tmp =
"enable_indexscan";
3693 tmp =
"enable_indexonlyscan";
3696 tmp =
"enable_bitmapscan";
3699 tmp =
"enable_tidscan";
3702 tmp =
"enable_nestloop";
3705 tmp =
"enable_mergejoin";
3708 tmp =
"enable_hashjoin";
3728 return "log_parser_stats";
3729 else if (
optarg[1] ==
'l')
3730 return "log_planner_stats";
3734 return "log_executor_stats";
3775 if (argc > 1 && strcmp(argv[1],
"--single") == 0)
3786#ifdef HAVE_INT_OPTERR
3801 while ((
flag =
getopt(argc, argv,
"B:bC:c:D:d:EeFf:h:ijk:lN:nOPp:r:S:sTt:v:W:-:")) != -1)
3829 (
errcode(ERRCODE_SYNTAX_ERROR),
3843 (
errcode(ERRCODE_SYNTAX_ERROR),
3844 errmsg(
"--%s requires a value",
3848 (
errcode(ERRCODE_SYNTAX_ERROR),
3849 errmsg(
"-c %s requires a value",
3987 if (errs || argc !=
optind)
3995 errcode(ERRCODE_SYNTAX_ERROR),
3996 errmsg(
"invalid command-line argument for server process: %s", argv[
optind]),
4000 errcode(ERRCODE_SYNTAX_ERROR),
4001 errmsg(
"%s: invalid command-line argument: %s",
4011#ifdef HAVE_INT_OPTRESET
4030 const char *
dbname = NULL;
4053 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4054 errmsg(
"%s: no database nor user name specified",
4158 sigjmp_buf local_sigjmp_buf;
4161 volatile bool send_ready_for_query =
true;
4162 volatile bool idle_in_transaction_timeout_enabled =
false;
4163 volatile bool idle_session_timeout_enabled =
false;
4242 (
errcode(ERRCODE_INTERNAL_ERROR),
4243 errmsg(
"could not generate random cancel key")));
4310 printf(
"\nPostgreSQL stand-alone backend %s\n", PG_VERSION);
4329 "RowDescriptionContext",
4360 if (sigsetjmp(local_sigjmp_buf, 1) != 0)
4389 idle_in_transaction_timeout_enabled =
false;
4390 idle_session_timeout_enabled =
false;
4466 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
4467 errmsg(
"terminating connection because protocol synchronization was lost")));
4477 send_ready_for_query =
true;
4498 old_valgrind_error_count = VALGRIND_COUNT_ERRORS;
4532 if (send_ready_for_query)
4543 idle_in_transaction_timeout_enabled =
true;
4557 idle_in_transaction_timeout_enabled =
true;
4590 if (stats_timeout > 0)
4609 idle_session_timeout_enabled =
true;
4644 errmsg(
"connection ready: setup total=%.3f ms, fork=%.3f ms, authentication=%.3f ms",
4651 send_ready_for_query =
false;
4675 if (idle_in_transaction_timeout_enabled)
4678 idle_in_transaction_timeout_enabled =
false;
4680 if (idle_session_timeout_enabled)
4683 idle_session_timeout_enabled =
false;
4719 const char *query_string;
4737 send_ready_for_query =
true;
4743 const char *stmt_name;
4744 const char *query_string;
4746 Oid *paramTypes = NULL;
4759 for (
int i = 0;
i < numParams;
i++)
4765 paramTypes, numParams);
4788 const char *portal_name;
4838 send_ready_for_query =
true;
4844 const char *close_target;
4855 if (close_target[0] !=
'\0')
4874 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
4875 errmsg(
"invalid CLOSE message subtype %d",
4890 const char *describe_target;
4901 switch (describe_type)
4911 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
4912 errmsg(
"invalid DESCRIBE message subtype %d",
4938 send_ready_for_query =
true;
4984 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
4985 errmsg(
"invalid frontend message type %d",
5005 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
5006 errmsg(
"fastpath function calls not supported in a replication connection")));
5009 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
5010 errmsg(
"extended query protocol not supported in a replication connection")));
5029 struct timeval
user,
5031 struct timeval elapse_t;
5037 memcpy(&sys, &r.
ru_stime,
sizeof(sys));
5038 if (elapse_t.tv_usec <
Save_t.tv_usec)
5041 elapse_t.tv_usec += 1000000;
5062 "!\t%ld.%06ld s user, %ld.%06ld s system, %ld.%06ld s elapsed\n",
5067 (
long) (elapse_t.tv_sec -
Save_t.tv_sec),
5068 (
long) (elapse_t.tv_usec -
Save_t.tv_usec));
5070 "!\t[%ld.%06ld s user, %ld.%06ld s system total]\n",
5072 (
long)
user.tv_usec,
5074 (
long) sys.tv_usec);
5084 "!\t%ld kB max resident size\n",
5094 "!\t%ld/%ld [%ld/%ld] filesystem blocks in/out\n",
5095 r.ru_inblock -
Save_r.ru_inblock,
5097 r.ru_oublock -
Save_r.ru_oublock,
5098 r.ru_inblock, r.ru_oublock);
5100 "!\t%ld/%ld [%ld/%ld] page faults/reclaims, %ld [%ld] swaps\n",
5101 r.ru_majflt -
Save_r.ru_majflt,
5102 r.ru_minflt -
Save_r.ru_minflt,
5103 r.ru_majflt, r.ru_minflt,
5104 r.ru_nswap -
Save_r.ru_nswap,
5107 "!\t%ld [%ld] signals rcvd, %ld/%ld [%ld/%ld] messages rcvd/sent\n",
5108 r.ru_nsignals -
Save_r.ru_nsignals,
5110 r.ru_msgrcv -
Save_r.ru_msgrcv,
5111 r.ru_msgsnd -
Save_r.ru_msgsnd,
5112 r.ru_msgrcv, r.ru_msgsnd);
5114 "!\t%ld/%ld [%ld/%ld] voluntary/involuntary context switches\n",
5115 r.ru_nvcsw -
Save_r.ru_nvcsw,
5116 r.ru_nivcsw -
Save_r.ru_nivcsw,
5117 r.ru_nvcsw, r.ru_nivcsw);
5121 if (
str.data[
str.len - 1] ==
'\n')
5122 str.data[--
str.len] =
'\0';
5148 msecs = usecs / 1000;
5156 (
errmsg(
"disconnection: session time: %d:%02d:%02d.%03d "
5157 "user=%s database=%s host=%s%s%s",
5158 hours, minutes, seconds, msecs,
5159 port->user_name,
port->database_name,
port->remote_host,
5160 port->remote_port[0] ?
" port=" :
"",
port->remote_port)));
Datum querytree(PG_FUNCTION_ARGS)
volatile sig_atomic_t ParallelApplyMessagePending
void ProcessParallelApplyMessages(void)
void ProcessNotifyInterrupt(bool flush)
volatile sig_atomic_t notifyInterruptPending
void ProcessParallelMessages(void)
volatile sig_atomic_t ParallelMessagePending
void DropPreparedStatement(const char *stmt_name, bool showError)
PreparedStatement * FetchPreparedStatement(const char *stmt_name, bool throwError)
void StorePreparedStatement(const char *stmt_name, CachedPlanSource *plansource, bool from_sql)
void elog_node_display(int lev, const char *title, const void *obj, bool pretty)
List * raw_parser(const char *str, RawParseMode mode)
bool IsLogicalWorker(void)
void TimestampDifference(TimestampTz start_time, TimestampTz stop_time, long *secs, int *microsecs)
TimestampTz GetCurrentTimestamp(void)
ConnectionTiming conn_timing
@ LOG_CONNECTION_SETUP_DURATIONS
void pgstat_report_query_id(uint64 query_id, bool force)
void pgstat_report_activity(BackendState state, const char *cmd_str)
@ STATE_IDLEINTRANSACTION_ABORTED
@ STATE_IDLEINTRANSACTION
bool HoldingBufferPinThatDelaysRecovery(void)
#define unconstify(underlying_type, expr)
const char * GetCommandTagNameAndLen(CommandTag commandTag, Size *len)
#define TIMESTAMP_MINUS_INFINITY
void EndCommand(const QueryCompletion *qc, CommandDest dest, bool force_undecorated_output)
DestReceiver * CreateDestReceiver(CommandDest dest)
void BeginCommand(CommandTag commandTag, CommandDest dest)
void ReadyForQuery(CommandDest dest)
void NullCommand(CommandDest dest)
int errmsg_internal(const char *fmt,...)
int errhidestmt(bool hide_stmt)
void EmitErrorReport(void)
int errdetail_internal(const char *fmt,...)
int errdetail(const char *fmt,...)
ErrorContextCallback * error_context_stack
void FlushErrorState(void)
int errhint(const char *fmt,...)
int errcode(int sqlerrcode)
int errmsg(const char *fmt,...)
sigjmp_buf * PG_exception_stack
#define WARNING_CLIENT_ONLY
#define ereport(elevel,...)
bool equal(const void *a, const void *b)
void EventTriggerOnLogin(void)
void HandleFunctionRequest(StringInfo msgBuf)
void set_max_safe_fds(void)
#define palloc_array(type, count)
#define palloc0_array(type, count)
Datum OidReceiveFunctionCall(Oid functionId, StringInfo buf, Oid typioparam, int32 typmod)
Datum OidInputFunctionCall(Oid functionId, char *str, Oid typioparam, int32 typmod)
volatile sig_atomic_t IdleStatsUpdateTimeoutPending
volatile sig_atomic_t LogMemoryContextPending
volatile sig_atomic_t ProcSignalBarrierPending
volatile sig_atomic_t InterruptPending
volatile sig_atomic_t IdleSessionTimeoutPending
volatile uint32 QueryCancelHoldoffCount
ProtocolVersion FrontendProtocol
volatile sig_atomic_t IdleInTransactionSessionTimeoutPending
volatile uint32 InterruptHoldoffCount
volatile sig_atomic_t TransactionTimeoutPending
volatile sig_atomic_t ClientConnectionLost
volatile uint32 CritSectionCount
volatile sig_atomic_t QueryCancelPending
TimestampTz MyStartTimestamp
char OutputFileName[MAXPGPATH]
volatile sig_atomic_t ProcDiePending
volatile sig_atomic_t CheckClientConnectionPending
void ProcessConfigFile(GucContext context)
void BeginReportingGUCOptions(void)
void SetConfigOption(const char *name, const char *value, GucContext context, GucSource source)
void * guc_malloc(int elevel, size_t size)
bool SelectConfigFiles(const char *userDoption, const char *progname)
void ParseLongOption(const char *string, char **name, char **value)
void InitializeGUCOptions(void)
void ReportChangedGUCOptions(void)
#define GUC_check_errdetail
int log_parameter_max_length_on_error
int log_min_duration_statement
int log_min_duration_sample
bool Debug_print_rewritten
int log_parameter_max_length
double log_statement_sample_rate
Assert(PointerIsAligned(start, uint64))
#define INJECTION_POINT(name)
volatile sig_atomic_t ConfigReloadPending
void SignalHandlerForConfigReload(SIGNAL_ARGS)
void on_proc_exit(pg_on_exit_callback function, Datum arg)
bool proc_exit_inprogress
void InitializeShmemGUCs(void)
void CreateSharedMemoryAndSemaphores(void)
if(TABLE==NULL||TABLE_index==NULL)
void jit_reset_after_error(void)
void SetLatch(Latch *latch)
bool IsLogicalLauncher(void)
#define PQ_SMALL_MESSAGE_LIMIT
#define PQ_LARGE_MESSAGE_LIMIT
List * lappend(List *list, void *datum)
static List * new_list(NodeTag type, int min_size)
void list_free(List *list)
LOCALLOCK * GetAwaitedLock(void)
void getTypeInputInfo(Oid type, Oid *typInput, Oid *typIOParam)
void getTypeBinaryInputInfo(Oid type, Oid *typReceive, Oid *typIOParam)
DispatchOption parse_dispatch_option(const char *name)
char * pg_client_to_server(const char *s, int len)
MemoryContext MessageContext
void MemoryContextReset(MemoryContext context)
char * pstrdup(const char *in)
void MemoryContextSetParent(MemoryContext context, MemoryContext new_parent)
void pfree(void *pointer)
MemoryContext TopMemoryContext
char * pnstrdup(const char *in, Size len)
void MemoryContextStats(MemoryContext context)
MemoryContext PostmasterContext
void ProcessLogMemoryContextInterrupt(void)
void MemoryContextDelete(MemoryContext context)
#define AllocSetContextCreate
#define ALLOCSET_DEFAULT_SIZES
#define RESUME_INTERRUPTS()
#define IsExternalConnectionBackend(backend_type)
#define GetProcessingMode()
#define HOLD_CANCEL_INTERRUPTS()
#define INIT_PG_LOAD_SESSION_LIBS
#define AmAutoVacuumWorkerProcess()
#define RESUME_CANCEL_INTERRUPTS()
#define AmBackgroundWorkerProcess()
#define CHECK_FOR_INTERRUPTS()
#define HOLD_INTERRUPTS()
#define SetProcessingMode(mode)
#define AmIoWorkerProcess()
void ChangeToDataDir(void)
void process_shmem_requests(void)
void InitStandaloneProcess(const char *argv0)
void process_shared_preload_libraries(void)
BackendType MyBackendType
void CreateDataDirLockFile(bool amPostmaster)
#define IsA(nodeptr, _type_)
char * nodeToStringWithLocations(const void *obj)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
ParamListInfo makeParamList(int numParams)
char * BuildParamLogString(ParamListInfo params, char **knownTextValues, int maxlen)
void ParamsErrorCallback(void *arg)
void(* ParserSetupHook)(struct ParseState *pstate, void *arg)
#define CURSOR_OPT_PARALLEL_OK
#define CURSOR_OPT_BINARY
Query * parse_analyze_withcb(RawStmt *parseTree, const char *sourceText, ParserSetupHook parserSetup, void *parserSetupArg, QueryEnvironment *queryEnv)
bool analyze_requires_snapshot(RawStmt *parseTree)
Query * parse_analyze_fixedparams(RawStmt *parseTree, const char *sourceText, const Oid *paramTypes, int numParams, QueryEnvironment *queryEnv)
Query * parse_analyze_varparams(RawStmt *parseTree, const char *sourceText, Oid **paramTypes, int *numParams, QueryEnvironment *queryEnv)
int getopt(int nargc, char *const *nargv, const char *ostr)
PGDLLIMPORT char * optarg
#define lfirst_node(type, lc)
static int list_length(const List *l)
#define linitial_node(type, l)
static ListCell * lnext(const List *l, const ListCell *c)
double pg_prng_double(pg_prng_state *state)
pg_prng_state pg_global_prng_state
static rewind_source * source
#define MAX_MULTIBYTE_CHAR_LEN
#define ERRCODE_T_R_SERIALIZATION_FAILURE
long pgstat_report_stat(bool force)
void pgstat_report_connect(Oid dboid)
void pgstat_report_recovery_conflict(int reason)
SessionEndType pgStatSessionEndCause
void DropCachedPlan(CachedPlanSource *plansource)
void SaveCachedPlan(CachedPlanSource *plansource)
void CompleteCachedPlan(CachedPlanSource *plansource, List *querytree_list, MemoryContext querytree_context, Oid *param_types, int num_params, ParserSetupHook parserSetup, void *parserSetupArg, int cursor_options, bool fixed_result)
CachedPlan * GetCachedPlan(CachedPlanSource *plansource, ParamListInfo boundParams, ResourceOwner owner, QueryEnvironment *queryEnv)
CachedPlanSource * CreateCachedPlan(RawStmt *raw_parse_tree, const char *query_string, CommandTag commandTag)
List * CachedPlanGetTargetList(CachedPlanSource *plansource, QueryEnvironment *queryEnv)
PlannedStmt * planner(Query *parse, const char *query_string, int cursorOptions, ParamListInfo boundParams)
void InitPostmasterChildSlots(void)
QuitSignalReason GetQuitSignalReason(void)
bool pg_strong_random(void *buf, size_t len)
int pg_strcasecmp(const char *s1, const char *s2)
size_t strlcpy(char *dst, const char *src, size_t siz)
void PortalDefineQuery(Portal portal, const char *prepStmtName, const char *sourceText, CommandTag commandTag, List *stmts, CachedPlan *cplan, CachedPlanSource *plansource)
void PortalDrop(Portal portal, bool isTopCommit)
Portal GetPortalByName(const char *name)
Portal CreatePortal(const char *name, bool allowDup, bool dupSilent)
void PortalErrorCleanup(void)
static int errdetail_recovery_conflict(ProcSignalReason reason)
struct BindParamCbData BindParamCbData
static void disable_statement_timeout(void)
PlannedStmt * pg_plan_query(Query *querytree, const char *query_string, int cursorOptions, ParamListInfo boundParams)
static bool IsTransactionStmtList(List *pstmts)
List * pg_analyze_and_rewrite_withcb(RawStmt *parsetree, const char *query_string, ParserSetupHook parserSetup, void *parserSetupArg, QueryEnvironment *queryEnv)
void assign_transaction_timeout(int newval, void *extra)
List * pg_parse_query(const char *query_string)
static bool check_log_statement(List *stmt_list)
static void exec_describe_statement_message(const char *stmt_name)
void assign_restrict_nonsystem_relation_kind(const char *newval, void *extra)
void process_postgres_switches(int argc, char *argv[], GucContext ctx, const char **dbname)
void quickdie(SIGNAL_ARGS)
static bool IsTransactionExitStmtList(List *pstmts)
static void log_disconnections(int code, Datum arg)
static int errdetail_abort(void)
static void forbidden_in_wal_sender(char firstchar)
static void exec_execute_message(const char *portal_name, long max_rows)
void PostgresSingleUserMain(int argc, char *argv[], const char *username)
List * pg_plan_queries(List *querytrees, const char *query_string, int cursorOptions, ParamListInfo boundParams)
void set_debug_options(int debug_flag, GucContext context, GucSource source)
static bool UseSemiNewlineNewline
static CachedPlanSource * unnamed_stmt_psrc
void FloatExceptionHandler(SIGNAL_ARGS)
int client_connection_check_interval
bool check_log_stats(bool *newval, void **extra, GucSource source)
void StatementCancelHandler(SIGNAL_ARGS)
CommandDest whereToSendOutput
static bool ignore_till_sync
static void finish_xact_command(void)
bool set_plan_disabling_options(const char *arg, GucContext context, GucSource source)
static void enable_statement_timeout(void)
List * pg_analyze_and_rewrite_fixedparams(RawStmt *parsetree, const char *query_string, const Oid *paramTypes, int numParams, QueryEnvironment *queryEnv)
int check_log_duration(char *msec_str, bool was_logged)
static struct timeval Save_t
const char * debug_query_string
static void exec_simple_query(const char *query_string)
const char * get_stats_option_name(const char *arg)
void HandleRecoveryConflictInterrupt(ProcSignalReason reason)
List * pg_rewrite_query(Query *query)
static volatile sig_atomic_t RecoveryConflictPendingReasons[NUM_PROCSIGNALS]
static int errdetail_execute(List *raw_parsetree_list)
void ShowUsage(const char *title)
static void exec_parse_message(const char *query_string, const char *stmt_name, Oid *paramTypes, int numParams)
int restrict_nonsystem_relation_kind
static const char * userDoption
static volatile sig_atomic_t RecoveryConflictPending
static void exec_bind_message(StringInfo input_message)
static bool DoingCommandRead
static int interactive_getc(void)
static int errdetail_params(ParamListInfo params)
static void ProcessRecoveryConflictInterrupts(void)
static int SocketBackend(StringInfo inBuf)
void ProcessClientReadInterrupt(bool blocked)
void ProcessInterrupts(void)
static void bind_param_error_callback(void *arg)
static bool IsTransactionExitStmt(Node *parsetree)
void PostgresMain(const char *dbname, const char *username)
static MemoryContext row_description_context
static int InteractiveBackend(StringInfo inBuf)
static void ProcessRecoveryConflictInterrupt(ProcSignalReason reason)
static struct rusage Save_r
bool check_client_connection_check_interval(int *newval, void **extra, GucSource source)
static StringInfoData row_description_buf
void ProcessClientWriteInterrupt(bool blocked)
static bool doing_extended_query_message
static void start_xact_command(void)
bool check_restrict_nonsystem_relation_kind(char **newval, void **extra, GucSource source)
static void exec_describe_portal_message(const char *portal_name)
List * pg_analyze_and_rewrite_varparams(RawStmt *parsetree, const char *query_string, Oid **paramTypes, int *numParams, QueryEnvironment *queryEnv)
static void drop_unnamed_stmt(void)
#define valgrind_report_error_query(query)
static int ReadCommand(StringInfo inBuf)
bool check_stage_log_stats(bool *newval, void **extra, GucSource source)
void InitializeMaxBackends(void)
void InitializeFastPathLocks(void)
void InitPostgres(const char *in_dbname, Oid dboid, const char *username, Oid useroid, bits32 flags, char *out_dbname)
bool ClientAuthInProgress
BackgroundWorker * MyBgworkerEntry
int pq_getmessage(StringInfo s, int maxlen)
bool pq_is_reading_msg(void)
bool pq_check_connection(void)
void pq_startmsgread(void)
void PortalSetResultFormat(Portal portal, int nFormats, int16 *formats)
void PortalStart(Portal portal, ParamListInfo params, int eflags, Snapshot snapshot)
List * FetchPortalTargetList(Portal portal)
bool PortalRun(Portal portal, long count, bool isTopLevel, DestReceiver *dest, DestReceiver *altdest, QueryCompletion *qc)
void SetRemoteDestReceiverParams(DestReceiver *self, Portal portal)
void SendRowDescriptionMessage(StringInfo buf, TupleDesc typeinfo, List *targetlist, int16 *formats)
void ProcessProcSignalBarrier(void)
void procsignal_sigusr1_handler(SIGNAL_ARGS)
@ PROCSIG_RECOVERY_CONFLICT_BUFFERPIN
@ PROCSIG_RECOVERY_CONFLICT_LOCK
@ PROCSIG_RECOVERY_CONFLICT_LOGICALSLOT
@ PROCSIG_RECOVERY_CONFLICT_DATABASE
@ PROCSIG_RECOVERY_CONFLICT_SNAPSHOT
@ PROCSIG_RECOVERY_CONFLICT_LAST
@ PROCSIG_RECOVERY_CONFLICT_FIRST
@ PROCSIG_RECOVERY_CONFLICT_TABLESPACE
@ PROCSIG_RECOVERY_CONFLICT_STARTUP_DEADLOCK
#define PqMsg_CloseComplete
#define PqMsg_BindComplete
#define PqMsg_ParameterDescription
#define PqMsg_FunctionCall
#define PqMsg_PortalSuspended
#define PqMsg_BackendKeyData
#define PqMsg_ParseComplete
void set_ps_display_with_len(const char *activity, size_t len)
static void set_ps_display(const char *activity)
int getrusage(int who, struct rusage *rusage)
List * QueryRewrite(Query *parsetree)
void ProcessCatchupInterrupt(void)
volatile sig_atomic_t catchupInterruptPending
ReplicationSlot * MyReplicationSlot
void ReplicationSlotRelease(void)
void ReplicationSlotCleanup(bool synced_only)
Snapshot GetTransactionSnapshot(void)
void PushActiveSnapshot(Snapshot snapshot)
bool ActiveSnapshotSet(void)
void InvalidateCatalogSnapshotConditionally(void)
void PopActiveSnapshot(void)
int IdleInTransactionSessionTimeout
int GetStartupBufferPinWaitBufId(void)
void LockErrorCleanup(void)
void CheckDeadLockAlert(void)
void resetStringInfo(StringInfo str)
void appendStringInfo(StringInfo str, const char *fmt,...)
void appendStringInfoString(StringInfo str, const char *s)
void appendStringInfoChar(StringInfo str, char ch)
void initStringInfo(StringInfo str)
static void initReadOnlyStringInfo(StringInfo str, char *data, int len)
void appendStringInfoStringQuoted(StringInfo str, const char *s, int maxlen)
char bgw_type[BGW_MAXLEN]
const char * query_string
struct RawStmt * raw_parse_tree
TimestampTz ready_for_use
TimestampTz socket_create
struct ErrorContextCallback * previous
void(* callback)(void *arg)
bool recoveryConflictPending
ParamExternData params[FLEXIBLE_ARRAY_MEMBER]
MemoryContext portalContext
ParamListInfo portalParams
const char * prepStmtName
CachedPlanSource * plansource
void(* rDestroy)(DestReceiver *self)
#define RESTRICT_RELKIND_FOREIGN_TABLE
#define RESTRICT_RELKIND_VIEW
void enable_timeout_after(TimeoutId id, int delay_ms)
bool get_timeout_active(TimeoutId id)
void disable_all_timeouts(bool keep_indicators)
TimestampTz get_timeout_finish_time(TimeoutId id)
void InitializeTimeouts(void)
void disable_timeout(TimeoutId id, bool keep_indicator)
bool get_timeout_indicator(TimeoutId id, bool reset_indicator)
@ IDLE_IN_TRANSACTION_SESSION_TIMEOUT
@ IDLE_STATS_UPDATE_TIMEOUT
@ CLIENT_CONNECTION_CHECK_TIMEOUT
CommandTag CreateCommandTag(Node *parsetree)
LogStmtLevel GetCommandLogLevel(Node *parsetree)
static uint64 TimestampDifferenceMicroseconds(TimestampTz start_time, TimestampTz stop_time)
bool SplitIdentifierString(char *rawstring, char separator, List **namelist)
bool WaitEventSetCanReportClosed(void)
void WalSndErrorCleanup(void)
bool exec_replication_command(const char *cmd_string)
int gettimeofday(struct timeval *tp, void *tzp)
bool IsTransactionOrTransactionBlock(void)
void BeginImplicitTransactionBlock(void)
bool IsTransactionState(void)
void CommandCounterIncrement(void)
void StartTransactionCommand(void)
bool IsAbortedTransactionBlockState(void)
void EndImplicitTransactionBlock(void)
bool IsSubTransaction(void)
void SetCurrentStatementStartTimestamp(void)
TimestampTz GetCurrentStatementStartTimestamp(void)
void CommitTransactionCommand(void)
void AbortCurrentTransaction(void)
#define XACT_FLAGS_PIPELINING
#define XACT_FLAGS_NEEDIMMEDIATECOMMIT
void InitializeWalConsistencyChecking(void)
void LocalProcessControlFile(bool reset)