aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-06-23 15:07:01 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2021-06-23 15:07:01 +0000
commit9782c49d43e2b9669d88a44cfbfc2fc1465c8b00 (patch)
tree4aeb6edf817d97a9769f183cced21b0dfe3e99f5
parentc62cacfcf3092ebb3cb473574d793015e27a3a71 (diff)
Use equality operators.
-rw-r--r--searchcore/src/tests/proton/server/memory_flush_config_updater/memory_flush_config_updater_test.cpp46
-rw-r--r--searchcore/src/vespa/searchcore/proton/server/memory_flush_config_updater.cpp2
-rw-r--r--searchcore/src/vespa/searchcore/proton/server/memoryflush.h2
3 files changed, 36 insertions, 14 deletions
diff --git a/searchcore/src/tests/proton/server/memory_flush_config_updater/memory_flush_config_updater_test.cpp b/searchcore/src/tests/proton/server/memory_flush_config_updater/memory_flush_config_updater_test.cpp
index 0e06e5d28ed..46de8479d1d 100644
--- a/searchcore/src/tests/proton/server/memory_flush_config_updater/memory_flush_config_updater_test.cpp
+++ b/searchcore/src/tests/proton/server/memory_flush_config_updater/memory_flush_config_updater_test.cpp
@@ -75,33 +75,53 @@ TEST_F("require that strategy is updated when setting new config", Fixture)
TEST_DO(f.assertStrategyConfig(6, 3, 30));
}
+void
+expectEqual(const MemoryFlush::Config & a, const MemoryFlush::Config & b) {
+ EXPECT_TRUE(a.equal(b));
+ EXPECT_TRUE(a == b);
+ EXPECT_FALSE( a != b);
+ EXPECT_TRUE(b.equal(a));
+ EXPECT_TRUE(b == a);
+ EXPECT_FALSE( b != a);
+}
+
+void
+expectNotEqual(const MemoryFlush::Config & a, const MemoryFlush::Config & b) {
+ EXPECT_FALSE(a.equal(b));
+ EXPECT_FALSE(a == b);
+ EXPECT_TRUE( a != b);
+ EXPECT_FALSE(b.equal(a));
+ EXPECT_FALSE(b == a);
+ EXPECT_TRUE( b != a);
+}
+
TEST("require that MemoryFlush::Config equal is correct") {
MemoryFlush::Config a, b;
- EXPECT_TRUE(a.equal(b) && b.equal(a));
+ expectEqual(a, b);;
a.maxGlobalMemory = 7;
- EXPECT_FALSE(a.equal(b) || b.equal(a));
+ expectNotEqual(a, b);
b.maxGlobalMemory = 7;
- EXPECT_TRUE(a.equal(b) && b.equal(a));
+ expectEqual(a, b);;
a.maxMemoryGain = 8;
- EXPECT_FALSE(a.equal(b) || b.equal(a));
+ expectNotEqual(a, b);
b.maxMemoryGain = 8;
- EXPECT_TRUE(a.equal(b) && b.equal(a));
+ expectEqual(a, b);;
a.maxGlobalTlsSize = 9;
- EXPECT_FALSE(a.equal(b) || b.equal(a));
+ expectNotEqual(a, b);
b.maxGlobalTlsSize = 9;
- EXPECT_TRUE(a.equal(b) && b.equal(a));
+ expectEqual(a, b);;
a.maxTimeGain = 10us;
- EXPECT_FALSE(a.equal(b) || b.equal(a));
+ expectNotEqual(a, b);
b.maxTimeGain = 10us;
- EXPECT_TRUE(a.equal(b) && b.equal(a));
+ expectEqual(a, b);;
a.globalDiskBloatFactor = 11;
- EXPECT_FALSE(a.equal(b) || b.equal(a));
+ expectNotEqual(a, b);
b.globalDiskBloatFactor = 11;
- EXPECT_TRUE(a.equal(b) && b.equal(a));
+ expectEqual(a, b);;
a.diskBloatFactor = 12;
- EXPECT_FALSE(a.equal(b) || b.equal(a));
+ expectNotEqual(a, b);
b.diskBloatFactor = 12;
- EXPECT_TRUE(a.equal(b) && b.equal(a));
+ expectEqual(a, b);;
}
TEST("require that we use configured memory limits") {
diff --git a/searchcore/src/vespa/searchcore/proton/server/memory_flush_config_updater.cpp b/searchcore/src/vespa/searchcore/proton/server/memory_flush_config_updater.cpp
index 1600ec21756..b842820bfe1 100644
--- a/searchcore/src/vespa/searchcore/proton/server/memory_flush_config_updater.cpp
+++ b/searchcore/src/vespa/searchcore/proton/server/memory_flush_config_updater.cpp
@@ -75,7 +75,7 @@ MemoryFlushConfigUpdater::updateFlushStrategy(const LockGuard &guard, const char
considerUseConservativeDiskMode(guard, newConfig);
considerUseConservativeMemoryMode(guard, newConfig);
MemoryFlush::Config currentConfig = _flushStrategy->getConfig();
- if ( ! currentConfig.equal(newConfig) ) {
+ if ( currentConfig != newConfig ) {
_flushStrategy->setConfig(newConfig);
LOG(info, "Due to %s (conservative-disk=%d, conservative-memory=%d, retired=%d) flush config updated to "
"global-disk-bloat(%1.2f), max-tls-size(%" PRIu64 "),"
diff --git a/searchcore/src/vespa/searchcore/proton/server/memoryflush.h b/searchcore/src/vespa/searchcore/proton/server/memoryflush.h
index 1fac4800d95..1e8d1b1f08c 100644
--- a/searchcore/src/vespa/searchcore/proton/server/memoryflush.h
+++ b/searchcore/src/vespa/searchcore/proton/server/memoryflush.h
@@ -34,6 +34,8 @@ public:
uint64_t maxMemoryGain_in,
double diskBloatFactor_in,
vespalib::duration maxTimeGain_in);
+ bool operator == (const Config & rhs) const { return equal(rhs); }
+ bool operator != (const Config & rhs) const { return ! equal(rhs); }
bool equal(const Config & rhs) const {
return (maxGlobalMemory == rhs.maxGlobalMemory) &&
(maxGlobalTlsSize == rhs.maxGlobalTlsSize) &&