Method handler

src/jrd/idx.cpp:447–760

};

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

	ThreadContextHolder tdbb(NULL);
	tdbb->tdbb_flags = m_tdbb_flags;

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

	try {

	WorkerContextHolder holder(tdbb, FB_FUNCTION);

	Database* dbb = tdbb->getDatabase();
	Attachment* attachment = tdbb->getAttachment();
	jrd_rel* relation = MET_relation(tdbb, m_creation->relation->rel_id);
	if (!(relation->rel_flags & REL_scanned))
		MET_scan_relation(tdbb, relation);

	index_desc* idx = &item->m_idx;
	jrd_tra* transaction = item->m_tra ? item->m_tra : m_creation->transaction;
	Sort* scb = item->m_sort;

	RecordStack stack;
	record_param primary, secondary;
	secondary.rpb_relation = relation;
	primary.rpb_relation   = relation;
	primary.rpb_number.setValue(BOF_NUMBER);
	//primary.getWindow(tdbb).win_flags = secondary.getWindow(tdbb).win_flags = 0; redundant

	IndexErrorContext context(relation, idx, m_creation->index_name);

	// If scan is finished, do final sort pass over own sort
	if (item->m_ppSequence == m_countPP)
	{
		//fb_assert((scb->scb_flags & scb_sorted) == 0);

		if (item->m_ownAttach && idx->idx_expression_statement)
		{
			idx->idx_expression_statement->release(tdbb);
			idx->idx_expression_statement = NULL;
		}

		if (!m_stop && m_creation->duplicates.value() == 0)
			scb->sort(tdbb);

		if (!m_stop && m_creation->duplicates.value() > 0)
		{
			AutoPtr<Record> error_record;
			primary.rpb_record = NULL;
			fb_assert(m_creation->dup_recno >= 0);
			primary.rpb_number.setValue(m_creation->dup_recno);

			if (DPM_get(tdbb, &primary, LCK_read))