Method renewBuffer

src/burp/BurpTasks.cpp:351–406

}

IOBuffer* BackupRelationTask::renewBuffer(BurpGlobals* tdgbl)
{
	fb_assert(!tdgbl->master);

	Item* item = static_cast<Item*>(tdgbl->taskItem);
	fb_assert(item);
	if (!item)
		return NULL;

	BackupRelationTask* task = item->getBackupTask();

	IOBuffer* oldBuf = item->m_buffer;
	IOBuffer* newBuf = task->getCleanBuffer(*item);

	if (!newBuf)
	{
		if (oldBuf && task->m_stop)
			oldBuf->unlock();

		throw LongJump();
	}

	FB_SIZE_T used = 0;
	UCHAR* const p = newBuf->getBuffer();

	if (oldBuf)
	{
		fb_assert(tdgbl->mvol_io_buffer == oldBuf->getBuffer());
		fb_assert(tdgbl->gbl_io_ptr == tdgbl->mvol_io_buffer + oldBuf->getSize());
		fb_assert(tdgbl->gbl_io_cnt <= 0);

		if (oldBuf->getRecs() > 0)
		{
			used = tdgbl->mvol_io_data - tdgbl->mvol_io_buffer;
			oldBuf->setUsed(used);

			used = newBuf->getSize() - used;
			memcpy(p, tdgbl->mvol_io_data, used);
		}
		else
		{
			oldBuf->setUsed(oldBuf->getSize());
			oldBuf->linkNext(newBuf);
		}

		task->putDirtyBuffer(oldBuf);
	}

	item->m_buffer = newBuf;
	tdgbl->mvol_io_buffer = p;					// buffer start
	tdgbl->mvol_io_data = p;					// current record start
	tdgbl->gbl_io_ptr = p + used;					// current write pointer
	tdgbl->gbl_io_cnt = newBuf->getSize() - used;	// space left at buffer

	return newBuf;
}

void BackupRelationTask::releaseBuffer(Item& item)