Method fileWriter

src/burp/BurpTasks.cpp:581–629

}

bool BackupRelationTask::fileWriter(Item& item)
{
	BurpGlobals* tdgbl = item.m_gbl;
	fb_assert(tdgbl == m_masterGbl);

	BURP_verbose(142, m_relation->rel_name);
	// msg 142  writing data for relation %s

	IOBuffer*& buf = item.m_buffer = NULL;
	FB_UINT64 records = 0;
	FB_UINT64 verbRecs = -1;
	FB_UINT64 verb = 0;
	while (!m_stop)
	{
		if (!buf)
			buf = getDirtyBuffer();
		else
			buf->lock();

		if (!buf)
			break;

		const UCHAR* p = buf->getBuffer();
		FB_SIZE_T recs = buf->getRecs();
		FB_SIZE_T len = (recs > 0) ? buf->getUsed() : buf->getSize();

		// very inefficient !
		MVOL_write_block(tdgbl, p, len);

		IOBuffer* next = buf->getNext();
		buf->clear();
		putCleanBuffer(buf);
		buf = next;

		records += recs;

		if (verb != (records / tdgbl->verboseInterval))
		{
			verb = (records / tdgbl->verboseInterval);
			verbRecs = records;
			BURP_verbose(108, SafeArg() << (verb * tdgbl->verboseInterval) /*records*/);
		}
	}

	if (records != verbRecs)
		BURP_verbose(108, SafeArg() << records);

	return true;
}

BackupRelationTask::Item::EnsureUnlockBuffer::~EnsureUnlockBuffer()
{