dest.c File Reference

#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"

Include dependency graph for dest.c:

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

Function Documentation

BeginCommand()

void BeginCommand	(	CommandTag	commandTag,
		CommandDest	dest
	)

Definition at line 103 of file dest.c.

{
    /* Nothing to do at present */
}

Referenced by exec_execute_message(), and exec_simple_query().

CreateDestReceiver()

DestReceiver * CreateDestReceiver

(

CommandDest

dest

)

Definition at line 113 of file dest.c.

{
    /*
     * It's ok to cast the constness away as any modification of the none
     * receiver would be a bug (which gets easier to catch this way).
     */
 
    switch (dest)
    {
        case DestRemote:
        case DestRemoteExecute:
            return printtup_create_DR(dest);
 
        case DestRemoteSimple:
            return unconstify(DestReceiver *, &printsimpleDR);
 
        case DestNone:
            return unconstify(DestReceiver *, &donothingDR);
 
        case DestDebug:
            return unconstify(DestReceiver *, &debugtupDR);
 
        case DestSPI:
            return unconstify(DestReceiver *, &spi_printtupDR);
 
        case DestTuplestore:
            return CreateTuplestoreDestReceiver();
 
        case DestIntoRel:
            return CreateIntoRelDestReceiver(NULL);
 
        case DestCopyOut:
            return CreateCopyDestReceiver();
 
        case DestSQLFunction:
            return CreateSQLFunctionDestReceiver();
 
        case DestTransientRel:
            return CreateTransientRelDestReceiver(InvalidOid);
 
        case DestTupleQueue:
            return CreateTupleQueueDestReceiver(NULL);
 
        case DestExplainSerialize:
            return CreateExplainSerializeDestReceiver(NULL);
    }
 
    /* should never get here */
    pg_unreachable();
}

References CreateCopyDestReceiver(), CreateExplainSerializeDestReceiver(), CreateIntoRelDestReceiver(), CreateSQLFunctionDestReceiver(), CreateTransientRelDestReceiver(), CreateTupleQueueDestReceiver(), CreateTuplestoreDestReceiver(), debugtupDR, DestCopyOut, DestDebug, DestExplainSerialize, DestIntoRel, DestNone, DestRemote, DestRemoteExecute, DestRemoteSimple, DestSPI, DestSQLFunction, DestTransientRel, DestTupleQueue, DestTuplestore, donothingDR, fb(), 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().

donothingCleanup()

static void donothingCleanup ( DestReceiver *  self )

static

Definition at line 61 of file dest.c.

{
    /* this is used for both shutdown and destroy methods */
}

donothingReceive()

static bool donothingReceive ( TupleTableSlot *  slot, DestReceiver *  self  )

static

Definition at line 50 of file dest.c.

{
    return true;
}

donothingStartup()

static void donothingStartup ( DestReceiver *  self, int  operation, TupleDesc  typeinfo  )

static

Definition at line 56 of file dest.c.

{
}

EndCommand()

void EndCommand	(	const QueryCompletion *	qc,
		CommandDest	dest,
		bool	force_undecorated_output
	)

Definition at line 169 of file dest.c.

{
    char        completionTag[COMPLETION_TAG_BUFSIZE];
    Size        len;
 
    switch (dest)
    {
        case DestRemote:
        case DestRemoteExecute:
        case DestRemoteSimple:
 
            len = BuildQueryCompletionString(completionTag, qc,
                                             force_undecorated_output);
            pq_putmessage(PqMsg_CommandComplete, completionTag, len + 1);
            break;
 
        case DestNone:
        case DestDebug:
        case DestSPI:
        case DestTuplestore:
        case DestIntoRel:
        case DestCopyOut:
        case DestSQLFunction:
        case DestTransientRel:
        case DestTupleQueue:
        case DestExplainSerialize:
            break;
    }
}

