PostgreSQL Source Code git master
|
#include "postgres.h"
#include "access/printsimple.h"
#include "access/printtup.h"
#include "access/xact.h"
#include "commands/copy.h"
#include "commands/createas.h"
#include "commands/explain_dr.h"
#include "commands/matview.h"
#include "executor/functions.h"
#include "executor/tqueue.h"
#include "executor/tstoreReceiver.h"
#include "libpq/libpq.h"
#include "libpq/pqformat.h"
Go to the source code of this file.
Functions | |
static bool | donothingReceive (TupleTableSlot *slot, DestReceiver *self) |
static void | donothingStartup (DestReceiver *self, int operation, TupleDesc typeinfo) |
static void | donothingCleanup (DestReceiver *self) |
void | BeginCommand (CommandTag commandTag, CommandDest dest) |
DestReceiver * | CreateDestReceiver (CommandDest dest) |
void | EndCommand (const QueryCompletion *qc, CommandDest dest, bool force_undecorated_output) |
void | EndReplicationCommand (const char *commandTag) |
void | NullCommand (CommandDest dest) |
void | ReadyForQuery (CommandDest dest) |
Variables | |
static const DestReceiver | donothingDR |
static const DestReceiver | debugtupDR |
static const DestReceiver | printsimpleDR |
static const DestReceiver | spi_printtupDR |
DestReceiver * | None_Receiver = (DestReceiver *) &donothingDR |
void BeginCommand | ( | CommandTag | commandTag, |
CommandDest | dest | ||
) |
Definition at line 103 of file dest.c.
Referenced by exec_execute_message(), and exec_simple_query().
DestReceiver * CreateDestReceiver | ( | CommandDest | dest | ) |
Definition at line 113 of file dest.c.
References CreateCopyDestReceiver(), CreateExplainSerializeDestReceiver(), CreateIntoRelDestReceiver(), CreateSQLFunctionDestReceiver(), CreateTransientRelDestReceiver(), CreateTupleQueueDestReceiver(), CreateTuplestoreDestReceiver(), debugtupDR, generate_unaccent_rules::dest, DestCopyOut, DestDebug, DestExplainSerialize, DestIntoRel, DestNone, DestRemote, DestRemoteExecute, DestRemoteSimple, DestSPI, DestSQLFunction, DestTransientRel, DestTupleQueue, DestTuplestore, donothingDR, InvalidOid, pg_unreachable, printsimpleDR, printtup_create_DR(), spi_printtupDR, and unconstify.
Referenced by _SPI_execute_plan(), BeginCopyTo(), CreateReplicationSlot(), exec_execute_message(), exec_replication_command(), exec_simple_query(), exec_stmt_return_query(), execute_sql_string(), FillPortalStore(), IdentifySystem(), PersistHoldablePortal(), postquel_start(), ReadReplicationSlot(), SendTablespaceList(), SendTimeLineHistory(), SendXlogRecPtrResult(), SPI_cursor_fetch(), SPI_scroll_cursor_fetch(), and StartReplication().
|
static |
|
static |
|
static |
void EndCommand | ( | const QueryCompletion * | qc, |
CommandDest | dest, | ||
bool | force_undecorated_output | ||
) |
Definition at line 169 of file dest.c.
References BuildQueryCompletionString(), COMPLETION_TAG_BUFSIZE, generate_unaccent_rules::dest, DestCopyOut, DestDebug, DestExplainSerialize, DestIntoRel, DestNone, DestRemote, DestRemoteExecute, DestRemoteSimple, DestSPI, DestSQLFunction, DestTransientRel, DestTupleQueue, DestTuplestore, len, pq_putmessage, and PqMsg_CommandComplete.
Referenced by exec_execute_message(), exec_simple_query(), StartLogicalReplication(), and WalSndDone().
void EndReplicationCommand | ( | const char * | commandTag | ) |
Definition at line 205 of file dest.c.
References pq_putmessage, and PqMsg_CommandComplete.
Referenced by exec_replication_command(), and StartReplication().
void NullCommand | ( | CommandDest | dest | ) |
Definition at line 218 of file dest.c.
References generate_unaccent_rules::dest, DestCopyOut, DestDebug, DestExplainSerialize, DestIntoRel, DestNone, DestRemote, DestRemoteExecute, DestRemoteSimple, DestSPI, DestSQLFunction, DestTransientRel, DestTupleQueue, DestTuplestore, pq_putemptymessage(), and PqMsg_EmptyQueryResponse.
Referenced by exec_execute_message(), and exec_simple_query().
void ReadyForQuery | ( | CommandDest | dest | ) |
Definition at line 256 of file dest.c.
References buf, generate_unaccent_rules::dest, DestCopyOut, DestDebug, DestExplainSerialize, DestIntoRel, DestNone, DestRemote, DestRemoteExecute, DestRemoteSimple, DestSPI, DestSQLFunction, DestTransientRel, DestTupleQueue, DestTuplestore, pq_beginmessage(), pq_endmessage(), pq_flush, pq_sendbyte(), PqMsg_ReadyForQuery, and TransactionBlockStatusCode().
Referenced by PostgresMain().
|
static |
Definition at line 75 of file dest.c.
Referenced by CreateDestReceiver().
|
static |
Definition at line 70 of file dest.c.
Referenced by CreateDestReceiver().
DestReceiver* None_Receiver = (DestReceiver *) &donothingDR |
Definition at line 96 of file dest.c.
Referenced by CreateSchemaCommand(), DoPortalRunFetch(), ExplainOnePlan(), FillPortalStore(), ImportForeignSchema(), PerformPortalFetch(), PortalRunMulti(), PortalStart(), postquel_start(), ProcessUtilityForAlterTable(), ProcessUtilitySlow(), SPI_cursor_move(), and SPI_scroll_cursor_move().
|
static |
Definition at line 80 of file dest.c.
Referenced by CreateDestReceiver().
|
static |
Definition at line 85 of file dest.c.
Referenced by CreateDestReceiver().