PostgreSQL Source Code  git master
pqmq.h File Reference
#include "lib/stringinfo.h"
#include "storage/shm_mq.h"
Include dependency graph for pqmq.h:
This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions

void pq_redirect_to_shm_mq (dsm_segment *seg, shm_mq_handle *mqh)
 
void pq_set_parallel_master (pid_t pid, BackendId backend_id)
 
void pq_parse_errornotice (StringInfo str, ErrorData *edata)
 

Function Documentation

◆ pq_parse_errornotice()

void pq_parse_errornotice ( StringInfo  str,
ErrorData edata 
)

Definition at line 215 of file pqmq.c.

References ErrorData::assoc_context, ErrorData::column_name, ErrorData::constraint_name, ErrorData::context, CurrentMemoryContext, ErrorData::cursorpos, ErrorData::datatype_name, DEBUG1, ErrorData::detail, ErrorData::elevel, elog, ERROR, FATAL, ErrorData::filename, ErrorData::funcname, ErrorData::hint, INFO, ErrorData::internalpos, ErrorData::internalquery, ErrorData::lineno, LOG, MAKE_SQLSTATE, MemSet, ErrorData::message, NOTICE, PANIC, pg_atoi(), PG_DIAG_COLUMN_NAME, PG_DIAG_CONSTRAINT_NAME, PG_DIAG_CONTEXT, PG_DIAG_DATATYPE_NAME, PG_DIAG_INTERNAL_POSITION, PG_DIAG_INTERNAL_QUERY, PG_DIAG_MESSAGE_DETAIL, PG_DIAG_MESSAGE_HINT, PG_DIAG_MESSAGE_PRIMARY, PG_DIAG_SCHEMA_NAME, PG_DIAG_SEVERITY, PG_DIAG_SEVERITY_NONLOCALIZED, PG_DIAG_SOURCE_FILE, PG_DIAG_SOURCE_FUNCTION, PG_DIAG_SOURCE_LINE, PG_DIAG_SQLSTATE, PG_DIAG_STATEMENT_POSITION, PG_DIAG_TABLE_NAME, pq_getmsgbyte(), pq_getmsgend(), pq_getmsgrawstring(), pstrdup(), ErrorData::schema_name, ErrorData::sqlerrcode, ErrorData::table_name, value, and WARNING.

Referenced by HandleParallelMessage().

