Function testPolicy

fdbrpc/ReplicationUtils.cpp:551–617

}

bool testPolicy(Reference<LocalitySet> servers,
                Reference<IReplicationPolicy> const& policy,
                std::vector<LocalityEntry> const& including,
                bool validate) {
	LocalityMap<repTestType>* serverMap = (LocalityMap<repTestType>*)servers.getPtr();
	std::string outputText, includeText;
	std::vector<LocalityEntry> entryResults;
	std::vector<repTestType*> results;
	bool valid, solved;

	if (g_replicationdebug > 1) {
		printf("Policy test:   include:%4lu  policy: %-10s => %s\n",
		       including.size(),
		       policy->name().c_str(),
		       policy->info().c_str());
	}
	if (g_replicationdebug > 2) {
		for (auto& entry : including) {
			printf("   also:  %s\n", servers->getEntryInfo(entry).c_str());
		}
	}

	solved = serverMap->selectReplicas(policy, including, entryResults, results);

	if (g_replicationdebug > 1) {
		printf("%-10s solution:%3lu  policy: %-10s => %s    include:%4lu\n",
		       ((solved) ? "Solved" : "Unsolved"),
		       results.size(),
		       policy->name().c_str(),
		       policy->info().c_str(),
		       including.size());
	}
	if (g_replicationdebug > 2) {
		for (auto& entry : entryResults) {
			printf("   item:  %s\n", servers->getEntryInfo(entry).c_str());
		}
		for (auto& entry : including) {
			printf("   also:  %s\n", servers->getEntryInfo(entry).c_str());
		}
	}

	valid = (validate) ? policy->validateFull(solved, entryResults, including, servers) : true;

	if (g_replicationdebug > 0) {
		if (including.size()) {
			includeText = " with ";
			for (auto& entry : including) {
				includeText += " " + servers->getEntryInfo(entry);
			}
		}

		if (results.size()) {
			outputText = policy->info() + includeText + " -> ";
			int count = 0;
			for (auto& entry : entryResults) {
				outputText += " " + *results[count] + "-" + servers->getEntryInfo(entry);
				count++;
			}