X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fclient%2FObjecterWriteback.h;fp=src%2Fceph%2Fsrc%2Fclient%2FObjecterWriteback.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=8928437646ce2ee8d6a605f43e4be095811b058d;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/client/ObjecterWriteback.h b/src/ceph/src/client/ObjecterWriteback.h deleted file mode 100644 index 8928437..0000000 --- a/src/ceph/src/client/ObjecterWriteback.h +++ /dev/null @@ -1,72 +0,0 @@ -// -*- 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, 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; - Mutex *m_lock; -}; - -#endif