Function CopyMultiInsertBufferCleanup

src/backend/commands/copyfrom.c:548–583

* Drop used slots and free member for this buffer. * * The buffer must be flushed before cleanup. */

 * The buffer must be flushed before cleanup.
 */
static inline void
CopyMultiInsertBufferCleanup(CopyMultiInsertInfo *miinfo,
							 CopyMultiInsertBuffer *buffer)
{
	int			i;

	/* Ensure buffer was flushed */
	Assert(buffer->nused == 0);

	/* Remove back-link to ourself */
	buffer->resultRelInfo->ri_CopyMultiInsertBuffer = NULL;

	FreeBulkInsertState(buffer->bistate);

	/* Since we only create slots on demand, just drop the non-null ones. */
	for (i = 0; i < MAX_BUFFERED_TUPLES && buffer->slots[i] != NULL; i++)
		ExecDropSingleTupleTableSlot(buffer->slots[i]);

	if (RelationIsNonblockRelation(buffer->resultRelInfo->ri_RelationDesc))
	{
		/*
		 * CBDB: do not call table_finish_bulk_insert for AO/AOCO or PAX tables.
		 * https://github.com/apache/cloudberry/issues/547
		 * Do not clean up context or resource here, table_finish_bulk_insert
		 * routine will be called more than once during COPY FROM if
		 * the partition buffer is flushed but COPY is not finished.
		 */
		pfree(buffer);
		return;
	}

	table_finish_bulk_insert(buffer->resultRelInfo->ri_RelationDesc,
							 miinfo->ti_options);

	pfree(buffer);
}

/*
 * Write out all stored tuples in all buffers out to the tables.