Method start

src/yvalve/DistributedTransaction.cpp:553–593

}

YTransaction* DtcStart::start(CheckStatusWrapper* status)
{
	try
	{
		status->init();

		RefPtr<DTransaction> dtransaction(FB_NEW DTransaction);

		unsigned cnt = components.getCount();
		if (status->getState() & IStatus::STATE_ERRORS)
			status_exception::raise(status);
		if (cnt == 0)
			(Arg::Gds(isc_random) << "No attachments to start distributed transaction provided").raise();

		for (unsigned i = 0; i < cnt; ++i)
		{
			ITransaction* started = components[i].att->startTransaction(status, components[i].tpbLen, components[i].tpb);
			if (status->getState() & IStatus::STATE_ERRORS)
				status_exception::raise(status);

			dtransaction->join(status, started);
			if (status->getState() & IStatus::STATE_ERRORS)
			{
				started->release();
				status_exception::raise(status);
			}
		}

		YTransaction* rc = FB_NEW YTransaction(NULL, dtransaction);
		rc->addRef();
		dtransaction->addRef();
		this->dispose();
		return rc;
	}
	catch (const Exception& ex)
	{
		ex.stuffException(status);
	}

	return NULL;
}

YTransaction* Dtc::join(CheckStatusWrapper* status, ITransaction* one, ITransaction* two)
{