crimson/os/seastore/cached_extent: add on_replace_prior interface

Signed-off-by: Xuehan Xu <xxhdx1985126@gmail.com>
(cherry picked from commit c56af30a9c199b4a5d2cba9d2208b8c1d8a6abfb)

diff --git a/src/crimson/os/seastore/cache.cc b/src/crimson/os/seastore/cache.cc
index 8209e374994048bef1f3e212ce42ccde57796e60..ebeb123cf5e43d370f322a9c99af97d0195ac83b 100644 (file)
--- a/src/crimson/os/seastore/cache.cc
+++ b/src/crimson/os/seastore/cache.cc
@@ -802,6 +802,7 @@ void Cache::commit_replace_extent(
     add_to_dirty(next);
   }
 
+  next->on_replace_prior(t);
   invalidate_extent(t, *prev);
 }
 

diff --git a/src/crimson/os/seastore/cached_extent.h b/src/crimson/os/seastore/cached_extent.h
index f79eb3e644ee98f8da9a7739900077c88896e33d..0245044955139b2bb23c9133d510f419c025837a 100644 (file)
--- a/src/crimson/os/seastore/cached_extent.h
+++ b/src/crimson/os/seastore/cached_extent.h
@@ -232,6 +232,16 @@ public:
    */
   virtual void on_delta_write(paddr_t record_block_offset) {}
 
+  /**
+   * on_replace_prior
+   *
+   * Called after the extent has replaced a previous one. State
+   * of the extent must be MUTATION_PENDING. Implementation
+   * may use this call to synchronize states that must be synchronized
+   * with the states of Cache and can't wait till transaction
+   * completes.
+   */
+  virtual void on_replace_prior(Transaction &t) {}
   /**
    * get_type
    *