crimson/os/cyanstore: handle OP_ZERO

Signed-off-by: Kefu Chai <kchai@redhat.com>

diff --git a/src/crimson/os/cyanstore/cyan_store.cc b/src/crimson/os/cyanstore/cyan_store.cc
index 3d362dd675a8407358c8d6ee71c9919a87e5a50d..ec1bc5ce4bf319a01d9e6cc00d7ed45a44b52b2b 100644 (file)
--- a/src/crimson/os/cyanstore/cyan_store.cc
+++ b/src/crimson/os/cyanstore/cyan_store.cc
@@ -350,6 +350,15 @@ seastar::future<> CyanStore::do_transaction(CollectionRef ch,
         r = _write(cid, oid, off, len, bl, fadvise_flags);
       }
       break;
+      case Transaction::OP_ZERO:
+      {
+        coll_t cid = i.get_cid(op->cid);
+        ghobject_t oid = i.get_oid(op->oid);
+        uint64_t off = op->off;
+        uint64_t len = op->len;
+        r = _zero(cid, oid, off, len);
+      }
+      break;
       case Transaction::OP_TRUNCATE:
       {
         coll_t cid = i.get_cid(op->cid);
@@ -512,6 +521,17 @@ int CyanStore::_write(const coll_t& cid, const ghobject_t& oid,
   return 0;
 }
 
+int CyanStore::_zero(const coll_t& cid, const ghobject_t& oid,
+                     uint64_t offset, size_t len)
+{
+  logger().debug("{} {} {} {} ~ {}",
+                __func__, cid, oid, offset, len);
+
+  ceph::buffer::list bl;
+  bl.append_zero(len);
+  return _write(cid, oid, offset, len, bl, 0);
+}
+
 int CyanStore::_omap_clear(
   const coll_t& cid,
   const ghobject_t& oid)

diff --git a/src/crimson/os/cyanstore/cyan_store.h b/src/crimson/os/cyanstore/cyan_store.h
index 71569d8154e11c27269fcfdad8338b1b56ae85e3..86678042f305fdbded609d546e3c3b606612c164 100644 (file)
--- a/src/crimson/os/cyanstore/cyan_store.h
+++ b/src/crimson/os/cyanstore/cyan_store.h
@@ -151,6 +151,8 @@ private:
   int _write(const coll_t& cid, const ghobject_t& oid,
             uint64_t offset, size_t len, const ceph::bufferlist& bl,
             uint32_t fadvise_flags);
+  int _zero(const coll_t& cid, const ghobject_t& oid,
+           uint64_t offset, size_t len);
   int _omap_clear(
     const coll_t& cid,
     const ghobject_t& oid);