Method rollforward

src/jrd/Savepoint.cpp:481–569

}

Savepoint* Savepoint::rollforward(thread_db* tdbb, Savepoint* prior)
{
	// Merge changes made in this savepoint into next one.
	// Perform index and BLOB cleanup if needed.
	// At the exit savepoint is clear and safe to reuse.

	jrd_tra* const old_tran = tdbb->getTransaction();

	try
	{
		// If the current to-be-cleaned-up savepoint is very big, and the next
		// level savepoint is the transaction level savepoint, then get rid of
		// the transaction level savepoint now (instead of after making the
		// transaction level savepoint very very big).

		if (m_next && m_next->isRoot() && this->isLarge())
		{
			fb_assert(!m_next->m_next); // check that transaction savepoint is the last in list
			// get rid of tx-level savepoint
			m_next->rollforward(tdbb);
			m_next = NULL;
		}

		// Cleanup/merge deferred work/event post

		if (m_actions || (m_flags & SAV_force_dfw))
		{
			DFW_merge_work(m_transaction, m_number, m_next ? m_next->m_number : 0);

			if (m_next && (m_flags & SAV_force_dfw))
				m_next->m_flags |= SAV_force_dfw;

			m_flags &= ~SAV_force_dfw;
		}

		tdbb->tdbb_flags |= TDBB_verb_cleanup;
		tdbb->setTransaction(m_transaction);

		while (m_actions)
		{
			VerbAction* const action = m_actions;
			VerbAction* nextAction = NULL;

			if (m_next)
			{
				nextAction = m_next->getAction(action->vct_relation);

				if (!nextAction) // next savepoint didn't touch this table yet - send whole action
				{
					m_actions = action->vct_next;
					action->vct_next = m_next->m_actions;
					m_next->m_actions = action;
					continue;
				}
			}

			// No luck, merge action in a slow way
			action->mergeTo(tdbb, m_transaction, nextAction);