summaryrefslogtreecommitdiff
path: root/cpp/test/IceGrid/replicaGroup/AllTests.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'cpp/test/IceGrid/replicaGroup/AllTests.cpp')
-rw-r--r--cpp/test/IceGrid/replicaGroup/AllTests.cpp134
1 files changed, 68 insertions, 66 deletions
diff --git a/cpp/test/IceGrid/replicaGroup/AllTests.cpp b/cpp/test/IceGrid/replicaGroup/AllTests.cpp
index ab0d3913df3..45b68bbb36e 100644
--- a/cpp/test/IceGrid/replicaGroup/AllTests.cpp
+++ b/cpp/test/IceGrid/replicaGroup/AllTests.cpp
@@ -15,7 +15,8 @@ using namespace Test;
using namespace IceGrid;
void
-instantiateServer(const AdminPrx& admin, const string& templ, const string& node, const map<string, string>& params,
+instantiateServer(const shared_ptr<AdminPrx>& admin, const string& templ, const string& node,
+ const map<string, string>& params,
const string& application = string("Test"), bool startServer = true)
{
ServerInstanceDescriptor desc;
@@ -61,7 +62,7 @@ instantiateServer(const AdminPrx& admin, const string& templ, const string& node
}
void
-removeServer(const AdminPrx& admin, const string& id)
+removeServer(const shared_ptr<AdminPrx>& admin, const string& id)
{
try
{
@@ -102,20 +103,20 @@ removeServer(const AdminPrx& admin, const string& id)
void
allTests(Test::TestHelper* helper)
{
- Ice::CommunicatorPtr comm = helper->communicator();
- IceGrid::RegistryPrx registry = IceGrid::RegistryPrx::checkedCast(
+ auto comm = helper->communicator();
+ auto registry = Ice::checkedCast<IceGrid::RegistryPrx>(
comm->stringToProxy(comm->getDefaultLocator()->ice_getIdentity().category + "/Registry"));
test(registry);
- IceGrid::QueryPrx query = IceGrid::QueryPrx::checkedCast(
+ auto query = Ice::checkedCast<IceGrid::QueryPrx>(
comm->stringToProxy(comm->getDefaultLocator()->ice_getIdentity().category + "/Query"));
test(query);
- AdminSessionPrx session = registry->createAdminSession("foo", "bar");
+ auto session = registry->createAdminSession("foo", "bar");
session->ice_getConnection()->setACM(registry->getACMTimeout(),
IceUtil::None,
- Ice::ICE_ENUM(ACMHeartbeat, HeartbeatAlways));
+ Ice::ACMHeartbeat::HeartbeatAlways);
- AdminPrx admin = session->getAdmin();
+ auto admin = session->getAdmin();
test(admin);
set<string> serverReplicaIds;
@@ -138,33 +139,33 @@ allTests(Test::TestHelper* helper)
params["id"] = "Server3";
instantiateServer(admin, "Server", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("dummy@RoundRobin"));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("dummy@RoundRobin"));
Ice::ObjectProxySeq objs = query->findAllReplicas(obj);
test(objs.size() == 3);
test(serverReplicaIds.find(objs[0]->ice_getAdapterId()) != serverReplicaIds.end());
test(serverReplicaIds.find(objs[1]->ice_getAdapterId()) != serverReplicaIds.end());
test(serverReplicaIds.find(objs[2]->ice_getAdapterId()) != serverReplicaIds.end());
- obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("RoundRobin"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("RoundRobin"));
objs = query->findAllReplicas(obj);
test(objs.size() == 3);
test(serverReplicaIds.find(objs[0]->ice_getAdapterId()) != serverReplicaIds.end());
test(serverReplicaIds.find(objs[1]->ice_getAdapterId()) != serverReplicaIds.end());
test(serverReplicaIds.find(objs[2]->ice_getAdapterId()) != serverReplicaIds.end());
- obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("dummy@dummy"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("dummy@dummy"));
objs = query->findAllReplicas(obj);
test(objs.empty());
- obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("dummy@Server1.ReplicatedAdapter"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("dummy@Server1.ReplicatedAdapter"));
objs = query->findAllReplicas(obj);
test(objs.empty());
- obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("dummy:tcp"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("dummy:tcp"));
objs = query->findAllReplicas(obj);
test(objs.empty());
- obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("dummy@Ordered"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("dummy@Ordered"));
objs = query->findAllReplicas(obj);
test(objs.empty());
@@ -184,9 +185,9 @@ allTests(Test::TestHelper* helper)
instantiateServer(admin, "Server", "localnode", params);
params["id"] = "Server3";
instantiateServer(admin, "Server", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("RoundRobin"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("RoundRobin"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
try
{
test(obj->getReplicaIdAndShutdown() == "Server1.ReplicatedAdapter");
@@ -261,9 +262,9 @@ allTests(Test::TestHelper* helper)
params["replicaGroup"] = "RoundRobin";
params["id"] = "IceBox1";
instantiateServer(admin, "IceBox", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("RoundRobin"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("RoundRobin"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
try
{
test(obj->getReplicaIdAndShutdown() == "IceBox1.Service1.Service1");
@@ -292,7 +293,7 @@ allTests(Test::TestHelper* helper)
params["id"] = "Server3";
params["priority"] = "2";
instantiateServer(admin, "Server", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Ordered"));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Ordered"));
try
{
test(obj->getReplicaIdAndShutdown() == "Server2.ReplicatedAdapter");
@@ -315,9 +316,9 @@ allTests(Test::TestHelper* helper)
params["replicaGroup"] = "Ordered";
params["id"] = "IceBox1";
instantiateServer(admin, "IceBox", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Ordered"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Ordered"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
try
{
test(obj->getReplicaIdAndShutdown() == "IceBox1.Service3.Service3");
@@ -343,9 +344,9 @@ allTests(Test::TestHelper* helper)
instantiateServer(admin, "Server", "localnode", params);
params["id"] = "Server3";
instantiateServer(admin, "Server", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Random"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Random"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
set<string> replicaIds = serverReplicaIds;
while(!replicaIds.empty())
{
@@ -404,9 +405,9 @@ allTests(Test::TestHelper* helper)
params["replicaGroup"] = "Random";
params["id"] = "IceBox1";
instantiateServer(admin, "IceBox", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Random"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Random"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
set<string> replicaIds = svcReplicaIds;
while(!replicaIds.empty())
{
@@ -437,9 +438,9 @@ allTests(Test::TestHelper* helper)
instantiateServer(admin, "Server", "localnode", params);
params["id"] = "Server3";
instantiateServer(admin, "Server", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Adaptive"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Adaptive"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
set<string> replicaIds = serverReplicaIds;
while(!replicaIds.empty())
{
@@ -462,9 +463,9 @@ allTests(Test::TestHelper* helper)
params["replicaGroup"] = "Adaptive";
params["id"] = "IceBox1";
instantiateServer(admin, "IceBox", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Adaptive"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Adaptive"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
set<string> replicaIds = svcReplicaIds;
while(!replicaIds.empty())
{
@@ -496,14 +497,14 @@ allTests(Test::TestHelper* helper)
params["id"] = "Server3";
instantiateServer(admin, "IceBox1", "localnode", params);
- Ice::LocatorPrx locator = comm->getDefaultLocator();
+ auto locator = comm->getDefaultLocator();
Ice::Context ctx;
ctx["server"] = "Server3";
locator->ice_context(ctx);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Ordered-Filtered"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Ordered-Filtered"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
try
{
ctx["server"] = "Server3";
@@ -548,13 +549,13 @@ allTests(Test::TestHelper* helper)
ctx["server"] = "Server3";
test(query->ice_context(ctx)->findObjectByTypeOnLeastLoadedNode(
- "::Test::TestIntf2", LoadSample5)->ice_getAdapterId() == "Server3.Service.Service");
+ "::Test::TestIntf2", LoadSample::LoadSample5)->ice_getAdapterId() == "Server3.Service.Service");
ctx["server"] = "Server1";
test(query->ice_context(ctx)->findObjectByTypeOnLeastLoadedNode(
- "::Test::TestIntf2", LoadSample5)->ice_getAdapterId() == "Server1.ReplicatedAdapter");
+ "::Test::TestIntf2", LoadSample::LoadSample5)->ice_getAdapterId() == "Server1.ReplicatedAdapter");
ctx["server"] = "Server2";
test(query->ice_context(ctx)->findObjectByTypeOnLeastLoadedNode(
- "::Test::TestIntf2", LoadSample5)->ice_getAdapterId() == "Server2.ReplicatedAdapter");
+ "::Test::TestIntf2", LoadSample::LoadSample5)->ice_getAdapterId() == "Server2.ReplicatedAdapter");
ctx["server"] = "Server3";
test(query->ice_context(ctx)->findAllObjectsByType("::Test::TestIntf2")[0]->ice_getAdapterId() ==
@@ -582,7 +583,7 @@ allTests(Test::TestHelper* helper)
params["id"] = "UnknownServer";
instantiateServer(admin, "Server", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Unknown"));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Unknown"));
obj->getReplicaId();
removeServer(admin, "UnknownServer");
@@ -593,9 +594,9 @@ allTests(Test::TestHelper* helper)
params["id"] = "ExcludeServer";
instantiateServer(admin, "Server", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Exclude"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Exclude"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
try
{
obj->getReplicaId();
@@ -605,7 +606,7 @@ allTests(Test::TestHelper* helper)
{
}
- Ice::LocatorPrx locator = comm->getDefaultLocator();
+ auto locator = comm->getDefaultLocator();
try
{
Ice::Context ctx;
@@ -637,9 +638,9 @@ allTests(Test::TestHelper* helper)
cout << "testing load balancing n-replicas... " << flush;
{
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("RoundRobin-2"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(-1));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("RoundRobin-2"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(-1));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
try
{
obj->ice_ping();
@@ -714,9 +715,9 @@ allTests(Test::TestHelper* helper)
}
{
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("RoundRobin-All"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(-1));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("RoundRobin-All"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(-1));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
try
{
obj->ice_ping();
@@ -781,13 +782,14 @@ allTests(Test::TestHelper* helper)
instantiateServer(admin, "Server", "inactivenode", params);
params["id"] = "Server2";
instantiateServer(admin, "Server", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Random"));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Random"));
test(obj->getReplicaId() == "Server2.ReplicatedAdapter");
//
// Also make sure that findObjectByTypeOnLeastLoadedNode still work.
//
- obj = TestIntfPrx::uncheckedCast(query->findObjectByTypeOnLeastLoadedNode("::Test::TestIntf", LoadSample1));
+ obj = Ice::uncheckedCast<TestIntfPrx>(query->findObjectByTypeOnLeastLoadedNode("::Test::TestIntf",
+ LoadSample::LoadSample1));
test(obj->getReplicaId() == "Server2.ReplicatedAdapter");
removeServer(admin, "Server1");
@@ -798,7 +800,7 @@ allTests(Test::TestHelper* helper)
instantiateServer(admin, "Server", "inactivenode", params);
params["id"] = "Server2";
instantiateServer(admin, "Server", "localnode", params);
- obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("RoundRobin"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("RoundRobin"));
test(obj->getReplicaId() == "Server2.ReplicatedAdapter");
removeServer(admin, "Server1");
removeServer(admin, "Server2");
@@ -808,7 +810,7 @@ allTests(Test::TestHelper* helper)
instantiateServer(admin, "Server", "inactivenode", params);
params["id"] = "Server2";
instantiateServer(admin, "Server", "localnode", params);
- obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Adaptive"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Adaptive"));
test(obj->getReplicaId() == "Server2.ReplicatedAdapter");
removeServer(admin, "Server1");
removeServer(admin, "Server2");
@@ -818,7 +820,7 @@ allTests(Test::TestHelper* helper)
instantiateServer(admin, "IceBox", "localnode", params);
params["id"] = "Server1";
instantiateServer(admin, "Server", "inactivenode", params);
- obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Random"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Random"));
test(svcReplicaIds.find(obj->getReplicaId()) != svcReplicaIds.end());
removeServer(admin, "IceBox1");
removeServer(admin, "Server1");
@@ -875,9 +877,9 @@ allTests(Test::TestHelper* helper)
// Test has a replica group referenced by the Test1 application.
}
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("Random"));
- obj = TestIntfPrx::uncheckedCast(obj->ice_locatorCacheTimeout(0));
- obj = TestIntfPrx::uncheckedCast(obj->ice_connectionCached(false));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("Random"));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_locatorCacheTimeout(0));
+ obj = Ice::uncheckedCast<TestIntfPrx>(obj->ice_connectionCached(false));
set<string> replicaIds;
replicaIds.insert("Server1.ReplicatedAdapter");
replicaIds.insert("Server2.ReplicatedAdapter");
@@ -899,7 +901,7 @@ allTests(Test::TestHelper* helper)
ReplicaGroupDescriptor replicaGroup;
replicaGroup.id = "ReplicatedAdapterFromTest1";
- replicaGroup.loadBalancing = new RandomLoadBalancingPolicy();
+ replicaGroup.loadBalancing = make_shared<RandomLoadBalancingPolicy>();
replicaGroup.loadBalancing->nReplicas = "0";
update = ApplicationUpdateDescriptor();
update.name = "Test1";
@@ -978,7 +980,7 @@ allTests(Test::TestHelper* helper)
params["encoding"] = "1.0";
instantiateServer(admin, "Server", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy(*p));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy(*p));
obj = obj->ice_locatorCacheTimeout(0);
obj = obj->ice_connectionCached(false);
@@ -1021,7 +1023,7 @@ allTests(Test::TestHelper* helper)
params["encoding"] = "1.0";
instantiateServer(admin, "DynamicallyRegisteredServer", "localnode", params);
- TestIntfPrx obj = TestIntfPrx::uncheckedCast(comm->stringToProxy("DynamicRandom@DynamicRandom"));
+ auto obj = Ice::uncheckedCast<TestIntfPrx>(comm->stringToProxy("DynamicRandom@DynamicRandom"));
obj = obj->ice_locatorCacheTimeout(0);
obj = obj->ice_connectionCached(false);
obj = obj->ice_encodingVersion(Ice::Encoding_1_1);
@@ -1117,7 +1119,7 @@ allTests(Test::TestHelper* helper)
app.descriptor.nodes.clear();
ReplicaGroupDescriptor replicaGroup;
replicaGroup.id = "DynamicRandomRG";
- replicaGroup.loadBalancing = new RandomLoadBalancingPolicy("1");
+ replicaGroup.loadBalancing = make_shared<RandomLoadBalancingPolicy>("1");
app.descriptor.replicaGroups.push_back(replicaGroup);
try
{
generated by cgit v1.2.3 (git 2.46.0) at 2025-08-03 16:53:05 +0000