Method IndexCreateTask

src/jrd/idx.cpp:215–264

	const ULONG IS_LARGE_SCAN	= 0x02;		// relation not fits into page cache

	IndexCreateTask(thread_db* tdbb, MemoryPool* pool, IndexCreation* creation) : Task(),
		m_pool(pool),
		m_dbb(tdbb->getDatabase()),
		m_tdbb_flags(tdbb->tdbb_flags),
		m_flags(0),
		m_creation(creation),
		m_items(*m_pool),
		m_stop(false),
		m_countPP(0),
		m_nextPP(0)
	{
		Attachment* att = tdbb->getAttachment();

		if (att->isGbak())
			m_flags |= IS_GBAK;

		m_exprBlob.clear();
		m_condBlob.clear();

		int workers = 1;
		if (att->att_parallel_workers > 0)
			workers = att->att_parallel_workers;

		// Classic in single-user shutdown mode can't create additional worker attachments
		if ((m_dbb->dbb_ast_flags & DBB_shutdown_single) && !(m_dbb->dbb_flags & DBB_shared))
			workers = 1;

		for (int i = 0; i < workers; i++)
			m_items.add(FB_NEW_POOL(*m_pool) Item(this));

		m_items[0]->m_ownAttach = false;
		m_items[0]->m_attStable = att->getStable();
		m_items[0]->m_tra = m_creation->transaction;

		if (m_creation)
		{
			// Unless this is the only attachment or a database restore, worry about
			// preserving the page working sets of other attachments.
			if (att && (att != m_dbb->dbb_attachments || att->att_next))
			{
				if (att->isGbak() || DPM_data_pages(tdbb, m_creation->relation) > m_dbb->dbb_bcb->bcb_count)
					m_flags |= IS_LARGE_SCAN;
			}

			m_countPP = DPM_pointer_pages(tdbb, m_creation->relation);

			if ((m_creation->index->idx_flags & (idx_expression | idx_condition)) && (workers > 1))
				MET_lookup_index_expr_cond_blr(tdbb, m_creation->index_name, m_exprBlob, m_condBlob);
		}
	}

	virtual ~IndexCreateTask()
	{