PostgreSQL Source Code git master
|
Go to the source code of this file.
Typedefs | |
typedef struct TupleQueueReader | TupleQueueReader |
Functions | |
DestReceiver * | CreateTupleQueueDestReceiver (shm_mq_handle *handle) |
TupleQueueReader * | CreateTupleQueueReader (shm_mq_handle *handle) |
void | DestroyTupleQueueReader (TupleQueueReader *reader) |
MinimalTuple | TupleQueueReaderNext (TupleQueueReader *reader, bool nowait, bool *done) |
typedef struct TupleQueueReader TupleQueueReader |
DestReceiver * CreateTupleQueueDestReceiver | ( | shm_mq_handle * | handle | ) |
Definition at line 119 of file tqueue.c.
References DestTupleQueue, _DestReceiver::mydest, palloc0(), TQueueDestReceiver::pub, TQueueDestReceiver::queue, _DestReceiver::rDestroy, _DestReceiver::receiveSlot, _DestReceiver::rShutdown, _DestReceiver::rStartup, tqueueDestroyReceiver(), tqueueReceiveSlot(), tqueueShutdownReceiver(), and tqueueStartupReceiver().
Referenced by CreateDestReceiver(), and ExecParallelGetReceiver().
TupleQueueReader * CreateTupleQueueReader | ( | shm_mq_handle * | handle | ) |
Definition at line 139 of file tqueue.c.
References palloc0(), and TupleQueueReader::queue.
Referenced by ExecParallelCreateReaders().
void DestroyTupleQueueReader | ( | TupleQueueReader * | reader | ) |
MinimalTuple TupleQueueReaderNext | ( | TupleQueueReader * | reader, |
bool | nowait, | ||
bool * | done | ||
) |
Definition at line 176 of file tqueue.c.
References Assert, data, TupleQueueReader::queue, SHM_MQ_DETACHED, shm_mq_receive(), SHM_MQ_SUCCESS, SHM_MQ_WOULD_BLOCK, and MinimalTupleData::t_len.
Referenced by gather_readnext(), and gm_readnext_tuple().