References BuildQueryCompletionString(), COMPLETION_TAG_BUFSIZE, DestCopyOut, DestDebug, DestExplainSerialize, DestIntoRel, DestNone, DestRemote, DestRemoteExecute, DestRemoteSimple, DestSPI, DestSQLFunction, DestTransientRel, DestTupleQueue, DestTuplestore, fb(), len, pq_putmessage, and PqMsg_CommandComplete.

Referenced by exec_execute_message(), exec_simple_query(), StartLogicalReplication(), and WalSndDone().

EndReplicationCommand()

void EndReplicationCommand

(

const char *

commandTag

)

Definition at line 206 of file dest.c.

{
    pq_putmessage(PqMsg_CommandComplete, commandTag, strlen(commandTag) + 1);
}

References fb(), pq_putmessage, and PqMsg_CommandComplete.

Referenced by exec_replication_command(), and StartReplication().

NullCommand()

void NullCommand

(

CommandDest

dest

)

Definition at line 219 of file dest.c.

{
    switch (dest)
    {
        case DestRemote:
        case DestRemoteExecute:
        case DestRemoteSimple:
 
            /* Tell the FE that we saw an empty query string */
            pq_putemptymessage(PqMsg_EmptyQueryResponse);
            break;
 
        case DestNone:
        case DestDebug:
        case DestSPI:
        case DestTuplestore:
        case DestIntoRel:
        case DestCopyOut:
        case DestSQLFunction:
        case DestTransientRel:
        case DestTupleQueue:
        case DestExplainSerialize:
            break;
    }
}

References 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().

ReadyForQuery()

void ReadyForQuery

(

CommandDest

dest

)

Definition at line 257 of file dest.c.

{
    switch (dest)
    {
        case DestRemote:
        case DestRemoteExecute:
        case DestRemoteSimple:
            {
                StringInfoData buf;
 
                pq_beginmessage(&buf, PqMsg_ReadyForQuery);
                pq_sendbyte(&buf, TransactionBlockStatusCode());
                pq_endmessage(&buf);
            }
            /* Flush output at end of cycle in any case. */
            pq_flush();
            break;
 
        case DestNone:
        case DestDebug:
        case DestSPI:
        case DestTuplestore:
        case DestIntoRel:
        case DestCopyOut:
        case DestSQLFunction:
        case DestTransientRel:
        case DestTupleQueue:
        case DestExplainSerialize:
            break;
    }
}

References buf, 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().

Variable Documentation

debugtupDR

const DestReceiver debugtupDR

static

Initial value:

= {
    debugtup, debugStartup, donothingCleanup, donothingCleanup,
    DestDebug
}

Definition at line 75 of file dest.c.

                                       {
    debugtup, debugStartup, donothingCleanup, donothingCleanup,
    DestDebug
};

Referenced by CreateDestReceiver().

donothingDR

const DestReceiver donothingDR

static

Initial value:

= {
    donothingReceive, donothingStartup, donothingCleanup, donothingCleanup,
    DestNone
}

Definition at line 70 of file dest.c.

                                        {
    donothingReceive, donothingStartup, donothingCleanup, donothingCleanup,
    DestNone
};

Referenced by CreateDestReceiver().

None_Receiver

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().

printsimpleDR

const DestReceiver printsimpleDR

static

Initial value:

= {
    printsimple, printsimple_startup, donothingCleanup, donothingCleanup,
    DestRemoteSimple
}

Definition at line 80 of file dest.c.

                                          {
    printsimple, printsimple_startup, donothingCleanup, donothingCleanup,
    DestRemoteSimple
};

Referenced by CreateDestReceiver().

spi_printtupDR

const DestReceiver spi_printtupDR

static

Initial value:

= {
    spi_printtup, spi_dest_startup, donothingCleanup, donothingCleanup,
    DestSPI
}

Definition at line 85 of file dest.c.

                                           {
    spi_printtup, spi_dest_startup, donothingCleanup, donothingCleanup,
    DestSPI
};

Referenced by CreateDestReceiver().