tstoreReceiver.h File Reference

#include "tcop/dest.h"
#include "utils/tuplestore.h"

Include dependency graph for tstoreReceiver.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
DestReceiver *	CreateTuplestoreDestReceiver (void)
void	SetTuplestoreDestReceiverParams (DestReceiver *self, Tuplestorestate *tStore, MemoryContext tContext, bool detoast, TupleDesc target_tupdesc, const char *map_failure_msg)

Function Documentation

CreateTuplestoreDestReceiver()

DestReceiver* CreateTuplestoreDestReceiver

(

void

)

Definition at line 238 of file tstoreReceiver.c.

{
    TStoreState *self = (TStoreState *) palloc0(sizeof(TStoreState));
 
    self->pub.receiveSlot = tstoreReceiveSlot_notoast;  /* might change */
    self->pub.rStartup = tstoreStartupReceiver;
    self->pub.rShutdown = tstoreShutdownReceiver;
    self->pub.rDestroy = tstoreDestroyReceiver;
    self->pub.mydest = DestTuplestore;
 
    /* private fields will be set by SetTuplestoreDestReceiverParams */
 
    return (DestReceiver *) self;
}

References DestTuplestore, palloc0(), tstoreDestroyReceiver(), tstoreReceiveSlot_notoast(), tstoreShutdownReceiver(), and tstoreStartupReceiver().

Referenced by CreateDestReceiver().

SetTuplestoreDestReceiverParams()

void SetTuplestoreDestReceiverParams	(	DestReceiver *	self,
		Tuplestorestate *	tStore,
		MemoryContext	tContext,
		bool	detoast,
		TupleDesc	target_tupdesc,
		const char *	map_failure_msg
	)

Definition at line 266 of file tstoreReceiver.c.

{
    TStoreState *myState = (TStoreState *) self;
 
    Assert(!(detoast && target_tupdesc));
 
    Assert(myState->pub.mydest == DestTuplestore);
    myState->tstore = tStore;
    myState->cxt = tContext;
    myState->detoast = detoast;
    myState->target_tupdesc = target_tupdesc;
    myState->map_failure_msg = map_failure_msg;
}

References Assert, TStoreState::cxt, DestTuplestore, TStoreState::detoast, TStoreState::map_failure_msg, _DestReceiver::mydest, TStoreState::pub, TStoreState::target_tupdesc, and TStoreState::tstore.

Referenced by exec_stmt_return_query(), FillPortalStore(), and PersistHoldablePortal().