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

Function cdbCopySendDataToAll

src/backend/cdb/cdbcopy.c:222–235  ·  view source on GitHub ↗

* sends data to a copy command on all segments. */

Source from the content-addressed store, hash-verified

220 * sends data to a copy command on all segments.
221 */
222void
223cdbCopySendDataToAll(CdbCopy *c, const char *buffer, int nbytes)
224{
225 Gang *gp = getCdbCopyPrimaryGang(c);
226
227 Assert(gp);
228
229 for (int i = 0; i < gp->size; ++i)
230 {
231 int seg = gp->db_descriptors[i]->segindex;
232
233 cdbCopySendData(c, seg, buffer, nbytes);
234 }
235}
236
237/*
238 * sends data to a copy command on a specific segment (usually

Callers 2

Calls 2

getCdbCopyPrimaryGangFunction · 0.85
cdbCopySendDataFunction · 0.85

Tested by

no test coverage detected