Method mergeTo

src/jrd/Savepoint.cpp:160–246

}

void VerbAction::mergeTo(thread_db* tdbb, jrd_tra* transaction, VerbAction* nextAction)
{
	// Post bitmap of modified records and undo data to the next savepoint.
	//
	// Notes:
	//
	// If previous savepoint already touched a record, undo data must be dropped and
	// all BLOBs it refers to should be cleaned out because under no circumstances
	// this undo data can become an active record.

	// Merge undo records first

	if (vct_undo && vct_undo->getFirst())
	{
		do
		{
			UndoItem& item = vct_undo->current();

			if (item.hasData()) // this item wasn't released yet
			{
				const SINT64 recordNumber = item.generate(NULL, item);

				if (nextAction && !(RecordBitmap::test(nextAction->vct_records, recordNumber)))
				{
					if (!nextAction->vct_undo)
					{
						nextAction->vct_undo =
							FB_NEW_POOL(*transaction->tra_pool) UndoItemTree(*transaction->tra_pool);
						// We cannot just push whole current undo items list, some items still may be released
					}
					else
					{
						if (nextAction->vct_undo->locate(recordNumber))
						{
							// It looks like something went wrong on previous loop and undo record
							// was moved to next action but record bit in bitmap wasn't set
							fb_assert(false);
							item.clear();
							continue;
						}
					}

					nextAction->vct_undo->add(item);
					item.clear(); // Do not release undo data, it now belongs to next action
					continue;
				}

				// garbage cleanup and release
				// because going version for sure has all index entries successfully set up (in contrast with undo)
				// we can use lightweigth version of garbage collection without collection of full staying list

				AutoTempRecord this_ver(item.setupRecord(transaction));

				garbageCollectIdxLite(tdbb, transaction, recordNumber, nextAction, this_ver);

				item.release(transaction);
			}
		} while (vct_undo->getNext());