diff options
author | Tor Egge <Tor.Egge@oath.com> | 2017-10-18 12:36:24 +0000 |
---|---|---|
committer | Tor Egge <Tor.Egge@oath.com> | 2017-10-18 12:36:24 +0000 |
commit | 00673fd58679212a69a5f51ff255a90c2fff9271 (patch) | |
tree | b75044ce6c4c2d5bf759ee024b55c95b07cc57f3 /storage/src/tests/storageserver | |
parent | 8530d49ee9f6e4e6cf613d59bc454d39082046b3 (diff) |
Remove DocBlockCommand and DocBlockReply from storage api.
Diffstat (limited to 'storage/src/tests/storageserver')
-rw-r--r-- | storage/src/tests/storageserver/documentapiconvertertest.cpp | 72 |
1 files changed, 0 insertions, 72 deletions
diff --git a/storage/src/tests/storageserver/documentapiconvertertest.cpp b/storage/src/tests/storageserver/documentapiconvertertest.cpp index ff261e88922..224dc8b9a9b 100644 --- a/storage/src/tests/storageserver/documentapiconvertertest.cpp +++ b/storage/src/tests/storageserver/documentapiconvertertest.cpp @@ -52,8 +52,6 @@ struct DocumentApiConverterTest : public CppUnit::TestFixture void testCreateVisitorReplyLastBucket(); void testDestroyVisitor(); void testVisitorInfo(); - void testDocBlock(); - void testDocBlockWithKeepTimeStamps(); void testMultiOperation(); void testBatchDocumentUpdate(); @@ -68,8 +66,6 @@ struct DocumentApiConverterTest : public CppUnit::TestFixture CPPUNIT_TEST(testCreateVisitorReplyLastBucket); CPPUNIT_TEST(testDestroyVisitor); CPPUNIT_TEST(testVisitorInfo); - CPPUNIT_TEST(testDocBlock); - CPPUNIT_TEST(testDocBlockWithKeepTimeStamps); CPPUNIT_TEST(testMultiOperation); CPPUNIT_TEST(testBatchDocumentUpdate); CPPUNIT_TEST_SUITE_END(); @@ -270,74 +266,6 @@ DocumentApiConverterTest::testVisitorInfo() } void -DocumentApiConverterTest::testDocBlock() -{ - Document::SP doc(new Document(_html_type, DocumentId(DocIdString("test", "test")))); - - char buffer[10000]; - vdslib::WritableDocumentList docBlock(_repo, buffer, sizeof(buffer)); - docBlock.addPut(*doc, 100); - - document::BucketIdFactory fac; - document::BucketId bucketId = fac.getBucketId(doc->getId()); - bucketId.setUsedBits(32); - - api::DocBlockCommand dbcmd(bucketId, docBlock, std::shared_ptr<void>()); - dbcmd.setTimeout(123456); - - std::unique_ptr<mbus::Message> mbusmsg = _converter->toDocumentAPI(dbcmd, _repo); - - documentapi::MultiOperationMessage* mbusdb = dynamic_cast<documentapi::MultiOperationMessage*>(mbusmsg.get()); - CPPUNIT_ASSERT(mbusdb); - - CPPUNIT_ASSERT_EQUAL((uint64_t)123456, mbusdb->getTimeRemaining()); - - const vdslib::DocumentList& list = mbusdb->getOperations(); - CPPUNIT_ASSERT_EQUAL((uint32_t)1, list.size()); - CPPUNIT_ASSERT_EQUAL(*doc, *dynamic_cast<document::Document*>(list.begin()->getDocument().get())); - - std::unique_ptr<mbus::Reply> reply = mbusdb->createReply(); - CPPUNIT_ASSERT(reply.get()); - - std::unique_ptr<storage::api::StorageReply> rep = - _converter->toStorageAPI(static_cast<documentapi::DocumentReply&>(*reply), dbcmd); - api::DocBlockReply* pr = dynamic_cast<api::DocBlockReply*>(rep.get()); - CPPUNIT_ASSERT(pr); -} - - -void -DocumentApiConverterTest::testDocBlockWithKeepTimeStamps() -{ - char buffer[10000]; - vdslib::WritableDocumentList docBlock(_repo, buffer, sizeof(buffer)); - api::DocBlockCommand dbcmd(document::BucketId(0), docBlock, std::shared_ptr<void>()); - - { - CPPUNIT_ASSERT_EQUAL(dbcmd.keepTimeStamps(), false); - - std::unique_ptr<mbus::Message> mbusmsg = _converter->toDocumentAPI(dbcmd, _repo); - - documentapi::MultiOperationMessage* mbusdb = dynamic_cast<documentapi::MultiOperationMessage*>(mbusmsg.get()); - CPPUNIT_ASSERT(mbusdb); - CPPUNIT_ASSERT_EQUAL(mbusdb->keepTimeStamps(), false); - } - - { - dbcmd.keepTimeStamps(true); - CPPUNIT_ASSERT_EQUAL(dbcmd.keepTimeStamps(), true); - - std::unique_ptr<mbus::Message> mbusmsg = _converter->toDocumentAPI(dbcmd, _repo); - - documentapi::MultiOperationMessage* mbusdb = dynamic_cast<documentapi::MultiOperationMessage*>(mbusmsg.get()); - CPPUNIT_ASSERT(mbusdb); - CPPUNIT_ASSERT_EQUAL(mbusdb->keepTimeStamps(), true); - } - -} - - -void DocumentApiConverterTest::testMultiOperation() { //create a document |