Method handler

src/jrd/vio.cpp:407–505

bool SweepTask::handler(WorkItem& _item)
{
	Item* item = reinterpret_cast<Item*>(&_item);

	ThreadContextHolder tdbb(NULL);

	if (!item->init(tdbb))
	{
		setError(tdbb->tdbb_status_vector, true);
		return false;
	}

	WorkerContextHolder wrkHolder(tdbb, FB_FUNCTION);

	record_param rpb;
	jrd_rel* relation = NULL;

	try
	{
		RelInfo* relInfo = item->m_relInfo;

		Database* dbb = tdbb->getDatabase();
		Attachment* att = tdbb->getAttachment();

		/*relation = (*att->att_relations)[relInfo->rel_id];
		if (relation)*/
			relation = MET_lookup_relation_id(tdbb, relInfo->rel_id, false);

		if (relation &&
			!(relation->rel_flags & (REL_deleted | REL_deleting)) &&
			!relation->isTemporary() &&
			relation->getPages(tdbb)->rel_pages)
		{
			jrd_rel::GCShared gcGuard(tdbb, relation);
			if (!gcGuard.gcEnabled())
			{
				string str;
				str.printf("Acquire garbage collection lock failed (%s)", relation->rel_name.c_str());
				status_exception::raise(Arg::Gds(isc_random) << Arg::Str(str));
			}

			jrd_tra* tran = tdbb->getTransaction();

			if (relInfo->countPP == 0)
				relInfo->countPP = relation->getPages(tdbb)->rel_pages->count();

			rpb.rpb_relation = relation;
			rpb.rpb_org_scans = relation->rel_scan_count++;
			rpb.rpb_record = NULL;
			rpb.rpb_stream_flags = RPB_s_no_data | RPB_s_sweeper;
			rpb.getWindow(tdbb).win_flags = WIN_large_scan;

			rpb.rpb_number.compose(dbb->dbb_max_records, dbb->dbb_dp_per_pp, 0, 0, item->m_firstPP);
			rpb.rpb_number.decrement();

			RecordNumber lastRecNo;
			lastRecNo.compose(dbb->dbb_max_records, dbb->dbb_dp_per_pp, 0, 0, item->m_lastPP + 1);
			lastRecNo.decrement();