65 #ifdef HAVE_EXECINFO_H
90 #define _(x) err_gettext(x)
129 #ifndef PG_SYSLOG_LIMIT
130 #define PG_SYSLOG_LIMIT 900
133 static bool openlog_done =
false;
134 static char *syslog_ident = NULL;
137 static void write_syslog(
int level,
const char *line);
143 static void write_eventlog(
int level,
const char *line,
int len);
147 #define ERRORDATA_STACK_SIZE 5
162 #define FORMATTED_TS_LEN 128
168 #define CHECK_STACK_DEPTH() \
170 if (errordata_stack_depth < 0) \
172 errordata_stack_depth = -1; \
173 ereport(ERROR, (errmsg_internal("errstart was not called"))); \
209 if (log_min_level ==
LOG || log_min_level <=
ERROR)
217 else if (log_min_level ==
LOG)
224 else if (elevel >= log_min_level)
259 return (elevel >=
ERROR);
281 if (elevel >=
ERROR ||
308 static inline const char *
349 bool output_to_server;
350 bool output_to_client =
false;
405 if (elevel <
ERROR && !output_to_server && !output_to_client)
415 write_stderr(
"error occurred before error message processing is available\n");
457 edata->
sqlerrcode = ERRCODE_SUCCESSFUL_COMPLETION;
503 (edata->
sqlerrcode == ERRCODE_INTERNAL_ERROR &&
897 edata->
sqlerrcode = ERRCODE_INSUFFICIENT_PRIVILEGE;
914 edata->
sqlerrcode = ERRCODE_WRONG_OBJECT_TYPE;
928 edata->
sqlerrcode = ERRCODE_INSUFFICIENT_RESOURCES;
966 edata->
sqlerrcode = ERRCODE_CONNECTION_FAILURE;
991 #define EVALUATE_MESSAGE(domain, targetfield, appendval, translateit) \
993 StringInfoData buf; \
995 if ((translateit) && !in_error_recursion_trouble()) \
996 fmt = dgettext((domain), fmt); \
997 initStringInfo(&buf); \
998 if ((appendval) && edata->targetfield) { \
999 appendStringInfoString(&buf, edata->targetfield); \
1000 appendStringInfoChar(&buf, '\n'); \
1007 errno = edata->saved_errno; \
1008 va_start(args, fmt); \
1009 needed = appendStringInfoVA(&buf, fmt, args); \
1013 enlargeStringInfo(&buf, needed); \
1016 if (edata->targetfield) \
1017 pfree(edata->targetfield); \
1018 edata->targetfield = pstrdup(buf.data); \
1027 #define EVALUATE_MESSAGE_PLURAL(domain, targetfield, appendval) \
1030 StringInfoData buf; \
1032 if (!in_error_recursion_trouble()) \
1033 fmt = dngettext((domain), fmt_singular, fmt_plural, n); \
1035 fmt = (n == 1 ? fmt_singular : fmt_plural); \
1036 initStringInfo(&buf); \
1037 if ((appendval) && edata->targetfield) { \
1038 appendStringInfoString(&buf, edata->targetfield); \
1039 appendStringInfoChar(&buf, '\n'); \
1046 errno = edata->saved_errno; \
1047 va_start(args, n); \
1048 needed = appendStringInfoVA(&buf, fmt, args); \
1052 enlargeStringInfo(&buf, needed); \
1055 if (edata->targetfield) \
1056 pfree(edata->targetfield); \
1057 edata->targetfield = pstrdup(buf.data); \
1124 #ifdef HAVE_BACKTRACE_SYMBOLS
1131 strfrms = backtrace_symbols(
buf, nframes);
1132 if (strfrms == NULL)
1135 for (
int i = num_skip;
i < nframes;
i++)
1141 "backtrace generation is not supported by this installation");
1183 unsigned long n,...)
1275 unsigned long n,...)
1298 unsigned long n,...)
1342 unsigned long n,...)
1539 elog(
ERROR,
"unsupported ErrorData field id: %d", field);
1701 (*emit_log_hook) (edata);
1738 memcpy(newedata, edata,
sizeof(
ErrorData));
1923 memcpy(newedata, edata,
sizeof(
ErrorData));
2095 errmsg(
"could not reopen file \"%s\" as stderr: %m",
2108 errmsg(
"could not reopen file \"%s\" as stdout: %m",
2127 int newvallen = strlen(*
newval);
2137 validlen = strspn(*
newval,
2139 "abcdefghijklmnopqrstuvwxyz"
2140 "ABCDEFGHIJKLMNOPQRSTUVWXYZ"
2142 if (validlen != newvallen)
2160 for (
i = 0,
j = 0;
i < newvallen;
i++)
2163 someval[
j++] =
'\0';
2164 else if ((*
newval)[
i] ==
' ' ||
2169 someval[
j++] = (*newval)[
i];
2174 someval[
j + 1] =
'\0';
2214 foreach(l, elemlist)
2216 char *tok = (
char *)
lfirst(l);
2245 *myextra = newlogdest;
2246 *extra = (
void *) myextra;
2277 if (syslog_ident == NULL || strcmp(syslog_ident,
newval) != 0)
2282 openlog_done =
false;
2285 syslog_ident = strdup(
newval);
2307 openlog_done =
false;
2321 write_syslog(
int level,
const char *line)
2323 static unsigned long seq = 0;
2331 openlog(syslog_ident ? syslog_ident :
"postgres",
2332 LOG_PID | LOG_NDELAY | LOG_NOWAIT,
2334 openlog_done =
true;
2352 nlpos = strchr(line,
'\n');
2359 char buf[PG_SYSLOG_LIMIT + 1];
2364 if (line[0] ==
'\n')
2369 nlpos = strchr(line,
'\n');
2375 buflen = nlpos - line;
2378 buflen =
Min(buflen, PG_SYSLOG_LIMIT);
2379 memcpy(
buf, line, buflen);
2389 if (line[buflen] !=
'\0' &&
2390 !isspace((
unsigned char) line[buflen]))
2394 while (
i > 0 && !isspace((
unsigned char)
buf[
i]))
2407 syslog(level,
"[%lu-%d] %s", seq, chunk_nr,
buf);
2409 syslog(level,
"[%d] %s", chunk_nr,
buf);
2419 syslog(level,
"[%lu] %s", seq, line);
2421 syslog(level,
"%s", line);
2433 GetACPEncoding(
void)
2438 encoding = pg_codepage_to_encoding(GetACP());
2447 write_eventlog(
int level,
const char *line,
int len)
2450 int eventlevel = EVENTLOG_ERROR_TYPE;
2451 static HANDLE evtHandle = INVALID_HANDLE_VALUE;
2453 if (evtHandle == INVALID_HANDLE_VALUE)
2455 evtHandle = RegisterEventSource(NULL,
2457 if (evtHandle == NULL)
2459 evtHandle = INVALID_HANDLE_VALUE;
2475 eventlevel = EVENTLOG_INFORMATION_TYPE;
2479 eventlevel = EVENTLOG_WARNING_TYPE;
2485 eventlevel = EVENTLOG_ERROR_TYPE;
2506 utf16 = pgwin32_message_to_UTF16(line,
len, NULL);
2509 ReportEventW(evtHandle,
2524 ReportEventA(evtHandle,
2567 utf16 = pgwin32_message_to_UTF16(line,
len, &utf16len);
2573 stdHandle = GetStdHandle(STD_ERROR_HANDLE);
2574 if (WriteConsoleW(stdHandle, utf16, utf16len, &written, NULL))
2602 rc =
write(fileno(stderr), line,
len);
2639 "%Y-%m-%d %H:%M:%S %Z",
2679 "%Y-%m-%d %H:%M:%S %Z",
2714 const char *backend_type_str;
2717 backend_type_str =
"postmaster";
2723 return backend_type_str;
2736 int paddingsign = 1;
2749 while (*p >=
'0' && *p <=
'9')
2750 padding = padding * 10 + (*p++ -
'0');
2756 padding *= paddingsign;
2757 *ppadding = padding;
2777 static long log_line_number = 0;
2780 static int log_my_pid = 0;
2792 log_line_number = 0;
2801 for (p =
format; *p !=
'\0'; p++)
2849 if (appname == NULL || *appname ==
'\0')
2850 appname =
_(
"[unknown]");
2856 else if (padding != 0)
2858 padding > 0 ? padding : -padding);
2883 else if (padding != 0)
2885 padding > 0 ? padding : -padding);
2899 else if (padding != 0)
2901 padding > 0 ? padding : -padding);
2908 snprintf(strfbuf,
sizeof(strfbuf) - 1,
"%lx.%x",
2933 padding > 0 ? padding : -padding);
2934 else if (padding != 0)
2939 else if (padding != 0)
2941 padding > 0 ? padding : -padding);
2966 "%Y-%m-%d %H:%M:%S %Z",
2984 snprintf(strfbuf,
sizeof(strfbuf),
"%ld.%03d",
3016 else if (padding != 0)
3018 padding > 0 ? padding : -padding);
3054 else if (padding != 0)
3056 padding > 0 ? padding : -padding);
3066 else if (padding != 0)
3068 padding > 0 ? padding : -padding);
3084 snprintf(strfbuf,
sizeof(strfbuf) - 1,
"%d/%u",
3091 else if (padding != 0)
3093 padding > 0 ? padding : -padding);
3129 static char buf[12];
3132 for (
i = 0;
i < 5;
i++)
3150 bool fallback_to_stderr =
false;
3264 syslog_level = LOG_DEBUG;
3269 syslog_level = LOG_INFO;
3274 syslog_level = LOG_NOTICE;
3277 syslog_level = LOG_WARNING;
3280 syslog_level = LOG_ERR;
3284 syslog_level = LOG_CRIT;
3288 write_syslog(syslog_level,
buf.data);
3311 fallback_to_stderr =
true;
3327 fallback_to_stderr =
true;
3393 int fd = fileno(stderr);
3687 while ((ch = *
str++) !=
'\0')
3726 write_eventlog(
ERROR, errbuf, strlen(errbuf));
void ExceptionalCondition(const char *conditionName, const char *fileName, int lineNumber)
uint64 pgstat_get_my_query_id(void)
#define pg_attribute_format_arg(a)
#define pg_attribute_cold
#define PG_TEXTDOMAIN(domain)
#define MemSet(start, val, len)
void write_csvlog(ErrorData *edata)
void assign_syslog_facility(int newval, void *extra)
int getinternalerrposition(void)
static bool should_output_to_client(int elevel)
void assign_syslog_ident(const char *newval, void *extra)
int errcode_for_socket_access(void)
bool errsave_start(struct Node *context, const char *domain)
static void log_line_prefix(StringInfo buf, ErrorData *edata)
static const char * process_log_prefix_padding(const char *p, int *ppadding)
int err_generic_string(int field, const char *str)
int errmsg_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
void errsave_finish(struct Node *context, const char *filename, int lineno, const char *funcname)
static char formatted_log_time[FORMATTED_TS_LEN]
int internalerrquery(const char *query)
static char formatted_start_time[FORMATTED_TS_LEN]
int internalerrposition(int cursorpos)
static void send_message_to_frontend(ErrorData *edata)
bool check_log_of_query(ErrorData *edata)
int errmsg_internal(const char *fmt,...)
static void append_with_tabs(StringInfo buf, const char *str)
int errhidestmt(bool hide_stmt)
char * get_formatted_log_time(void)
bool errstart(int elevel, const char *domain)
void EmitErrorReport(void)
bool syslog_split_messages
static void FreeErrorDataContents(ErrorData *edata)
static int errordata_stack_depth
static void err_sendstring(StringInfo buf, const char *str)
void FreeErrorData(ErrorData *edata)
void assign_backtrace_functions(const char *newval, void *extra)
static ErrorData * get_error_stack_entry(void)
int errdetail_internal(const char *fmt,...)
static bool saved_timeval_set
int errcode_for_file_access(void)
static char * backtrace_function_list
int errdetail(const char *fmt,...)
const char * error_severity(int elevel)
int errcontext_msg(const char *fmt,...)
static int save_format_errnumber
bool check_backtrace_functions(char **newval, void **extra, GucSource source)
void pre_format_elog_string(int errnumber, const char *domain)
static int recursion_depth
ErrorContextCallback * error_context_stack
static struct timeval saved_timeval
void ReThrowError(ErrorData *edata)
static void set_errdata_field(MemoryContextData *cxt, char **ptr, const char *str)
const char * get_backend_type_for_log(void)
static bool matches_backtrace_functions(const char *funcname)
bool check_log_destination(char **newval, void **extra, GucSource source)
void FlushErrorState(void)
int errdetail_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
char * format_elog_string(const char *fmt,...)
int errhint(const char *fmt,...)
static bool is_log_level_output(int elevel, int log_min_level)
void ThrowErrorData(ErrorData *edata)
bool message_level_is_interesting(int elevel)
void write_pipe_chunks(char *data, int len, int dest)
int errhidecontext(bool hide_ctx)
emit_log_hook_type emit_log_hook
bool syslog_sequence_numbers
static void send_message_to_server_log(ErrorData *edata)
char * Log_destination_string
static void write_console(const char *line, int len)
#define EVALUATE_MESSAGE(domain, targetfield, appendval, translateit)
char * unpack_sql_state(int sql_state)
static void set_stack_entry_location(ErrorData *edata, const char *filename, int lineno, const char *funcname)
pg_attribute_cold bool errstart_cold(int elevel, const char *domain)
#define CHECK_STACK_DEPTH()
static void set_stack_entry_domain(ErrorData *edata, const char *domain)
#define EVALUATE_MESSAGE_PLURAL(domain, targetfield, appendval)
static bool should_output_to_server(int elevel)
int errcode(int sqlerrcode)
int errdetail_log_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
void write_stderr(const char *fmt,...)
int errmsg(const char *fmt,...)
void log_status_format(StringInfo buf, const char *format, ErrorData *edata)
char * GetErrorContextStack(void)
bool in_error_recursion_trouble(void)
void errfinish(const char *filename, int lineno, const char *funcname)
static const char * err_gettext(const char *str) pg_attribute_format_arg(1)
int errposition(int cursorpos)
#define ERRORDATA_STACK_SIZE
int errhint_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
int errdetail_log(const char *fmt,...)
static pg_noinline void set_backtrace(ErrorData *edata, int num_skip)
char * get_formatted_start_time(void)
int set_errcontext_domain(const char *domain)
void reset_formatted_start_time(void)
static ErrorData errordata[ERRORDATA_STACK_SIZE]
sigjmp_buf * PG_exception_stack
static const char * save_format_domain
ErrorData * CopyErrorData(void)
void assign_log_destination(const char *newval, void *extra)
void(* emit_log_hook_type)(ErrorData *edata)
#define WARNING_CLIENT_ONLY
#define LOG_DESTINATION_JSONLOG
#define LOG_DESTINATION_SYSLOG
#define LOG_DESTINATION_STDERR
#define ereport(elevel,...)
#define LOG_DESTINATION_EVENTLOG
#define LOG_DESTINATION_CSVLOG
#define palloc_object(type)
volatile uint32 QueryCancelHoldoffCount
ProtocolVersion FrontendProtocol
volatile uint32 InterruptHoldoffCount
volatile uint32 CritSectionCount
char OutputFileName[MAXPGPATH]
void * guc_malloc(int elevel, size_t size)
#define GUC_check_errdetail
int log_min_error_statement
static int syslog_facility
bool backtrace_on_internal_error
char * backtrace_functions
bool proc_exit_inprogress
void write_jsonlog(ErrorData *edata)
static void const char * fmt
static void const char fflush(stdout)
vfprintf(stderr, fmt, args)
Assert(fmt[strlen(fmt) - 1] !='\n')
void list_free(List *list)
int pg_mbcliplen(const char *mbstr, int len, int limit)
int GetMessageEncoding(void)
void MemoryContextReset(MemoryContext context)
char * pstrdup(const char *in)
void pfree(void *pointer)
MemoryContext CurrentMemoryContext
char * MemoryContextStrdup(MemoryContext context, const char *string)
MemoryContext ErrorContext
#define CHECK_FOR_INTERRUPTS()
const char * GetBackendTypeDesc(BackendType backendType)
BackendType MyBackendType
#define IsA(nodeptr, _type_)
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
#define DEFAULT_EVENT_SOURCE
static rewind_source * source
SessionEndType pgStatSessionEndCause
struct pg_tm * pg_localtime(const pg_time_t *timep, const pg_tz *tz)
size_t pg_strftime(char *s, size_t maxsize, const char *format, const struct pg_tm *t)
PGDLLIMPORT pg_tz * log_timezone
#define ALL_CONNECTION_FAILURE_ERRNOS
int pg_strcasecmp(const char *s1, const char *s2)
CommandDest whereToSendOutput
const char * debug_query_string
#define PG_DIAG_INTERNAL_QUERY
#define PG_DIAG_SCHEMA_NAME
#define PG_DIAG_CONSTRAINT_NAME
#define PG_DIAG_DATATYPE_NAME
#define PG_DIAG_SOURCE_LINE
#define PG_DIAG_STATEMENT_POSITION
#define PG_DIAG_SOURCE_FILE
#define PG_DIAG_MESSAGE_HINT
#define PG_DIAG_SEVERITY_NONLOCALIZED
#define PG_DIAG_TABLE_NAME
#define PG_DIAG_MESSAGE_PRIMARY
#define PG_DIAG_COLUMN_NAME
#define PG_DIAG_MESSAGE_DETAIL
#define PG_DIAG_SOURCE_FUNCTION
#define PG_DIAG_INTERNAL_POSITION
bool ClientAuthInProgress
BackgroundWorker * MyBgworkerEntry
int pq_putmessage_v2(char msgtype, const char *s, size_t len)
#define PG_PROTOCOL_MAJOR(v)
static int fd(const char *x, int i)
#define INVALID_PROC_NUMBER
#define PqMsg_ErrorResponse
#define PqMsg_NoticeResponse
const char * get_ps_display(int *displen)
char * psprintf(const char *fmt,...)
void appendStringInfo(StringInfo str, const char *fmt,...)
void appendBinaryStringInfo(StringInfo str, const void *data, int datalen)
void appendStringInfoSpaces(StringInfo str, int count)
void appendStringInfoString(StringInfo str, const char *s)
void appendStringInfoChar(StringInfo str, char ch)
void initStringInfo(StringInfo str)
#define appendStringInfoCharMacro(str, ch)
char bgw_type[BGW_MAXLEN]
struct ErrorContextCallback * previous
void(* callback)(void *arg)
struct MemoryContextData * assoc_context
const char * context_domain
void write_syslogger_file(const char *buffer, int count, int destination)
#define PIPE_PROTO_DEST_JSONLOG
#define PIPE_PROTO_IS_LAST
#define PIPE_PROTO_DEST_CSVLOG
#define PIPE_PROTO_DEST_STDERR
bool SplitIdentifierString(char *rawstring, char separator, List **namelist)
int pgwin32_is_service(void)
int gettimeofday(struct timeval *tp, void *tzp)
TransactionId GetTopTransactionIdIfAny(void)