Function doDispatchDtxProtocolCommand

src/backend/cdb/cdbtm.c:1267–1419

}

bool
doDispatchDtxProtocolCommand(DtxProtocolCommand dtxProtocolCommand,
							 char *gid,
							 bool raiseError,
							 List *dtxSegments,
							 char *serializedDtxContextInfo,
							 int serializedDtxContextInfoLen)
{
	int			i,
				resultCount,
				numOfFailed = 0;

	const char	   *dtxProtocolCommandStr;

	struct pg_result **results;
	MemoryContext oldContext;
	int *waitGxids = NULL;
	int totalWaits = 0;

	if (!dtxSegments)
		return true;

	dtxProtocolCommandStr = DtxProtocolCommandToString(dtxProtocolCommand);

	if (Test_print_direct_dispatch_info)
		elog(INFO, "Distributed transaction command '%s' to %s",
			 								dtxProtocolCommandStr,
											segmentsToContentStr(dtxSegments));

	ereport(DTM_DEBUG5,
			(errmsg("dispatchDtxProtocolCommand: %d ('%s'), direct content #: %s",
					dtxProtocolCommand, dtxProtocolCommandStr,
					segmentsToContentStr(dtxSegments))));

	ErrorData *qeError;
	results = CdbDispatchDtxProtocolCommand(dtxProtocolCommand,
											dtxProtocolCommandStr,
											gid,
											&qeError, &resultCount, dtxSegments,
											serializedDtxContextInfo, serializedDtxContextInfoLen);

	if (qeError)
	{
		/*
		 * Report the ERROR under Debug_print_full_dtm, as it can be lost as we
		 * flush below and the caller may forget to CopyErrorData(). Also, in
		 * some cases caller may not be able to act on the copy (e.g. due to
		 * another error).
		 */
		ereportif(Debug_print_full_dtm, LOG,
				  (errmsg("error on dispatch of dtx protocol command '%s' for gid '%s'",
						  dtxProtocolCommandStr, gid),
				   errdetail("QE reported error: %s", qeError->message)));

		if (raiseError)
		{
			/* flush then rethrow, to avoid overflowing the error stack */
			FlushErrorState();