diff options
Diffstat (limited to 'src/mongo/s/stale_exception_test.cpp')
-rw-r--r-- | src/mongo/s/stale_exception_test.cpp | 20 |
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 |