aboutsummaryrefslogtreecommitdiffstats
path: root/storage/src/tests/storageserver/statemanagertest.cpp
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@broadpark.no>2021-01-20 10:50:38 +0100
committerTor Egge <Tor.Egge@broadpark.no>2021-01-20 10:50:38 +0100
commit13691cfa6d95bd663588f04f58e87a36eee68e48 (patch)
tree4edac6be0d2c1294e67e9cb8c905fd6f8153b50b /storage/src/tests/storageserver/statemanagertest.cpp
parent47cebacad17e3760d0235e360a45a5d2e02a6419 (diff)
Add ServiceLayerHostInfoReporter.
Diffstat (limited to 'storage/src/tests/storageserver/statemanagertest.cpp')
-rw-r--r--storage/src/tests/storageserver/statemanagertest.cpp15
1 files changed, 15 insertions, 0 deletions
diff --git a/storage/src/tests/storageserver/statemanagertest.cpp b/storage/src/tests/storageserver/statemanagertest.cpp
index b55e62d5fd3..1a9882bd0fa 100644
--- a/storage/src/tests/storageserver/statemanagertest.cpp
+++ b/storage/src/tests/storageserver/statemanagertest.cpp
@@ -316,6 +316,21 @@ TEST_F(StateManagerTest, immediate_node_state_replying_is_tracked_per_controller
ASSERT_EQ(0, _upper->getNumReplies());
}
+TEST_F(StateManagerTest, request_almost_immediate_replies_triggers_fast_reply)
+{
+ mark_reported_node_state_up();
+ mark_reply_observed_from_n_controllers(1);
+ auto before = std::chrono::steady_clock::now();
+ for (size_t pass = 0; pass < 100; ++pass) {
+ send_down_get_node_state_request(0);
+ _manager->request_almost_immediate_node_state_replies();
+ _upper->waitForMessage(api::MessageType::GETNODESTATE_REPLY, 2);
+ clear_sent_replies();
+ }
+ auto after = std::chrono::steady_clock::now();
+ ASSERT_GT(10s, after - before);
+}
+
TEST_F(StateManagerTest, activation_command_is_bounced_with_current_cluster_state_version) {
force_current_cluster_state_version(12345);