From 19fcec84d8d7d21e796c7624e521b60d28ee21ed Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 7 Apr 2024 20:45:59 +0200 Subject: Adding upstream version 16.2.11+ds. Signed-off-by: Daniel Baumann --- src/client/ObjecterWriteback.h | 72 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 72 insertions(+) create mode 100644 src/client/ObjecterWriteback.h (limited to 'src/client/ObjecterWriteback.h') diff --git a/src/client/ObjecterWriteback.h b/src/client/ObjecterWriteback.h new file mode 100644 index 000000000..7a159e80e --- /dev/null +++ b/src/client/ObjecterWriteback.h @@ -0,0 +1,72 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab +#ifndef CEPH_OSDC_OBJECTERWRITEBACKHANDLER_H +#define CEPH_OSDC_OBJECTERWRITEBACKHANDLER_H + +#include "osdc/Objecter.h" +#include "osdc/WritebackHandler.h" + +class ObjecterWriteback : public WritebackHandler { + public: + ObjecterWriteback(Objecter *o, Finisher *fin, ceph::mutex *lock) + : m_objecter(o), + m_finisher(fin), + m_lock(lock) { } + ~ObjecterWriteback() override {} + + void read(const object_t& oid, uint64_t object_no, + const object_locator_t& oloc, uint64_t off, uint64_t len, + snapid_t snapid, bufferlist *pbl, uint64_t trunc_size, + __u32 trunc_seq, int op_flags, + const ZTracer::Trace &parent_trace, + Context *onfinish) override { + m_objecter->read_trunc(oid, oloc, off, len, snapid, pbl, 0, + trunc_size, trunc_seq, + new C_OnFinisher(new C_Lock(m_lock, onfinish), + m_finisher)); + } + + bool may_copy_on_write(const object_t& oid, uint64_t read_off, + uint64_t read_len, snapid_t snapid) override { + return false; + } + + ceph_tid_t write(const object_t& oid, const object_locator_t& oloc, + uint64_t off, uint64_t len, + const SnapContext& snapc, const bufferlist &bl, + ceph::real_time mtime, uint64_t trunc_size, + __u32 trunc_seq, ceph_tid_t journal_tid, + const ZTracer::Trace &parent_trace, + Context *oncommit) override { + return m_objecter->write_trunc(oid, oloc, off, len, snapc, bl, mtime, 0, + trunc_size, trunc_seq, + new C_OnFinisher(new C_Lock(m_lock, + oncommit), + m_finisher)); + } + + bool can_scattered_write() override { return true; } + using WritebackHandler::write; + ceph_tid_t write(const object_t& oid, const object_locator_t& oloc, + vector >& io_vec, + const SnapContext& snapc, ceph::real_time mtime, + uint64_t trunc_size, __u32 trunc_seq, + Context *oncommit) override { + ObjectOperation op; + for (vector >::iterator p = io_vec.begin(); + p != io_vec.end(); + ++p) + op.write(p->first, p->second, trunc_size, trunc_seq); + + return m_objecter->mutate(oid, oloc, op, snapc, mtime, 0, + new C_OnFinisher(new C_Lock(m_lock, oncommit), + m_finisher)); + } + + private: + Objecter *m_objecter; + Finisher *m_finisher; + ceph::mutex *m_lock; +}; + +#endif -- cgit v1.2.3