Merge pull request #79 from Derecho-Project/delta_core_fix

Implement bytes_size for DeltaStoreCore's DeltaType
Derecho-Project · Dec 13, 2024 · ad9cd03 · ad9cd03
2 parents 963d4df + f315a87
commit ad9cd03
Showing 1 changed file with 8 additions and 2 deletions.
diff --git a/include/cascade/detail/delta_store_core_impl.hpp b/include/cascade/detail/delta_store_core_impl.hpp
@@ -39,8 +39,14 @@ void DeltaCascadeStoreCore<KT, VT, IK, IV>::DeltaType::post_object(
 
 template <typename KT, typename VT, KT* IK, VT* IV>
 std::size_t DeltaCascadeStoreCore<KT, VT, IK, IV>::DeltaType::bytes_size() const {
-    dbg_default_warn("{} should not be called. It is not designed for serialization.",__PRETTY_FUNCTION__);
-    return 0;
+    size_t delta_size = 0;
+    if (objects.size() > 0) {
+        delta_size += mutils::bytes_size(static_cast<std::size_t>(objects.size()));
+        for (const auto& kv_pair : objects) {
+            delta_size += mutils::bytes_size(kv_pair.second);
+        }
+    }
+    return delta_size;
 }
 
 template <typename KT, typename VT, KT* IK, VT* IV>