ReplicatedPG: use append for write and writefull

Signed-off-by: Samuel Just <sam.just@inktank.com>

diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
index 2e2a36e0e2ad2d000091006ee89133aab7296249..4d81303dd90848f0059e6eb219e855d084af38ae 100644 (file)
--- a/src/osd/ReplicatedPG.cc
+++ b/src/osd/ReplicatedPG.cc
@@ -3518,7 +3518,11 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
        result = check_offset_and_length(op.extent.offset, op.extent.length, cct->_conf->osd_max_object_size);
        if (result < 0)
          break;
-       t->write(soid, op.extent.offset, op.extent.length, osd_op.indata);
+       if (pool.info.ec_pool()) {
+         t->append(soid, op.extent.offset, op.extent.length, osd_op.indata);
+       } else {
+         t->write(soid, op.extent.offset, op.extent.length, osd_op.indata);
+       }
        write_update_size_and_usage(ctx->delta_stats, oi, ssc->snapset, ctx->modified_ranges,
                                    op.extent.offset, op.extent.length, true);
        if (!obs.exists) {
@@ -3548,7 +3552,7 @@ int ReplicatedPG::do_osd_ops(OpContext *ctx, vector<OSDOp>& ops)
            }
          }
          ctx->mod_desc.create();
-         t->write(soid, op.extent.offset, op.extent.length, osd_op.indata);
+         t->append(soid, op.extent.offset, op.extent.length, osd_op.indata);
          if (obs.exists) {
            t->setattrs(soid, ctx->obc->attr_cache);
          }