MCPcopy Create free account
hub / github.com/apache/cloudberry / doSendEndOfStream

Function doSendEndOfStream

src/backend/executor/nodeMotion.c:1142–1153  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

1140
1141
1142void
1143doSendEndOfStream(Motion *motion, MotionState *node)
1144{
1145 /*
1146 * We have no more child tuples, but we have not successfully sent an
1147 * End-of-Stream token yet.
1148 */
1149 SendEndOfStream(node->ps.state->motionlayer_context,
1150 node->ps.state->interconnect_context,
1151 motion->motionID);
1152 node->sentEndOfStream = true;
1153}
1154
1155/*
1156 * A crufty confusing part of the current code is how contentId is used within

Callers 1

execMotionSenderFunction · 0.85

Calls 1

SendEndOfStreamFunction · 0.85

Tested by

no test coverage detected