Method getWorkItem

src/burp/BurpTasks.cpp:233–288

}

bool BackupRelationTask::getWorkItem(BackupRelationTask::WorkItem** pItem)
{
	Item* item = static_cast<Item*>(*pItem);

	MutexLockGuard guard(m_mutex, FB_FUNCTION);

	// if writer ask for new item - its done
	if (item && item->m_writer)
	{
		item->m_inuse = false;
		(*pItem) = NULL;
		return false;
	}

	const bool newReader = (item == NULL);

	if (item == NULL && !m_readDone)
	{
		for (Item** p = m_items.begin(); p < m_items.end(); p++)
		{
			if (!(*p)->m_inuse)
			{
				(*p)->m_inuse = true;
				*pItem = item = *p;
				break;
			}
		}
	}

	if (!item)
		return false;

	if (item->m_writer)
		return true;

	item->m_inuse = (m_nextPP <= m_relation->rel_max_pp);

	if (item->m_inuse)
	{
		item->m_ppSequence = m_nextPP;
		if (m_metadata.haveInputs())
			m_nextPP += 1;
		else
			m_nextPP = m_relation->rel_max_pp + 1;

		if (newReader)
			m_readers++;
	}
	else if (!newReader && --m_readers == 0)
	{
		m_readDone = true;
		m_dirtyCond.notifyAll();
	}

	return (item && item->m_inuse);
}

bool BackupRelationTask::getResult(IStatus* /*status*/)