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  )

extern

Definition at line 239 of file tstoreReceiver.c.

{
    TStoreState *self = palloc0_object(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, _DestReceiver::mydest, palloc0_object, TStoreState::pub, _DestReceiver::rDestroy, _DestReceiver::receiveSlot, _DestReceiver::rShutdown, _DestReceiver::rStartup, 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  )

extern

Definition at line 267 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, DestTuplestore, and fb().

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