Method prepareRecSource

src/jrd/ProfilerManager.cpp:505–594

}

void ProfilerManager::prepareRecSource(thread_db* tdbb, Request* request, const AccessPath* recordSource)
{
	auto profileStatement = getStatement(request);

	if (!profileStatement)
		return;

	if (profileStatement->recSourceSequence.exist(recordSource->getRecSourceId()))
		return;

	fb_assert(profileStatement->definedCursors.exist(recordSource->getCursorId()));

	struct PlanItem : PermanentStorage
	{
		explicit PlanItem(MemoryPool& p)
			: PermanentStorage(p)
		{
		}

		const AccessPath* recordSource = nullptr;
		const AccessPath* parentRecordSource = nullptr;
		string accessPath{getPool()};
		unsigned level = 0;
	};

	ObjectsArray<PlanItem> planItems;
	planItems.add().recordSource = recordSource;

	for (unsigned pos = 0; pos < planItems.getCount(); ++pos)
	{
		auto& planItem = planItems[pos];
		const auto thisRsb = planItem.recordSource;

		string& accessPath = planItem.accessPath;
		thisRsb->print(tdbb, accessPath, true, 0, false);

		constexpr auto INDENT_MARKER = "\n    ";
		constexpr unsigned INDENT_COUNT = 4;

		if (accessPath.find(INDENT_MARKER) == 0)
		{
			unsigned pos = 0;

			do {
				accessPath.erase(pos + 1, 4);
			} while ((pos = accessPath.find(INDENT_MARKER, pos + 1)) != string::npos);
		}

		if (accessPath.hasData() && accessPath[0] == '\n')
			accessPath.erase(0, 1);

		Array<const RecordSource*> children;
		thisRsb->getChildren(children);

		unsigned level = planItem.level;

		if (const auto lastLinePos = accessPath.find_last_of('\n'); lastLinePos != string::npos)
			level += (accessPath.find_first_not_of(' ', lastLinePos + 1) - lastLinePos + 1) / INDENT_COUNT;