Method processCommand

src/jrd/ProfilerManager.cpp:1106–1196

}

void ProfilerListener::processCommand(thread_db* tdbb)
{
	const auto header = ipc->sharedMemory->getHeader();
	const auto profilerManager = attachment->getProfilerManager(tdbb);

	if (header->userName[0] && attachment->getUserName() != header->userName)
		status_exception::raise(Arg::Gds(isc_miss_prvlg) << "PROFILE_ANY_ATTACHMENT");

	using Tag = ProfilerIpc::Tag;

	switch (header->tag)
	{
		case Tag::CANCEL_SESSION:
			profilerManager->cancelSession();
			header->bufferSize = 0;
			break;

		case Tag::DISCARD:
			profilerManager->discard();
			header->bufferSize = 0;
			break;

		case Tag::FINISH_SESSION:
		{
			const auto in = reinterpret_cast<const ProfilerPackage::FinishSessionInput::Type*>(header->buffer);
			fb_assert(sizeof(*in) == header->bufferSize);
			profilerManager->finishSession(tdbb, in->flush);
			header->bufferSize = 0;
			break;
		}

		case Tag::FLUSH:
			profilerManager->flush();
			header->bufferSize = 0;
			break;

		case Tag::PAUSE_SESSION:
		{
			const auto in = reinterpret_cast<const ProfilerPackage::PauseSessionInput::Type*>(header->buffer);
			fb_assert(sizeof(*in) == header->bufferSize);
			profilerManager->pauseSession(in->flush);
			header->bufferSize = 0;
			break;
		}

		case Tag::RESUME_SESSION:
			profilerManager->resumeSession();
			header->bufferSize = 0;
			break;

		case Tag::SET_FLUSH_INTERVAL:
		{
			const auto in = reinterpret_cast<const ProfilerPackage::SetFlushIntervalInput::Type*>(header->buffer);
			fb_assert(sizeof(*in) == header->bufferSize);

			profilerManager->setFlushInterval(in->flushInterval);
			header->bufferSize = 0;
			break;