Function flushAll

src/jrd/cch.cpp:2714–2765

Collect pages modified by garbage collector or all dirty pages or release page locks - depending of flush_flag, and write it to disk. See also comments in flushPages.

// locks - depending of flush_flag, and write it to disk.
// See also comments in flushPages.
static void flushAll(thread_db* tdbb, USHORT flush_flag)
{
	SET_TDBB(tdbb);
	Database* dbb = tdbb->getDatabase();
	BufferControl* bcb = dbb->dbb_bcb;
	Firebird::HalfStaticArray<BufferDesc*, 1024> flush(bcb->bcb_dirty_count);

	const bool all_flag = (flush_flag & FLUSH_ALL) != 0;
	const bool sweep_flag = (flush_flag & FLUSH_SWEEP) != 0;
	const bool release_flag = (flush_flag & FLUSH_RLSE) != 0;
	const bool write_thru = release_flag;

	{
		Sync bcbSync(&bcb->bcb_syncObject, FB_FUNCTION);
		if (!bcb->bcb_syncObject.ourExclusiveLock())
			bcbSync.lock(SYNC_SHARED);

		for (auto blk : bcb->bcb_bdbBlocks)
		{
			for (ULONG i = 0; i < blk.m_count; i++)
			{
				BufferDesc* bdb = &blk.m_bdbs[i];

				if (bdb->bdb_flags & (BDB_db_dirty | BDB_dirty))
				{
					if (bdb->bdb_flags & BDB_dirty)
						flush.add(bdb);
					else if (bdb->bdb_flags & BDB_db_dirty)
					{
						// pages modified by sweep\garbage collector are not in dirty list
						const bool dirty_list = (bdb->bdb_dirty.que_forward != &bdb->bdb_dirty);

						if (all_flag || (sweep_flag && !dirty_list))
							flush.add(bdb);
					}
				}
				else if (release_flag)
				{
					bdb->addRef(tdbb, SYNC_EXCLUSIVE);

					if (bdb->bdb_use_count > 1)
						BUGCHECK(210);	// msg 210 page in use during flush

					PAGE_LOCK_RELEASE(tdbb, bcb, bdb->bdb_lock);
					bdb->release(tdbb, false);
				}
			}
		}
	}

	flushPages(tdbb, flush_flag, flush.begin(), flush.getCount());
}


// Used in qsort below