You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@geode.apache.org by bb...@apache.org on 2021/10/12 22:08:40 UTC
[geode-native] branch develop updated: Fix build break (#882)
This is an automated email from the ASF dual-hosted git repository.
bbender pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/geode-native.git
The following commit(s) were added to refs/heads/develop by this push:
new 63425fe Fix build break (#882)
63425fe is described below
commit 63425fea82a8f51c6b06fc3a8f98136061988499
Author: Blake Bender <bb...@pivotal.io>
AuthorDate: Tue Oct 12 15:08:36 2021 -0700
Fix build break (#882)
- changes to Cluster ctor crossed paths on the way into develop with a
change that added some new tests
---
.../integration/test/FunctionExecutionTest.cpp | 30 +++++++++++-----------
1 file changed, 15 insertions(+), 15 deletions(-)
diff --git a/cppcache/integration/test/FunctionExecutionTest.cpp b/cppcache/integration/test/FunctionExecutionTest.cpp
index 74df4db..bc509b8 100644
--- a/cppcache/integration/test/FunctionExecutionTest.cpp
+++ b/cppcache/integration/test/FunctionExecutionTest.cpp
@@ -212,11 +212,11 @@ void waitUntilPRMetadataIsRefreshed(CacheImpl *cacheImpl) {
}
TEST(FunctionExecutionTest, FunctionExecutionWithIncompleteBucketLocations) {
- std::vector<uint16_t> serverPorts;
- serverPorts.push_back(Framework::getAvailablePort());
- serverPorts.push_back(Framework::getAvailablePort());
- serverPorts.push_back(Framework::getAvailablePort());
- Cluster cluster{LocatorCount{1}, ServerCount{3}, serverPorts};
+ Cluster cluster{
+ InitialLocators{{{"localhost", Framework::getAvailablePort()}}},
+ InitialServers{{{"localhost", Framework::getAvailablePort()},
+ {"localhost", Framework::getAvailablePort()},
+ {"localhost", Framework::getAvailablePort()}}}};
cluster.start([&]() {
cluster.getGfsh()
@@ -304,11 +304,11 @@ const std::vector<std::string> serverResultsToStrings(
}
TEST(FunctionExecutionTest, testThatFunctionExecutionThrowsExceptionNonHA) {
- std::vector<uint16_t> serverPorts;
- serverPorts.push_back(Framework::getAvailablePort());
- serverPorts.push_back(Framework::getAvailablePort());
- serverPorts.push_back(Framework::getAvailablePort());
- Cluster cluster{LocatorCount{1}, ServerCount{3}, serverPorts};
+ Cluster cluster{
+ InitialLocators{{{"localhost", Framework::getAvailablePort()}}},
+ InitialServers{{{"localhost", Framework::getAvailablePort()},
+ {"localhost", Framework::getAvailablePort()},
+ {"localhost", Framework::getAvailablePort()}}}};
cluster.start([&]() {
cluster.getGfsh()
@@ -362,11 +362,11 @@ TEST(FunctionExecutionTest, testThatFunctionExecutionThrowsExceptionNonHA) {
TEST(FunctionExecutionTest,
testThatFunctionExecutionThrowsExceptionNonHAWithFilter) {
- std::vector<uint16_t> serverPorts;
- serverPorts.push_back(Framework::getAvailablePort());
- serverPorts.push_back(Framework::getAvailablePort());
- serverPorts.push_back(Framework::getAvailablePort());
- Cluster cluster{LocatorCount{1}, ServerCount{3}, serverPorts};
+ Cluster cluster{
+ InitialLocators{{{"localhost", Framework::getAvailablePort()}}},
+ InitialServers{{{"localhost", Framework::getAvailablePort()},
+ {"localhost", Framework::getAvailablePort()},
+ {"localhost", Framework::getAvailablePort()}}}};
cluster.start([&]() {
cluster.getGfsh()