1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
3 #ifndef CEPH_OSDC_OBJECTERWRITEBACKHANDLER_H
4 #define CEPH_OSDC_OBJECTERWRITEBACKHANDLER_H
6 #include "osdc/Objecter.h"
7 #include "osdc/WritebackHandler.h"
9 class ObjecterWriteback : public WritebackHandler {
11 ObjecterWriteback(Objecter *o, Finisher *fin, Mutex *lock)
15 ~ObjecterWriteback() override {}
17 void read(const object_t& oid, uint64_t object_no,
18 const object_locator_t& oloc, uint64_t off, uint64_t len,
19 snapid_t snapid, bufferlist *pbl, uint64_t trunc_size,
20 __u32 trunc_seq, int op_flags,
21 const ZTracer::Trace &parent_trace,
22 Context *onfinish) override {
23 m_objecter->read_trunc(oid, oloc, off, len, snapid, pbl, 0,
24 trunc_size, trunc_seq,
25 new C_OnFinisher(new C_Lock(m_lock, onfinish),
29 bool may_copy_on_write(const object_t& oid, uint64_t read_off,
30 uint64_t read_len, snapid_t snapid) override {
34 ceph_tid_t write(const object_t& oid, const object_locator_t& oloc,
35 uint64_t off, uint64_t len,
36 const SnapContext& snapc, const bufferlist &bl,
37 ceph::real_time mtime, uint64_t trunc_size,
38 __u32 trunc_seq, ceph_tid_t journal_tid,
39 const ZTracer::Trace &parent_trace,
40 Context *oncommit) override {
41 return m_objecter->write_trunc(oid, oloc, off, len, snapc, bl, mtime, 0,
42 trunc_size, trunc_seq,
43 new C_OnFinisher(new C_Lock(m_lock,
48 bool can_scattered_write() override { return true; }
49 using WritebackHandler::write;
50 ceph_tid_t write(const object_t& oid, const object_locator_t& oloc,
51 vector<pair<uint64_t, bufferlist> >& io_vec,
52 const SnapContext& snapc, ceph::real_time mtime,
53 uint64_t trunc_size, __u32 trunc_seq,
54 Context *oncommit) override {
56 for (vector<pair<uint64_t, bufferlist> >::iterator p = io_vec.begin();
59 op.write(p->first, p->second, trunc_size, trunc_seq);
61 return m_objecter->mutate(oid, oloc, op, snapc, mtime, 0,
62 new C_OnFinisher(new C_Lock(m_lock, oncommit),