summaryrefslogtreecommitdiff
path: root/src/mongo/s/stale_exception_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/s/stale_exception_test.cpp')
-rw-r--r--src/mongo/s/stale_exception_test.cpp20
1 files changed, 19 insertions, 1 deletions
diff --git a/src/mongo/s/stale_exception_test.cpp b/src/mongo/s/stale_exception_test.cpp
index 1e92988516d..a91f52edd8f 100644
--- a/src/mongo/s/stale_exception_test.cpp
+++ b/src/mongo/s/stale_exception_test.cpp
@@ -54,7 +54,7 @@ TEST(StaleExceptionTest, StaleConfigInfoSerializationTest) {
ASSERT_EQUALS(deserializedInfo->getShardId(), kShardId);
}
-TEST(StaleExceptionTest, StaleEpochInfoSerializationTest) {
+TEST(StaleExceptionTest, StaleEpochInfoLegacySerializationTest) {
StaleEpochInfo info(kNss);
// Serialize
@@ -66,6 +66,24 @@ TEST(StaleExceptionTest, StaleEpochInfoSerializationTest) {
std::static_pointer_cast<const StaleEpochInfo>(StaleEpochInfo::parse(bob.obj()));
ASSERT_EQUALS(deserializedInfo->getNss(), kNss);
+ ASSERT(!deserializedInfo->getVersionReceived());
+ ASSERT(!deserializedInfo->getVersionWanted());
+}
+
+TEST(StaleExceptionTest, StaleEpochInfoSerializationTest) {
+ StaleEpochInfo info(kNss, ShardVersion::UNSHARDED(), ShardVersion::UNSHARDED());
+
+ // Serialize
+ BSONObjBuilder bob;
+ info.serialize(&bob);
+
+ // Deserialize
+ auto deserializedInfo =
+ std::static_pointer_cast<const StaleEpochInfo>(StaleEpochInfo::parse(bob.obj()));
+
+ ASSERT_EQ(deserializedInfo->getNss(), kNss);
+ ASSERT_EQ(deserializedInfo->getVersionReceived(), ShardVersion::UNSHARDED());
+ ASSERT_EQ(deserializedInfo->getVersionWanted(), ShardVersion::UNSHARDED());
}
} // namespace