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;
1136 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
1137 errmsg(
"current transaction is aborted, "
1138 "commands ignored until end of transaction block"),
1151 if (use_implicit_block)
1163 snapshot_set =
true;
1178 if (
lnext(parsetree_list, parsetree_item) != NULL)
1180 per_parsetree_context =
1182 "per-parsetree message context",
1285 if (
lnext(parsetree_list, parsetree_item) == NULL)
1296 if (use_implicit_block)
1340 if (per_parsetree_context)
1354 if (!parsetree_list)
1364 (
errmsg(
"duration: %s ms", msec_str),
1369 (
errmsg(
"duration: %s ms statement: %s",
1370 msec_str, query_string),
1376 if (save_log_statement_stats)
1379 TRACE_POSTGRESQL_QUERY_DONE(query_string);
1391 const char *stmt_name,
1397 List *parsetree_list;
1399 List *querytree_list;
1414 if (save_log_statement_stats)
1419 *stmt_name ? stmt_name :
"<unnamed>",
1443 is_named = (stmt_name[0] !=
'\0');
1454 unnamed_stmt_context =
1456 "unnamed prepared statement",
1474 (
errcode(ERRCODE_SYNTAX_ERROR),
1475 errmsg(
"cannot insert multiple commands into a prepared statement")));
1477 if (parsetree_list !=
NIL)
1479 bool snapshot_set =
false;
1494 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
1495 errmsg(
"current transaction is aborted, "
1496 "commands ignored until end of transaction block"),
1512 snapshot_set =
true;
1533 raw_parse_tree = NULL;
1536 querytree_list =
NIL;
1545 if (unnamed_stmt_context)
1551 unnamed_stmt_context,
1600 (
errmsg(
"duration: %s ms", msec_str),
1605 (
errmsg(
"duration: %s ms parse %s: %s",
1607 *stmt_name ? stmt_name :
"<unnamed>",
1613 if (save_log_statement_stats)
1627 const char *portal_name;
1628 const char *stmt_name;
1630 int16 *pformats = NULL;
1633 int16 *rformats = NULL;
1638 char *saved_stmt_name;
1642 bool snapshot_set =
false;
1654 *portal_name ? portal_name :
"<unnamed>",
1655 *stmt_name ? stmt_name :
"<unnamed>")));
1658 if (stmt_name[0] !=
'\0')
1671 (
errcode(ERRCODE_UNDEFINED_PSTATEMENT),
1672 errmsg(
"unnamed prepared statement does not exist")));
1695 if (save_log_statement_stats)
1711 if (numPFormats > 0)
1714 for (
int i = 0;
i < numPFormats;
i++)
1721 if (numPFormats > 1 && numPFormats != numParams)
1723 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
1724 errmsg(
"bind message has %d parameter formats but %d parameters",
1725 numPFormats, numParams)));
1729 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
1730 errmsg(
"bind message supplies %d parameters, but prepared statement \"%s\" requires %d",
1746 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
1747 errmsg(
"current transaction is aborted, "
1748 "commands ignored until end of transaction block"),
1755 if (portal_name[0] ==
'\0')
1773 saved_stmt_name =
pstrdup(stmt_name);
1775 saved_stmt_name = NULL;
1784 if (numParams > 0 ||
1789 snapshot_set =
true;
1797 char **knownTextValues = NULL;
1809 params_errcxt.
arg = &one_param_data;
1814 for (
int paramno = 0; paramno < numParams; paramno++)
1824 one_param_data.
paramno = paramno;
1828 isNull = (plength == -1);
1842 csave = pvalue[plength];
1843 pvalue[plength] =
'\0';
1852 if (numPFormats > 1)
1853 pformat = pformats[paramno];
1854 else if (numPFormats > 0)
1855 pformat = pformats[0];
1896 if (knownTextValues == NULL)
1900 knownTextValues[paramno] =
pstrdup(pstring);
1910 knownTextValues[paramno] =
1918 if (pstring != pbuf.
data)
1922 else if (pformat == 1)
1943 (
errcode(ERRCODE_INVALID_BINARY_REPRESENTATION),
1944 errmsg(
"incorrect binary data format in bind parameter %d",
1950 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
1951 errmsg(
"unsupported format code: %d",
1958 pbuf.
data[plength] = csave;
1996 params_data.
params = params;
1999 params_errcxt.
arg = ¶ms_data;
2004 if (numRFormats > 0)
2007 for (
int i = 0;
i < numRFormats;
i++)
2035 foreach(lc, portal->
stmts)
2079 (
errmsg(
"duration: %s ms", msec_str),
2084 (
errmsg(
"duration: %s ms bind %s%s%s: %s",
2086 *stmt_name ? stmt_name :
"<unnamed>",
2087 *portal_name ?
"/" :
"",
2088 *portal_name ? portal_name :
"",
2095 if (save_log_statement_stats)
2116 const char *sourceText;
2117 const char *prepStmtName;
2120 bool is_xact_command;
2121 bool execute_is_fetch;
2122 bool was_logged =
false;
2126 const char *cmdtagname;
2138 (
errcode(ERRCODE_UNDEFINED_CURSOR),
2139 errmsg(
"portal \"%s\" does not exist", portal_name)));
2165 prepStmtName =
"<unnamed>";
2175 foreach(lc, portal->
stmts)
2186 foreach(lc, portal->
stmts)
2201 if (save_log_statement_stats)
2226 execute_is_fetch = !portal->
atStart;
2234 _(
"execute fetch from") :
2237 *portal_name ?
"/" :
"",
2238 *portal_name ? portal_name :
"",
2252 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
2253 errmsg(
"current transaction is aborted, "
2254 "commands ignored until end of transaction block"),
2265 params_data.
params = portalParams;
2268 params_errcxt.
arg = ¶ms_data;
2305 portalParams = NULL;
2351 (
errmsg(
"duration: %s ms", msec_str),
2356 (
errmsg(
"duration: %s ms %s %s%s%s: %s",
2359 _(
"execute fetch from") :
2362 *portal_name ?
"/" :
"",
2363 *portal_name ? portal_name :
"",
2370 if (save_log_statement_stats)
2371 ShowUsage(
"EXECUTE MESSAGE STATISTICS");
2396 foreach(stmt_item, stmt_list)
2433 bool exceeded_duration;
2434 bool exceeded_sample_duration;
2435 bool in_sample =
false;
2440 msecs = usecs / 1000;
2462 if (exceeded_sample_duration)
2470 secs * 1000 + msecs, usecs % 1000);
2471 if ((exceeded_duration || in_sample ||
xact_is_sampled) && !was_logged)
2492 foreach(parsetree_item, raw_parsetree_list)
2504 errdetail(
"prepare: %s", pstmt->plansource->query_string);
2528 if (
str &&
str[0] !=
'\0')
2544 errdetail(
"Abort reason: recovery conflict");
2560 errdetail(
"User was holding shared buffer pin for too long.");
2563 errdetail(
"User was holding a relation lock for too long.");
2566 errdetail(
"User was or might have been using tablespace that must be dropped.");
2569 errdetail(
"User query might have needed to see row versions that must be removed.");
2572 errdetail(
"User was using a logical replication slot that must be invalidated.");
2575 errdetail(
"User transaction caused buffer deadlock with recovery.");
2578 errdetail(
"User was connected to a database that must be dropped.");
2600 if (
data->paramno < 0)
2609 quotedval =
buf.data;
2614 if (
data->portalName &&
data->portalName[0] !=
'\0')
2617 errcontext(
"portal \"%s\" parameter $%d = %s",
2618 data->portalName,
data->paramno + 1, quotedval);
2621 data->portalName,
data->paramno + 1);
2626 errcontext(
"unnamed portal parameter $%d = %s",
2627 data->paramno + 1, quotedval);
2657 if (stmt_name[0] !=
'\0')
2670 (
errcode(ERRCODE_UNDEFINED_PSTATEMENT),
2671 errmsg(
"unnamed prepared statement does not exist")));
2689 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
2690 errmsg(
"current transaction is aborted, "
2691 "commands ignored until end of transaction block"),
2752 (
errcode(ERRCODE_UNDEFINED_CURSOR),
2753 errmsg(
"portal \"%s\" does not exist", portal_name)));
2766 (
errcode(ERRCODE_IN_FAILED_SQL_TRANSACTION),
2767 errmsg(
"current transaction is aborted, "
2768 "commands ignored until end of transaction block"),
2836#ifdef MEMORY_CONTEXT_CHECKING
2842#ifdef SHOW_MEMORY_STATS
2934 sigprocmask(SIG_SETMASK, &
BlockSig, NULL);
2983 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
2984 errmsg(
"terminating connection because of unexpected SIGQUIT signal")));
2989 (
errcode(ERRCODE_CRASH_SHUTDOWN),
2990 errmsg(
"terminating connection because of crash of another server process"),
2991 errdetail(
"The postmaster has commanded this server process to roll back"
2992 " the current transaction and exit, because another"
2993 " server process exited abnormally and possibly corrupted"
2995 errhint(
"In a moment you should be able to reconnect to the"
2996 " database and repeat your command.")));
3001 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3002 errmsg(
"terminating connection due to immediate shutdown command")));
3079 (
errcode(ERRCODE_FLOATING_POINT_EXCEPTION),
3080 errmsg(
"floating-point exception"),
3081 errdetail(
"An invalid floating-point operation was signaled. "
3082 "This probably means an out-of-range result or an "
3083 "invalid operation, such as division by zero.")));
3225 errmsg(
"canceling statement due to conflict with recovery"),
3244 ERRCODE_DATABASE_DROPPED :
3246 errmsg(
"terminating connection due to conflict with recovery"),
3248 errhint(
"In a moment you should be able to reconnect to the"
3249 " database and repeat your command.")));
3253 elog(
FATAL,
"unrecognized conflict mode: %d", (
int) reason);
3317 (
errcode(ERRCODE_QUERY_CANCELED),
3318 errmsg(
"canceling authentication due to timeout")));
3321 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3322 errmsg(
"terminating autovacuum process due to administrator command")));
3325 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3326 errmsg(
"terminating logical replication worker due to administrator command")));
3340 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3341 errmsg(
"terminating walreceiver process due to administrator command")));
3344 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3345 errmsg(
"terminating background worker \"%s\" due to administrator command",
3350 (
errmsg_internal(
"io worker shutting down due to administrator command")));
3356 (
errcode(ERRCODE_ADMIN_SHUTDOWN),
3357 errmsg(
"terminating connection due to administrator command")));
3387 (
errcode(ERRCODE_CONNECTION_FAILURE),
3388 errmsg(
"connection to client lost")));
3413 bool lock_timeout_occurred;
3414 bool stmt_timeout_occurred;
3431 if (lock_timeout_occurred && stmt_timeout_occurred &&
3433 lock_timeout_occurred =
false;
3435 if (lock_timeout_occurred)
3439 (
errcode(ERRCODE_LOCK_NOT_AVAILABLE),
3440 errmsg(
"canceling statement due to lock timeout")));
3442 if (stmt_timeout_occurred)
3446 (
errcode(ERRCODE_QUERY_CANCELED),
3447 errmsg(
"canceling statement due to statement timeout")));
3453 (
errcode(ERRCODE_QUERY_CANCELED),
3454 errmsg(
"canceling autovacuum task")));
3466 (
errcode(ERRCODE_QUERY_CANCELED),
3467 errmsg(
"canceling statement due to user request")));
3487 (
errcode(ERRCODE_IDLE_IN_TRANSACTION_SESSION_TIMEOUT),
3488 errmsg(
"terminating connection due to idle-in-transaction timeout")));
3500 (
errcode(ERRCODE_TRANSACTION_TIMEOUT),
3501 errmsg(
"terminating connection due to transaction timeout")));
3513 (
errcode(ERRCODE_IDLE_SESSION_TIMEOUT),
3514 errmsg(
"terminating connection due to idle-session timeout")));
3553 GUC_check_errdetail(
"\"client_connection_check_interval\" must be set to 0 on this platform.");
3590 "\"log_parser_stats\", \"log_planner_stats\", "
3591 "or \"log_executor_stats\" is true.");
3637 foreach(l, elemlist)
3639 char *tok = (
char *)
lfirst(l);
3661 *((
int *) *extra) = flags;
3672 int *flags = (
int *) extra;
3690 sprintf(debugstr,
"debug%d", debug_flag);
3701 if (debug_flag >= 2)
3703 if (debug_flag >= 3)
3705 if (debug_flag >= 4)
3707 if (debug_flag >= 5)
3715 const char *tmp = NULL;
3720 tmp =
"enable_seqscan";
3723 tmp =
"enable_indexscan";
3726 tmp =
"enable_indexonlyscan";
3729 tmp =
"enable_bitmapscan";
3732 tmp =
"enable_tidscan";
3735 tmp =
"enable_nestloop";
3738 tmp =
"enable_mergejoin";
3741 tmp =
"enable_hashjoin";
3761 return "log_parser_stats";
3762 else if (
optarg[1] ==
'l')
3763 return "log_planner_stats";
3767 return "log_executor_stats";
3808 if (argc > 1 && strcmp(argv[1],
"--single") == 0)
3819#ifdef HAVE_INT_OPTERR
3834 while ((
flag =
getopt(argc, argv,
"B:bC:c:D:d:EeFf:h:ijk:lN:nOPp:r:S:sTt:v:W:-:")) != -1)
3862 (
errcode(ERRCODE_SYNTAX_ERROR),
3876 (
errcode(ERRCODE_SYNTAX_ERROR),
3877 errmsg(
"--%s requires a value",
3881 (
errcode(ERRCODE_SYNTAX_ERROR),
3882 errmsg(
"-c %s requires a value",
4020 if (errs || argc !=
optind)
4028 errcode(ERRCODE_SYNTAX_ERROR),
4029 errmsg(
"invalid command-line argument for server process: %s", argv[
optind]),
4033 errcode(ERRCODE_SYNTAX_ERROR),
4034 errmsg(
"%s: invalid command-line argument: %s",
4044#ifdef HAVE_INT_OPTRESET
4063 const char *
dbname = NULL;
4086 (
errcode(ERRCODE_INVALID_PARAMETER_VALUE),
4087 errmsg(
"%s: no database nor user name specified",
4191 sigjmp_buf local_sigjmp_buf;
4194 volatile bool send_ready_for_query =
true;
4195 volatile bool idle_in_transaction_timeout_enabled =
false;
4196 volatile bool idle_session_timeout_enabled =
false;
4279 (
errcode(ERRCODE_INTERNAL_ERROR),
4280 errmsg(
"could not generate random cancel key")));
4348 printf(
"\nPostgreSQL stand-alone backend %s\n", PG_VERSION);
4367 "RowDescriptionContext",
4398 if (sigsetjmp(local_sigjmp_buf, 1) != 0)
4427 idle_in_transaction_timeout_enabled =
false;
4428 idle_session_timeout_enabled =
false;
4504 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
4505 errmsg(
"terminating connection because protocol synchronization was lost")));
4515 send_ready_for_query =
true;
4536 old_valgrind_error_count = VALGRIND_COUNT_ERRORS;
4570 if (send_ready_for_query)
4581 idle_in_transaction_timeout_enabled =
true;
4595 idle_in_transaction_timeout_enabled =
true;
4628 if (stats_timeout > 0)
4647 idle_session_timeout_enabled =
true;
4682 errmsg(
"connection ready: setup total=%.3f ms, fork=%.3f ms, authentication=%.3f ms",
4689 send_ready_for_query =
false;
4713 if (idle_in_transaction_timeout_enabled)
4716 idle_in_transaction_timeout_enabled =
false;
4718 if (idle_session_timeout_enabled)
4721 idle_session_timeout_enabled =
false;
4757 const char *query_string;
4775 send_ready_for_query =
true;
4781 const char *stmt_name;
4782 const char *query_string;
4784 Oid *paramTypes = NULL;
4797 for (
int i = 0;
i < numParams;
i++)
4803 paramTypes, numParams);
4826 const char *portal_name;
4876 send_ready_for_query =
true;
4882 const char *close_target;
4893 if (close_target[0] !=
'\0')
4912 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
4913 errmsg(
"invalid CLOSE message subtype %d",
4928 const char *describe_target;
4939 switch (describe_type)
4949 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
4950 errmsg(
"invalid DESCRIBE message subtype %d",
4976 send_ready_for_query =
true;
5022 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
5023 errmsg(
"invalid frontend message type %d",
5043 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
5044 errmsg(
"fastpath function calls not supported in a replication connection")));
5047 (
errcode(ERRCODE_PROTOCOL_VIOLATION),
5048 errmsg(
"extended query protocol not supported in a replication connection")));
5067 struct timeval
user,
5069 struct timeval elapse_t;
5075 memcpy(&sys, &r.
ru_stime,
sizeof(sys));
5076 if (elapse_t.tv_usec <
Save_t.tv_usec)
5079 elapse_t.tv_usec += 1000000;
5100 "!\t%ld.%06ld s user, %ld.%06ld s system, %ld.%06ld s elapsed\n",
5105 (
long) (elapse_t.tv_sec -
Save_t.tv_sec),
5106 (
long) (elapse_t.tv_usec -
Save_t.tv_usec));
5108 "!\t[%ld.%06ld s user, %ld.%06ld s system total]\n",
5110 (
long)
user.tv_usec,
5112 (
long) sys.tv_usec);
5122 "!\t%ld kB max resident size\n",
5132 "!\t%ld/%ld [%ld/%ld] filesystem blocks in/out\n",
5133 r.ru_inblock -
Save_r.ru_inblock,
5135 r.ru_oublock -
Save_r.ru_oublock,
5136 r.ru_inblock, r.ru_oublock);
5138 "!\t%ld/%ld [%ld/%ld] page faults/reclaims, %ld [%ld] swaps\n",
5139 r.ru_majflt -
Save_r.ru_majflt,
5140 r.ru_minflt -
Save_r.ru_minflt,
5141 r.ru_majflt, r.ru_minflt,
5142 r.ru_nswap -
Save_r.ru_nswap,
5145 "!\t%ld [%ld] signals rcvd, %ld/%ld [%ld/%ld] messages rcvd/sent\n",
5146 r.ru_nsignals -
Save_r.ru_nsignals,
5148 r.ru_msgrcv -
Save_r.ru_msgrcv,
5149 r.ru_msgsnd -
Save_r.ru_msgsnd,
5150 r.ru_msgrcv, r.ru_msgsnd);
5152 "!\t%ld/%ld [%ld/%ld] voluntary/involuntary context switches\n",
5153 r.ru_nvcsw -
Save_r.ru_nvcsw,
5154 r.ru_nivcsw -
Save_r.ru_nivcsw,
5155 r.ru_nvcsw, r.ru_nivcsw);
5159 if (
str.data[
str.len - 1] ==
'\n')
5160 str.data[--
str.len] =
'\0';
5186 msecs = usecs / 1000;
5194 (
errmsg(
"disconnection: session time: %d:%02d:%02d.%03d "
5195 "user=%s database=%s host=%s%s%s",
5196 hours, minutes, seconds, msecs,
5197 port->user_name,
port->database_name,
port->remote_host,
5198 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_plan_id(uint64 plan_id, bool force)
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
char MyCancelKey[MAX_CANCEL_KEY_LENGTH]
volatile uint32 CritSectionCount
volatile sig_atomic_t QueryCancelPending
TimestampTz MyStartTimestamp
volatile sig_atomic_t PublishMemoryContextPending
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)
void ProcessGetMemoryContextInterrupt(void)
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 AmWalReceiverProcess()
#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)
#define PG_PROTOCOL(m, n)
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 MAX_CANCEL_KEY_LENGTH
#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)