Method closeAttachment

src/jrd/ExtEngineManager.cpp:1270–1325

void ExtEngineManager::closeAttachment(thread_db* tdbb, Attachment* attachment)
{
	EnginesMap enginesCopy;

	{	// scope
		ReadLockGuard readGuard(enginesLock, FB_FUNCTION);

		EnginesMap::Accessor accessor(&engines);
		for (bool found = accessor.getFirst(); found; found = accessor.getNext())
			enginesCopy.put(accessor.current()->first, accessor.current()->second);
	}

	EngineCheckout cout(tdbb, FB_FUNCTION, EngineCheckout::UNNECESSARY);

	EnginesMap::Accessor accessor(&enginesCopy);
	for (bool found = accessor.getFirst(); found; found = accessor.getNext())
	{
		IExternalEngine* engine = accessor.current()->second;
		EngineAttachmentInfo* attInfo = getEngineAttachment(tdbb, engine, true);

		if (attInfo)
		{
			{	// scope
				ContextManager<IExternalFunction> ctxManager(tdbb, attInfo, attInfo->adminCharSet);
				FbLocalStatus status;
				engine->closeAttachment(&status, attInfo->context);	//// FIXME: log status

				// Check whether a non-SYSTEM engine is used by other attachments.
				// If no one uses, release it.
				if (engine != SystemEngine::INSTANCE)
				{
					bool close = true;
					WriteLockGuard writeGuard(enginesLock, FB_FUNCTION);

					EnginesAttachmentsMap::Accessor ea_accessor(&enginesAttachments);
					for (bool ea_found = ea_accessor.getFirst(); ea_found; ea_found = ea_accessor.getNext())
					{
						if (ea_accessor.current()->first.engine == engine)
						{
							close = false; // engine is in use, no need to release
							break;
						}
					}

					if (close)
					{
						if (engines.remove(accessor.current()->first)) // If engine has already been deleted - nothing to do
							PluginManagerInterfacePtr()->releasePlugin(engine);
					}
				}
			}

			delete attInfo;
		}
	}
}