summaryrefslogtreecommitdiffstats
path: root/searchcore
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-04-11 18:28:01 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-04-11 18:28:01 +0000
commit0e42524451b070f4006ac26cef53d675cfd35686 (patch)
treee5dda67c9854159bded738b557c6c3a2ae481e98 /searchcore
parent769a19ddb4adb8f69cb5483dce27c07e5862357e (diff)
Add test for RemoveOperationWithGid
Diffstat (limited to 'searchcore')
-rw-r--r--searchcore/src/tests/proton/feedoperation/feedoperation_test.cpp30
1 files changed, 30 insertions, 0 deletions
diff --git a/searchcore/src/tests/proton/feedoperation/feedoperation_test.cpp b/searchcore/src/tests/proton/feedoperation/feedoperation_test.cpp
index f3ec7b4689f..5fffd70f11d 100644
--- a/searchcore/src/tests/proton/feedoperation/feedoperation_test.cpp
+++ b/searchcore/src/tests/proton/feedoperation/feedoperation_test.cpp
@@ -326,6 +326,36 @@ TEST_F("require that we can serialize and deserialize remove operations", Fixtur
}
}
+TEST_F("require that we can serialize and deserialize remove by gid operations", Fixture)
+{
+ vespalib::nbostream stream;
+ GlobalId gid = docId.getGlobalId();
+ BucketId bucket(toBucket(gid));
+ uint32_t expSerializedDocSize = 25;
+ vespalib::string expDocType = "testdoc_type";
+ EXPECT_NOT_EQUAL(0u, expSerializedDocSize);
+ {
+ RemoveOperationWithGid op(bucket, Timestamp(10), gid, expDocType);
+ op.setPrevDbDocumentId({3, 4});
+ EXPECT_EQUAL(0u, op.getSerializedDocSize());
+ op.serialize(stream);
+ EXPECT_EQUAL(expSerializedDocSize, op.getSerializedDocSize());
+ }
+ {
+ RemoveOperationWithGid op;
+ op.deserialize(stream, *f._repo);
+ EXPECT_EQUAL(gid, op.getGlobalId());
+ EXPECT_EQUAL(expDocType, op.getDocType());
+ EXPECT_EQUAL(bucket, op.getBucketId());
+ EXPECT_EQUAL(10u, op.getTimestamp().getValue());
+ EXPECT_EQUAL(expSerializedDocSize, op.getSerializedDocSize());
+ EXPECT_FALSE( op.getValidDbdId());
+ EXPECT_EQUAL(3u, op.getPrevSubDbId());
+ EXPECT_EQUAL(4u, op.getPrevLid());
+ EXPECT_TRUE(stream.empty());
+ }
+}
+
} // namespace
TEST_MAIN() { TEST_RUN_ALL(); }