Method extractNewKeys

src/remote/server/server.cpp:7650–7706

}

bool SrvAuthBlock::extractNewKeys(CSTRING* to, ULONG flags)
{
	lastExtractedKeys.reset();

	if (!(flags & ONLY_CLEANUP))
	{
		for (unsigned n = 0; n < newKeys.getCount(); ++n)
		{
			const PathName& t = newKeys[n]->keyName;
			PathName plugins = knownCryptKeyTypes()[t];
			if (plugins.hasData())
			{
				lastExtractedKeys.insertString(TAG_KEY_TYPE, t);
				lastExtractedKeys.insertString(TAG_KEY_PLUGINS, plugins);

				if (port->port_protocol < PROTOCOL_VERSION16)
					continue;

				for (CryptKeyTypeManager::SpecificPlugins sp(knownCryptKeyTypes().getSpecific(t)); sp.hasData(); sp.next())
				{
					PathName plugin = sp.get();
					GetPlugins<IWireCryptPlugin> cp(IPluginManager::TYPE_WIRE_CRYPT, plugin.c_str());
					fb_assert(cp.hasData());
					if (cp.hasData())
					{
						LocalStatus ls;
						CheckStatusWrapper st(&ls);
						unsigned l;
						const unsigned char* d = cp.plugin()->getSpecificData(&st, t.c_str(), &l);
						check(&st, isc_wish_list);
						if (d)
						{
							port->addSpecificData(t, plugin, l, d);

							plugin += '\0';
							plugin.append(reinterpret_cast<const char*>(d), l);
							lastExtractedKeys.insertString(TAG_PLUGIN_SPECIFIC, plugin);
						}
					}
				}
			}
		}

		if ((flags & EXTRACT_PLUGINS_LIST) && (dataFromPlugin.getCount() == 0))
		{
			lastExtractedKeys.insertString(TAG_KNOWN_PLUGINS, pluginList);
		}
	}

	to->cstr_length = (ULONG) lastExtractedKeys.getBufferLength();
	to->cstr_address = const_cast<UCHAR*>(lastExtractedKeys.getBuffer());
	to->cstr_allocated = 0;

	newKeys.clear();		// Very important - avoids sending same key type more than once

	return to->cstr_length > 0;
}