65 #ifdef HAVE_EXECINFO_H
89 #define _(x) err_gettext(x)
125 #ifndef PG_SYSLOG_LIMIT
126 #define PG_SYSLOG_LIMIT 900
129 static bool openlog_done =
false;
130 static char *syslog_ident = NULL;
133 static void write_syslog(
int level,
const char *line);
139 static void write_eventlog(
int level,
const char *line,
int len);
143 #define ERRORDATA_STACK_SIZE 5
158 #define FORMATTED_TS_LEN 128
164 #define CHECK_STACK_DEPTH() \
166 if (errordata_stack_depth < 0) \
168 errordata_stack_depth = -1; \
169 ereport(ERROR, (errmsg_internal("errstart was not called"))); \
198 if (log_min_level ==
LOG || log_min_level <=
ERROR)
206 else if (log_min_level ==
LOG)
213 else if (elevel >= log_min_level)
248 return (elevel >=
ERROR);
270 if (elevel >=
ERROR ||
297 static inline const char *
338 bool output_to_server;
339 bool output_to_client =
false;
394 if (elevel <
ERROR && !output_to_server && !output_to_client)
404 write_stderr(
"error occurred before error message processing is available\n");
460 edata->
sqlerrcode = ERRCODE_SUCCESSFUL_COMPLETION;
491 if (strcmp(funcname, p) == 0)
731 edata->
sqlerrcode = ERRCODE_INSUFFICIENT_PRIVILEGE;
747 #if defined(ENOTEMPTY) && (ENOTEMPTY != EEXIST)
750 edata->
sqlerrcode = ERRCODE_WRONG_OBJECT_TYPE;
760 edata->
sqlerrcode = ERRCODE_INSUFFICIENT_RESOURCES;
798 edata->
sqlerrcode = ERRCODE_CONNECTION_FAILURE;
823 #define EVALUATE_MESSAGE(domain, targetfield, appendval, translateit) \
825 StringInfoData buf; \
827 if ((translateit) && !in_error_recursion_trouble()) \
828 fmt = dgettext((domain), fmt); \
829 initStringInfo(&buf); \
830 if ((appendval) && edata->targetfield) { \
831 appendStringInfoString(&buf, edata->targetfield); \
832 appendStringInfoChar(&buf, '\n'); \
839 errno = edata->saved_errno; \
840 va_start(args, fmt); \
841 needed = appendStringInfoVA(&buf, fmt, args); \
845 enlargeStringInfo(&buf, needed); \
848 if (edata->targetfield) \
849 pfree(edata->targetfield); \
850 edata->targetfield = pstrdup(buf.data); \
859 #define EVALUATE_MESSAGE_PLURAL(domain, targetfield, appendval) \
862 StringInfoData buf; \
864 if (!in_error_recursion_trouble()) \
865 fmt = dngettext((domain), fmt_singular, fmt_plural, n); \
867 fmt = (n == 1 ? fmt_singular : fmt_plural); \
868 initStringInfo(&buf); \
869 if ((appendval) && edata->targetfield) { \
870 appendStringInfoString(&buf, edata->targetfield); \
871 appendStringInfoChar(&buf, '\n'); \
878 errno = edata->saved_errno; \
880 needed = appendStringInfoVA(&buf, fmt, args); \
884 enlargeStringInfo(&buf, needed); \
887 if (edata->targetfield) \
888 pfree(edata->targetfield); \
889 edata->targetfield = pstrdup(buf.data); \
956 #ifdef HAVE_BACKTRACE_SYMBOLS
963 strfrms = backtrace_symbols(
buf, nframes);
967 for (
int i = num_skip;
i < nframes;
i++)
973 "backtrace generation is not supported by this installation");
1015 unsigned long n,...)
1107 unsigned long n,...)
1130 unsigned long n,...)
1174 unsigned long n,...)
1371 elog(
ERROR,
"unsupported ErrorData field id: %d", field);
1533 (*emit_log_hook) (edata);
1570 memcpy(newedata, edata,
sizeof(
ErrorData));
1755 memcpy(newedata, edata,
sizeof(
ErrorData));
1834 __FILE__, __LINE__);
1943 errmsg(
"could not reopen file \"%s\" as stderr: %m",
1956 errmsg(
"could not reopen file \"%s\" as stdout: %m",
1968 set_syslog_parameters(
const char *ident,
int facility)
1980 if (syslog_ident == NULL || strcmp(syslog_ident, ident) != 0 ||
1986 openlog_done =
false;
1989 syslog_ident = strdup(ident);
2000 write_syslog(
int level,
const char *line)
2002 static unsigned long seq = 0;
2010 openlog(syslog_ident ? syslog_ident :
"postgres",
2011 LOG_PID | LOG_NDELAY | LOG_NOWAIT,
2013 openlog_done =
true;
2031 nlpos = strchr(line,
'\n');
2038 char buf[PG_SYSLOG_LIMIT + 1];
2043 if (line[0] ==
'\n')
2048 nlpos = strchr(line,
'\n');
2054 buflen = nlpos - line;
2057 buflen =
Min(buflen, PG_SYSLOG_LIMIT);
2058 memcpy(
buf, line, buflen);
2068 if (line[buflen] !=
'\0' &&
2069 !isspace((
unsigned char) line[buflen]))
2073 while (
i > 0 && !isspace((
unsigned char)
buf[
i]))
2086 syslog(level,
"[%lu-%d] %s", seq, chunk_nr,
buf);
2088 syslog(level,
"[%d] %s", chunk_nr,
buf);
2098 syslog(level,
"[%lu] %s", seq, line);
2100 syslog(level,
"%s", line);
2112 GetACPEncoding(
void)
2117 encoding = pg_codepage_to_encoding(GetACP());
2126 write_eventlog(
int level,
const char *line,
int len)
2129 int eventlevel = EVENTLOG_ERROR_TYPE;
2130 static HANDLE evtHandle = INVALID_HANDLE_VALUE;
2132 if (evtHandle == INVALID_HANDLE_VALUE)
2134 evtHandle = RegisterEventSource(NULL,
2136 if (evtHandle == NULL)
2138 evtHandle = INVALID_HANDLE_VALUE;
2154 eventlevel = EVENTLOG_INFORMATION_TYPE;
2158 eventlevel = EVENTLOG_WARNING_TYPE;
2164 eventlevel = EVENTLOG_ERROR_TYPE;
2185 utf16 = pgwin32_message_to_UTF16(line,
len, NULL);
2188 ReportEventW(evtHandle,
2203 ReportEventA(evtHandle,
2246 utf16 = pgwin32_message_to_UTF16(line,
len, &utf16len);
2252 stdHandle = GetStdHandle(STD_ERROR_HANDLE);
2253 if (WriteConsoleW(stdHandle, utf16, utf16len, &written, NULL))
2281 rc =
write(fileno(stderr), line,
len);
2318 "%Y-%m-%d %H:%M:%S %Z",
2358 "%Y-%m-%d %H:%M:%S %Z",
2393 const char *backend_type_str;
2396 backend_type_str =
"postmaster";
2402 return backend_type_str;
2415 int paddingsign = 1;
2428 while (*p >=
'0' && *p <=
'9')
2429 padding = padding * 10 + (*p++ -
'0');
2435 padding *= paddingsign;
2436 *ppadding = padding;
2447 static long log_line_number = 0;
2450 static int log_my_pid = 0;
2462 log_line_number = 0;
2519 if (appname == NULL || *appname ==
'\0')
2520 appname =
_(
"[unknown]");
2526 else if (padding != 0)
2528 padding > 0 ? padding : -padding);
2553 else if (padding != 0)
2555 padding > 0 ? padding : -padding);
2569 else if (padding != 0)
2571 padding > 0 ? padding : -padding);
2578 snprintf(strfbuf,
sizeof(strfbuf) - 1,
"%lx.%x",
2603 padding > 0 ? padding : -padding);
2604 else if (padding != 0)
2609 else if (padding != 0)
2611 padding > 0 ? padding : -padding);
2636 "%Y-%m-%d %H:%M:%S %Z",
2654 snprintf(strfbuf,
sizeof(strfbuf),
"%ld.%03d",
2686 else if (padding != 0)
2688 padding > 0 ? padding : -padding);
2724 else if (padding != 0)
2726 padding > 0 ? padding : -padding);
2736 else if (padding != 0)
2738 padding > 0 ? padding : -padding);
2754 snprintf(strfbuf,
sizeof(strfbuf) - 1,
"%d/%u",
2761 else if (padding != 0)
2763 padding > 0 ? padding : -padding);
2799 static char buf[12];
2802 for (
i = 0;
i < 5;
i++)
2820 bool fallback_to_stderr =
false;
2934 syslog_level = LOG_DEBUG;
2939 syslog_level = LOG_INFO;
2944 syslog_level = LOG_NOTICE;
2947 syslog_level = LOG_WARNING;
2950 syslog_level = LOG_ERR;
2954 syslog_level = LOG_CRIT;
2958 write_syslog(syslog_level,
buf.data);
2981 fallback_to_stderr =
true;
2997 fallback_to_stderr =
true;
3063 int fd = fileno(stderr);
3354 while ((ch = *
str++) !=
'\0')
3393 write_eventlog(
ERROR, errbuf, strlen(errbuf));
3424 if (trace_level <
LOG &&
void ExceptionalCondition(const char *conditionName, const char *errorType, 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)
elog(ERROR, "%s: %s", p2, msg)
int getinternalerrposition(void)
static bool should_output_to_client(int elevel)
int errcode_for_socket_access(void)
static void log_line_prefix(StringInfo buf, ErrorData *edata)
int err_generic_string(int field, const char *str)
int errmsg_plural(const char *fmt_singular, const char *fmt_plural, unsigned long n,...)
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)
static const char * process_log_prefix_padding(const char *p, int *padding)
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 int errordata_stack_depth
static void err_sendstring(StringInfo buf, const char *str)
void FreeErrorData(ErrorData *edata)
int errdetail_internal(const char *fmt,...)
static bool saved_timeval_set
int errcode_for_file_access(void)
int errdetail(const char *fmt,...)
const char * error_severity(int elevel)
int errcontext_msg(const char *fmt,...)
static int save_format_errnumber
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)
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)
pg_attribute_cold bool errstart_cold(int elevel, const char *domain)
#define CHECK_STACK_DEPTH()
#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,...)
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]
int trace_recovery(int trace_level)
sigjmp_buf * PG_exception_stack
static const char * save_format_domain
ErrorData * CopyErrorData(void)
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
int gettimeofday(struct timeval *tp, struct timezone *tzp)
volatile uint32 QueryCancelHoldoffCount
ProtocolVersion FrontendProtocol
volatile uint32 InterruptHoldoffCount
volatile uint32 CritSectionCount
char OutputFileName[MAXPGPATH]
int log_min_error_statement
static int syslog_facility
int trace_recovery_messages
char * backtrace_symbol_list
char * backtrace_functions
bool proc_exit_inprogress
void write_jsonlog(ErrorData *edata)
static void const char fflush(stdout)
vfprintf(stderr, fmt, args)
Assert(fmt[strlen(fmt) - 1] !='\n')
static void const char * fmt
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 MemoryContextResetAndDeleteChildren(ctx)
#define CHECK_FOR_INTERRUPTS()
const char * GetBackendTypeDesc(BackendType backendType)
BackendType MyBackendType
static MemoryContext MemoryContextSwitchTo(MemoryContext context)
#define DEFAULT_EVENT_SOURCE
SessionEndType pgStatSessionEndCause
size_t pg_strftime(char *s, size_t max, const char *format, const struct pg_tm *tm)
struct pg_tm * pg_localtime(const pg_time_t *timep, const pg_tz *tz)
PGDLLIMPORT pg_tz * log_timezone
#define ALL_CONNECTION_FAILURE_ERRNOS
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)
const char * get_ps_display(int *displen)
char * psprintf(const char *fmt,...)
void appendStringInfo(StringInfo str, const char *fmt,...)
void appendBinaryStringInfo(StringInfo str, const char *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
int pgwin32_is_service(void)
TransactionId GetTopTransactionIdIfAny(void)