diff options
Diffstat (limited to 'documentapi/src/tests/policies/policies_test.cpp')
-rw-r--r-- | documentapi/src/tests/policies/policies_test.cpp | 48 |
1 files changed, 24 insertions, 24 deletions
diff --git a/documentapi/src/tests/policies/policies_test.cpp b/documentapi/src/tests/policies/policies_test.cpp index 0c659f589d6..02bd6b297d0 100644 --- a/documentapi/src/tests/policies/policies_test.cpp +++ b/documentapi/src/tests/policies/policies_test.cpp @@ -4,13 +4,13 @@ #include <vespa/documentapi/documentapi.h> #include <vespa/documentapi/messagebus/policies/andpolicy.h> +#include <vespa/documentapi/messagebus/policies/contentpolicy.h> #include <vespa/documentapi/messagebus/policies/documentrouteselectorpolicy.h> #include <vespa/documentapi/messagebus/policies/errorpolicy.h> #include <vespa/documentapi/messagebus/policies/externpolicy.h> #include <vespa/documentapi/messagebus/policies/loadbalancerpolicy.h> #include <vespa/documentapi/messagebus/policies/localservicepolicy.h> #include <vespa/documentapi/messagebus/policies/roundrobinpolicy.h> -#include <vespa/documentapi/messagebus/policies/storagepolicy.h> #include <vespa/documentapi/messagebus/policies/subsetservicepolicy.h> #include <vespa/messagebus/emptyreply.h> #include <vespa/messagebus/routing/routingnode.h> @@ -51,7 +51,7 @@ private: private: bool trySelect(TestFrame &frame, uint32_t numSelects, const std::vector<string> &expected); void setupExternPolicy(TestFrame &frame, mbus::Slobrok &slobrok, const string &pattern, int32_t numEntries = -1); - StoragePolicy &setupStoragePolicy(TestFrame &frame, const string ¶m, + ContentPolicy &setupContentPolicy(TestFrame &frame, const string ¶m, const string &pattern = "", int32_t numEntries = -1); bool isErrorPolicy(const string &name, const string ¶m); void assertMirrorReady(const IMirrorAPI &mirror); @@ -83,10 +83,10 @@ public: void requireThatExternPolicyWithUnknownPatternSelectsNone(); void requireThatExternPolicySelectsFromExternSlobrok(); void requireThatExternPolicyMergesOneReplyAsProtocol(); - void requireThatStoragePolicyWithIllegalParamIsAnErrorPolicy(); - void requireThatStoragePolicyIsRandomWithoutState(); - void requireThatStoragePolicyIsTargetedWithState(); - void requireThatStoragePolicyCombinesSystemAndSlobrokState(); + void requireThatContentPolicyWithIllegalParamIsAnErrorPolicy(); + void requireThatContentPolicyIsRandomWithoutState(); + void requireThatContentPolicyIsTargetedWithState(); + void requireThatContentPolicyCombinesSystemAndSlobrokState(); }; TEST_APPHOOK(Test); @@ -128,10 +128,10 @@ Test::Main() { requireThatExternPolicySelectsFromExternSlobrok(); TEST_FLUSH(); requireThatExternPolicyMergesOneReplyAsProtocol(); TEST_FLUSH(); - requireThatStoragePolicyWithIllegalParamIsAnErrorPolicy(); TEST_FLUSH(); - requireThatStoragePolicyIsRandomWithoutState(); TEST_FLUSH(); - requireThatStoragePolicyIsTargetedWithState(); TEST_FLUSH(); - requireThatStoragePolicyCombinesSystemAndSlobrokState(); TEST_FLUSH(); + requireThatContentPolicyWithIllegalParamIsAnErrorPolicy(); TEST_FLUSH(); + requireThatContentPolicyIsRandomWithoutState(); TEST_FLUSH(); + requireThatContentPolicyIsTargetedWithState(); TEST_FLUSH(); + requireThatContentPolicyCombinesSystemAndSlobrokState(); TEST_FLUSH(); TEST_DONE(); } @@ -782,15 +782,15 @@ void Test::testLoadBalancer() { } void -Test::requireThatStoragePolicyWithIllegalParamIsAnErrorPolicy() +Test::requireThatContentPolicyWithIllegalParamIsAnErrorPolicy() { - EXPECT_TRUE(isErrorPolicy("Storage", "")); - EXPECT_TRUE(isErrorPolicy("Storage", "config=foo;slobroks=foo")); - EXPECT_TRUE(isErrorPolicy("Storage", "slobroks=foo")); + EXPECT_TRUE(isErrorPolicy("Content", "")); + EXPECT_TRUE(isErrorPolicy("Content", "config=foo;slobroks=foo")); + EXPECT_TRUE(isErrorPolicy("Content", "slobroks=foo")); } void -Test::requireThatStoragePolicyIsRandomWithoutState() +Test::requireThatContentPolicyIsRandomWithoutState() { TestFrame frame(_repo); frame.setMessage(newPutDocumentMessage("id:ns:testdoc::")); @@ -808,7 +808,7 @@ Test::requireThatStoragePolicyIsRandomWithoutState() string param = vespalib::make_string( "cluster=mycluster;slobroks=tcp/localhost:%d;clusterconfigid=%s;syncinit", slobrok.port(), getDefaultDistributionConfig(2, 5).c_str()); - StoragePolicy &policy = setupStoragePolicy( + ContentPolicy &policy = setupContentPolicy( frame, param, "storage/cluster.mycluster/distributor/*/default", 5); ASSERT_TRUE(policy.getSystemState() == nullptr); @@ -826,15 +826,15 @@ Test::requireThatStoragePolicyIsRandomWithoutState() } } -StoragePolicy & -Test::setupStoragePolicy(TestFrame &frame, const string ¶m, +ContentPolicy & +Test::setupContentPolicy(TestFrame &frame, const string ¶m, const string &pattern, int32_t numEntries) { - frame.setHop(mbus::HopSpec("test", vespalib::make_string("[Storage:%s]", param.c_str()))); + frame.setHop(mbus::HopSpec("test", vespalib::make_string("[Content:%s]", param.c_str()))); mbus::MessageBus &mbus = frame.getMessageBus(); const mbus::HopBlueprint *hop = mbus.getRoutingTable(DocumentProtocol::NAME)->getHop("test"); const mbus::PolicyDirective dir = static_cast<mbus::PolicyDirective&>(*hop->getDirective(0)); - StoragePolicy &policy = static_cast<StoragePolicy&>(*mbus.getRoutingPolicy(DocumentProtocol::NAME, + ContentPolicy &policy = static_cast<ContentPolicy&>(*mbus.getRoutingPolicy(DocumentProtocol::NAME, dir.getName(), dir.getParam())); policy.initSynchronous(); assertMirrorReady(*policy.getMirror()); @@ -845,7 +845,7 @@ Test::setupStoragePolicy(TestFrame &frame, const string ¶m, } void -Test::requireThatStoragePolicyIsTargetedWithState() +Test::requireThatContentPolicyIsTargetedWithState() { TestFrame frame(_repo); frame.setMessage(newPutDocumentMessage("id:ns:testdoc::")); @@ -863,7 +863,7 @@ Test::requireThatStoragePolicyIsTargetedWithState() string param = vespalib::make_string( "cluster=mycluster;slobroks=tcp/localhost:%d;clusterconfigid=%s;syncinit", slobrok.port(), getDefaultDistributionConfig(2, 5).c_str()); - StoragePolicy &policy = setupStoragePolicy( + ContentPolicy &policy = setupContentPolicy( frame, param, "storage/cluster.mycluster/distributor/*/default", 5); ASSERT_TRUE(policy.getSystemState() == nullptr); @@ -888,7 +888,7 @@ Test::requireThatStoragePolicyIsTargetedWithState() } void -Test::requireThatStoragePolicyCombinesSystemAndSlobrokState() +Test::requireThatContentPolicyCombinesSystemAndSlobrokState() { TestFrame frame(_repo); frame.setMessage(newPutDocumentMessage("id:ns:testdoc::")); @@ -902,7 +902,7 @@ Test::requireThatStoragePolicyCombinesSystemAndSlobrokState() string param = vespalib::make_string( "cluster=mycluster;slobroks=tcp/localhost:%d;clusterconfigid=%s;syncinit", slobrok.port(), getDefaultDistributionConfig(2, 5).c_str()); - StoragePolicy &policy = setupStoragePolicy( + ContentPolicy &policy = setupContentPolicy( frame, param, "storage/cluster.mycluster/distributor/*/default", 1); ASSERT_TRUE(policy.getSystemState() == nullptr); |