diff options
Diffstat (limited to 'storage/src/tests/distributor/bucketdbupdatertest.cpp')
-rw-r--r-- | storage/src/tests/distributor/bucketdbupdatertest.cpp | 25 |
1 files changed, 0 insertions, 25 deletions
diff --git a/storage/src/tests/distributor/bucketdbupdatertest.cpp b/storage/src/tests/distributor/bucketdbupdatertest.cpp index 56f88b7f98f..53f80854bef 100644 --- a/storage/src/tests/distributor/bucketdbupdatertest.cpp +++ b/storage/src/tests/distributor/bucketdbupdatertest.cpp @@ -61,7 +61,6 @@ class BucketDBUpdaterTest : public CppUnit::TestFixture, CPPUNIT_TEST(testDistributorChangeWithGrouping); CPPUNIT_TEST(testNormalUsageInitializing); // Check that we send request bucket info when storage node is initializing, and send another when it's up. CPPUNIT_TEST(testFailedRequestBucketInfo); - CPPUNIT_TEST(testEncodeErrorHandling); CPPUNIT_TEST(testBitChange); // Check what happens when distribution bits change CPPUNIT_TEST(testNodeDown); CPPUNIT_TEST(testStorageNodeInMaintenanceClearsBucketsForNode); @@ -123,7 +122,6 @@ protected: void testDistributorChangeWithGrouping(); void testNormalUsageInitializing(); void testFailedRequestBucketInfo(); - void testEncodeErrorHandling(); void testNoResponses(); void testBitChange(); void testInconsistentChecksum(); @@ -811,29 +809,6 @@ BucketDBUpdaterTest::testFailedRequestBucketInfo() } void -BucketDBUpdaterTest::testEncodeErrorHandling() -{ - setSystemState(lib::ClusterState("distributor:1 .0.s:i storage:1")); - - CPPUNIT_ASSERT_EQUAL(_bucketSpaces.size(), _sender.commands.size()); - - // Not yet passing on system state. - CPPUNIT_ASSERT_EQUAL(size_t(0), _senderDown.commands.size()); - for (uint32_t i = 0; i < _bucketSpaces.size(); ++i) { - std::shared_ptr<api::RequestBucketInfoReply> reply = - getFakeBucketReply(lib::ClusterState("distributor:1 .0.s:i storage:1"), - *((RequestBucketInfoCommand*)_sender.commands[i].get()), - 0, - 10); - - reply->setResult(api::ReturnCode::ENCODE_ERROR); - getBucketDBUpdater().onRequestBucketInfoReply(reply); - } - CPPUNIT_ASSERT_EQUAL(std::string("Set system state"), - _senderDown.getCommands()); -} - -void BucketDBUpdaterTest::testDownWhileInit() { setStorageNodes(3); |