216 {
217  /* Initialize edata with reasonable defaults. */
218  MemSet(edata, 0, sizeof(ErrorData));
219  edata->elevel = ERROR;
221 
222  /* Loop over fields and extract each one. */
223  for (;;)
224  {
225  char code = pq_getmsgbyte(msg);
226  const char *value;
227 
228  if (code == '\0')
229  {
230  pq_getmsgend(msg);
231  break;
232  }
233  value = pq_getmsgrawstring(msg);
234 
235  switch (code)
236  {
237  case PG_DIAG_SEVERITY:
238  /* ignore, trusting we'll get a nonlocalized version */
239  break;
241  if (strcmp(value, "DEBUG") == 0)
242  {
243  /*
244  * We can't reconstruct the exact DEBUG level, but
245  * presumably it was >= client_min_messages, so select
246  * DEBUG1 to ensure we'll pass it on to the client.
247  */
248  edata->elevel = DEBUG1;
249  }
250  else if (strcmp(value, "LOG") == 0)
251  {
252  /*
253  * It can't be LOG_SERVER_ONLY, or the worker wouldn't
254  * have sent it to us; so LOG is the correct value.
255  */
256  edata->elevel = LOG;
257  }
258  else if (strcmp(value, "INFO") == 0)
259  edata->elevel = INFO;
260  else if (strcmp(value, "NOTICE") == 0)
261  edata->elevel = NOTICE;
262  else if (strcmp(value, "WARNING") == 0)
263  edata->elevel = WARNING;
264  else if (strcmp(value, "ERROR") == 0)
265  edata->elevel = ERROR;
266  else if (strcmp(value, "FATAL") == 0)
267  edata->elevel = FATAL;
268  else if (strcmp(value, "PANIC") == 0)
269  edata->elevel = PANIC;
270  else
271  elog(ERROR, "unrecognized error severity: \"%s\"", value);
272  break;
273  case PG_DIAG_SQLSTATE:
274  if (strlen(value) != 5)
275  elog(ERROR, "invalid SQLSTATE: \"%s\"", value);
276  edata->sqlerrcode = MAKE_SQLSTATE(value[0], value[1], value[2],
277  value[3], value[4]);
278  break;
280  edata->message = pstrdup(value);
281  break;
283  edata->detail = pstrdup(value);
284  break;
286  edata->hint = pstrdup(value);
287  break;
289  edata->cursorpos = pg_atoi(value, sizeof(int), '\0');
290  break;
292  edata->internalpos = pg_atoi(value, sizeof(int), '\0');
293  break;
295  edata->internalquery = pstrdup(value);
296  break;
297  case PG_DIAG_CONTEXT:
298  edata->context = pstrdup(value);
299  break;
300  case PG_DIAG_SCHEMA_NAME:
301  edata->schema_name = pstrdup(value);
302  break;
303  case PG_DIAG_TABLE_NAME:
304  edata->table_name = pstrdup(value);
305  break;
306  case PG_DIAG_COLUMN_NAME:
307  edata->column_name = pstrdup(value);
308  break;
310  edata->datatype_name = pstrdup(value);
311  break;
313  edata->constraint_name = pstrdup(value);
314  break;
315  case PG_DIAG_SOURCE_FILE:
316  edata->filename = pstrdup(value);
317  break;
318  case PG_DIAG_SOURCE_LINE:
319  edata->lineno = pg_atoi(value, sizeof(int), '\0');
320  break;
322  edata->funcname = pstrdup(value);
323  break;
324  default:
325  elog(ERROR, "unrecognized error field code: %d", (int) code);
326  break;
327  }
328  }
329 }
char * schema_name
Definition: elog.h:349
#define DEBUG1
Definition: elog.h:25
#define PG_DIAG_MESSAGE_PRIMARY
Definition: postgres_ext.h:58
#define PG_DIAG_SCHEMA_NAME
Definition: postgres_ext.h:65
int sqlerrcode
Definition: elog.h:342
#define PG_DIAG_MESSAGE_DETAIL
Definition: postgres_ext.h:59
#define PG_DIAG_COLUMN_NAME
Definition: postgres_ext.h:67
#define MAKE_SQLSTATE(ch1, ch2, ch3, ch4, ch5)
Definition: elog.h:62
const char * funcname
Definition: elog.h:339
char * pstrdup(const char *in)
Definition: mcxt.c:1063
#define PG_DIAG_TABLE_NAME
Definition: postgres_ext.h:66
int lineno
Definition: elog.h:338
#define PG_DIAG_SOURCE_LINE
Definition: postgres_ext.h:71
#define MemSet(start, val, len)
Definition: c.h:863
#define INFO
Definition: elog.h:33
char * internalquery
Definition: elog.h:356
#define LOG
Definition: elog.h:26
#define PG_DIAG_INTERNAL_POSITION
Definition: postgres_ext.h:62
const char * pq_getmsgrawstring(StringInfo msg)
Definition: pqformat.c:610
#define PG_DIAG_SQLSTATE
Definition: postgres_ext.h:57
#define PANIC
Definition: elog.h:53
int cursorpos
Definition: elog.h:354
#define PG_DIAG_SOURCE_FILE
Definition: postgres_ext.h:70
#define ERROR
Definition: elog.h:43
const char * filename
Definition: elog.h:337
#define FATAL
Definition: elog.h:52
static struct @121 value
char * table_name
Definition: elog.h:350
int internalpos
Definition: elog.h:355
#define PG_DIAG_SEVERITY
Definition: postgres_ext.h:55
MemoryContext CurrentMemoryContext
Definition: mcxt.c:37
#define PG_DIAG_STATEMENT_POSITION
Definition: postgres_ext.h:61
#define WARNING
Definition: elog.h:40
char * datatype_name
Definition: elog.h:352
int elevel
Definition: elog.h:331
char * detail
Definition: elog.h:344
#define PG_DIAG_DATATYPE_NAME
Definition: postgres_ext.h:68
#define PG_DIAG_CONSTRAINT_NAME
Definition: postgres_ext.h:69
#define PG_DIAG_SEVERITY_NONLOCALIZED
Definition: postgres_ext.h:56
#define PG_DIAG_INTERNAL_QUERY
Definition: postgres_ext.h:63
#define PG_DIAG_MESSAGE_HINT
Definition: postgres_ext.h:60
char * column_name
Definition: elog.h:351
#define NOTICE
Definition: elog.h:37
int pq_getmsgbyte(StringInfo msg)
Definition: pqformat.c:401
char * hint
Definition: elog.h:346
char * context
Definition: elog.h:347
struct MemoryContextData * assoc_context
Definition: elog.h:360
#define elog
Definition: elog.h:219
void pq_getmsgend(StringInfo msg)
Definition: pqformat.c:637
char * constraint_name
Definition: elog.h:353
#define PG_DIAG_SOURCE_FUNCTION
Definition: postgres_ext.h:72
char * message
Definition: elog.h:343
int32 pg_atoi(const char *s, int size, int c)
Definition: numutils.c:37
#define PG_DIAG_CONTEXT
Definition: postgres_ext.h:64

◆ pq_redirect_to_shm_mq()

void pq_redirect_to_shm_mq ( dsm_segment seg,
shm_mq_handle mqh 
)

Definition at line 55 of file pqmq.c.

References DestRemote, FrontendProtocol, on_dsm_detach(), PG_PROTOCOL_LATEST, pq_cleanup_redirect_to_shm_mq(), PqCommMethods, PqCommMqMethods, and whereToSendOutput.

Referenced by ParallelWorkerMain().

56 {
58  pq_mq_handle = mqh;
62 }
static shm_mq_handle * pq_mq_handle
Definition: pqmq.c:24
PQcommMethods * PqCommMethods
Definition: pqcomm.c:184
#define PG_PROTOCOL_LATEST
Definition: pqcomm.h:111
static void pq_cleanup_redirect_to_shm_mq(dsm_segment *seg, Datum arg)
Definition: pqmq.c:69
void on_dsm_detach(dsm_segment *seg, on_dsm_detach_callback function, Datum arg)
Definition: dsm.c:1024
static PQcommMethods PqCommMqMethods
Definition: pqmq.c:39
uintptr_t Datum
Definition: postgres.h:372
CommandDest whereToSendOutput
Definition: postgres.c:88
ProtocolVersion FrontendProtocol
Definition: globals.c:27

◆ pq_set_parallel_master()

void pq_set_parallel_master ( pid_t  pid,
BackendId  backend_id 
)

Definition at line 80 of file pqmq.c.

References Assert, pq_mq_parallel_master_backend_id, pq_mq_parallel_master_pid, and PqCommMethods.

Referenced by ParallelWorkerMain().

81 {
85 }
PQcommMethods * PqCommMethods
Definition: pqcomm.c:184
static PQcommMethods PqCommMqMethods
Definition: pqmq.c:39
static pid_t pq_mq_parallel_master_pid
Definition: pqmq.c:26
static pid_t pq_mq_parallel_master_backend_id
Definition: pqmq.c:27
#define Assert(condition)
Definition: c.h:680