diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-04-28 15:16:53 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-04-28 15:16:53 +0000 |
commit | 87789913698f4fd12c4bc81b6a731325f32fce02 (patch) | |
tree | 098ac83c1eead7b7c682bc8b13898b6a36e27169 /storage/src/tests | |
parent | 9370479561c4098775ca3c6ae3985eb563ce050d (diff) |
getReplySP => stealReplySP
Diffstat (limited to 'storage/src/tests')
-rw-r--r-- | storage/src/tests/persistence/mergehandlertest.cpp | 8 | ||||
-rw-r--r-- | storage/src/tests/persistence/processalltest.cpp | 4 |
2 files changed, 6 insertions, 6 deletions
diff --git a/storage/src/tests/persistence/mergehandlertest.cpp b/storage/src/tests/persistence/mergehandlertest.cpp index 3b3846c3278..45226995e46 100644 --- a/storage/src/tests/persistence/mergehandlertest.cpp +++ b/storage/src/tests/persistence/mergehandlertest.cpp @@ -230,7 +230,7 @@ MergeHandlerTest::testGetBucketDiffChain(bool midChain) LOG(debug, "Verifying that get bucket diff is sent on"); api::GetBucketDiffCommand cmd(_bucket, _nodes, _maxTimestamp); MessageTracker::UP tracker1 = handler.handleGetBucketDiff(cmd, *_context); - api::StorageMessage::SP replySent = tracker1->getReplySP(); + api::StorageMessage::SP replySent = tracker1->stealReplySP(); if (midChain) { LOG(debug, "Check state"); @@ -279,7 +279,7 @@ MergeHandlerTest::testApplyBucketDiffChain(bool midChain) LOG(debug, "Verifying that apply bucket diff is sent on"); api::ApplyBucketDiffCommand cmd(_bucket, _nodes, _maxTimestamp); MessageTracker::UP tracker1 = handler.handleApplyBucketDiff(cmd, *_context); - api::StorageMessage::SP replySent = tracker1->getReplySP(); + api::StorageMessage::SP replySent = tracker1->stealReplySP(); if (midChain) { LOG(debug, "Check state"); @@ -724,7 +724,7 @@ TEST_F(MergeHandlerTest, entry_removed_after_get_bucket_diff) { auto tracker = handler.handleApplyBucketDiff(*applyBucketDiffCmd, *_context); - auto applyBucketDiffReply = std::dynamic_pointer_cast<api::ApplyBucketDiffReply>(tracker->getReplySP()); + auto applyBucketDiffReply = std::dynamic_pointer_cast<api::ApplyBucketDiffReply>(tracker->stealReplySP()); ASSERT_TRUE(applyBucketDiffReply.get()); auto& diff = applyBucketDiffReply->getDiff(); @@ -1149,7 +1149,7 @@ TEST_F(MergeHandlerTest, remove_put_on_existing_timestamp) { auto tracker = handler.handleApplyBucketDiff(*applyBucketDiffCmd, *_context); - auto applyBucketDiffReply = std::dynamic_pointer_cast<api::ApplyBucketDiffReply>(tracker->getReplySP()); + auto applyBucketDiffReply = std::dynamic_pointer_cast<api::ApplyBucketDiffReply>(tracker->stealReplySP()); ASSERT_TRUE(applyBucketDiffReply.get()); api::MergeBucketCommand cmd(_bucket, _nodes, _maxTimestamp); diff --git a/storage/src/tests/persistence/processalltest.cpp b/storage/src/tests/persistence/processalltest.cpp index e33e692b7d2..f7f52761609 100644 --- a/storage/src/tests/persistence/processalltest.cpp +++ b/storage/src/tests/persistence/processalltest.cpp @@ -29,7 +29,7 @@ TEST_F(ProcessAllHandlerTest, remove_location) { "DocEntry(2345, 1, id:mail:testdoctype1:n=4:4008.html)\n", dumpBucket(bucketId)); - auto reply = std::dynamic_pointer_cast<api::RemoveLocationReply>(tracker->getReplySP()); + auto reply = std::dynamic_pointer_cast<api::RemoveLocationReply>(tracker->stealReplySP()); ASSERT_TRUE(reply); EXPECT_EQ(2u, reply->documents_removed()); } @@ -62,7 +62,7 @@ TEST_F(ProcessAllHandlerTest, remove_location_document_subset) { "DocEntry(109, 0, Doc(id:mail:testdoctype1:n=4:6925.html))\n", dumpBucket(bucketId)); - auto reply = std::dynamic_pointer_cast<api::RemoveLocationReply>(tracker->getReplySP()); + auto reply = std::dynamic_pointer_cast<api::RemoveLocationReply>(tracker->stealReplySP()); ASSERT_TRUE(reply); EXPECT_EQ(5u, reply->documents_removed()); } |