Method internalServiceAttach

src/yvalve/why.cpp:6697–6775

Attach and probably start a service through the first available subsystem.

// Attach and probably start a service through the first available subsystem.
IService* Dispatcher::internalServiceAttach(CheckStatusWrapper* status, const PathName& svcName,
	ClumpletReader& spb, std::function<void(CheckStatusWrapper*, IService*)> start,
	IProvider** retProvider)
{
	IService* service = NULL;

	// Build correct config
	RefPtr<const Config> config(Config::getDefaultConfig());
	if (spb.find(isc_spb_config))
	{
		string spb_config;
		spb.getString(spb_config);
		Config::merge(config, &spb_config);
	}

	FbLocalStatus temp1, temp2;
	CheckStatusWrapper* currentStatus = &temp1;

	for (GetPlugins<IProvider> providerIterator(IPluginManager::TYPE_PROVIDER, config);
		 providerIterator.hasData();
		 providerIterator.next())
	{
		IProvider* p = providerIterator.plugin();

		if (cryptCallback)
		{
			p->setDbCryptCallback(currentStatus, cryptCallback);
			if (currentStatus->getState() & IStatus::STATE_ERRORS)
				continue;
		}

		service = p->attachServiceManager(currentStatus, svcName.c_str(),
			spb.getBufferLength(), spb.getBuffer());

		if (!(currentStatus->getState() & IStatus::STATE_ERRORS))
		{
			start(currentStatus, service);

			if (!(currentStatus->getState() & IStatus::STATE_ERRORS))
			{
				fb_utils::copyStatus(status, currentStatus);
				if (retProvider)
				{
					p->addRef();
					*retProvider = p;
				}

				return service;
			}
		}

		switch (currentStatus->getErrors()[1])
		{
			case isc_service_att_err:
				currentStatus = &temp2;
				// fall down...
			case isc_unavailable:
			case isc_wrong_ods: