Method watcherThread

src/jrd/ProfilerManager.cpp:1019–1104

}

void ProfilerListener::watcherThread()
{
	bool startup = true;
	auto& sharedMemory = ipc->sharedMemory;
	const auto header = sharedMemory->getHeader();

	fb_assert(header->tag == ProfilerIpc::Tag::NOP);
	header->tag = ProfilerIpc::Tag::SERVER_STARTED;

	try
	{
		while (!exiting)
		{
			const SLONG value = sharedMemory->eventClear(&header->serverEvent);

			if (startup)
			{
				startup = false;
				startupSemaphore.release();
			}
			else
			{
				fb_assert(header->tag >= ProfilerIpc::Tag::FIRST_CLIENT_OP);

				try
				{
					FbLocalStatus statusVector;
					EngineContextHolder tdbb(&statusVector, attachment->getInterface(), FB_FUNCTION);

					processCommand(tdbb);
					header->tag = ProfilerIpc::Tag::RESPONSE;
				}
				catch (const status_exception& e)
				{
					//// TODO: Serialize status vector instead of formated message.

					const ISC_STATUS* status = e.value();
					string errorMsg;
					TEXT temp[BUFFER_LARGE];

					while (fb_interpret(temp, sizeof(temp), &status))
					{
						if (errorMsg.hasData())
							errorMsg += "\n\t";

						errorMsg += temp;
					}

					header->bufferSize = MIN(errorMsg.length(), sizeof(header->buffer) - 1);
					strncpy((char*) header->buffer, errorMsg.c_str(), sizeof(header->buffer));
					header->buffer[header->bufferSize] = '\0';

					header->tag = ProfilerIpc::Tag::EXCEPTION;
				}

				sharedMemory->eventPost(&header->clientEvent);
			}