X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fjournal%2FObjectRecorder.h;fp=src%2Fceph%2Fsrc%2Fjournal%2FObjectRecorder.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=22a46697c522d8442e598b724581550b143df5cb;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git

diff --git a/src/ceph/src/journal/ObjectRecorder.h b/src/ceph/src/journal/ObjectRecorder.h
deleted file mode 100644
index 22a4669..0000000
--- a/src/ceph/src/journal/ObjectRecorder.h
+++ /dev/null
@@ -1,164 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-
-#ifndef CEPH_JOURNAL_OBJECT_RECORDER_H
-#define CEPH_JOURNAL_OBJECT_RECORDER_H
-
-#include "include/Context.h"
-#include "include/rados/librados.hpp"
-#include "common/Cond.h"
-#include "common/Mutex.h"
-#include "common/RefCountedObj.h"
-#include "common/WorkQueue.h"
-#include "journal/FutureImpl.h"
-#include <list>
-#include <map>
-#include <set>
-#include <boost/intrusive_ptr.hpp>
-#include <boost/noncopyable.hpp>
-#include "include/assert.h"
-
-class SafeTimer;
-
-namespace journal {
-
-class ObjectRecorder;
-typedef boost::intrusive_ptr<ObjectRecorder> ObjectRecorderPtr;
-
-typedef std::pair<FutureImplPtr, bufferlist> AppendBuffer;
-typedef std::list<AppendBuffer> AppendBuffers;
-
-class ObjectRecorder : public RefCountedObject, boost::noncopyable {
-public:
-  struct Handler {
-    virtual ~Handler() {
-    }
-    virtual void closed(ObjectRecorder *object_recorder) = 0;
-    virtual void overflow(ObjectRecorder *object_recorder) = 0;
-  };
-
-  ObjectRecorder(librados::IoCtx &ioctx, const std::string &oid,
-                 uint64_t object_number, std::shared_ptr<Mutex> lock,
-                 ContextWQ *work_queue, SafeTimer &timer, Mutex &timer_lock,
-                 Handler *handler, uint8_t order, uint32_t flush_interval,
-                 uint64_t flush_bytes, double flush_age);
-  ~ObjectRecorder() override;
-
-  inline uint64_t get_object_number() const {
-    return m_object_number;
-  }
-  inline const std::string &get_oid() const {
-    return m_oid;
-  }
-
-  bool append_unlock(AppendBuffers &&append_buffers);
-  void flush(Context *on_safe);
-  void flush(const FutureImplPtr &future);
-
-  void claim_append_buffers(AppendBuffers *append_buffers);
-
-  bool is_closed() const {
-    assert(m_lock->is_locked());
-    return (m_object_closed && m_in_flight_appends.empty());
-  }
-  bool close();
-
-  inline CephContext *cct() const {
-    return m_cct;
-  }
-
-  inline size_t get_pending_appends() const {
-    Mutex::Locker locker(*m_lock);
-    return m_append_buffers.size();
-  }
-
-private:
-  typedef std::set<uint64_t> InFlightTids;
-  typedef std::map<uint64_t, AppendBuffers> InFlightAppends;
-
-  struct FlushHandler : public FutureImpl::FlushHandler {
-    ObjectRecorder *object_recorder;
-    FlushHandler(ObjectRecorder *o) : object_recorder(o) {}
-    void get() override {
-      object_recorder->get();
-    }
-    void put() override {
-      object_recorder->put();
-    }
-    void flush(const FutureImplPtr &future) override {
-      Mutex::Locker locker(*(object_recorder->m_lock));
-      object_recorder->flush(future);
-    }
-  };
-  struct C_AppendFlush : public Context {
-    ObjectRecorder *object_recorder;
-    uint64_t tid;
-    C_AppendFlush(ObjectRecorder *o, uint64_t _tid)
-        : object_recorder(o), tid(_tid) {
-      object_recorder->get();
-    }
-    void finish(int r) override {
-      object_recorder->handle_append_flushed(tid, r);
-      object_recorder->put();
-    }
-  };
-
-  librados::IoCtx m_ioctx;
-  std::string m_oid;
-  uint64_t m_object_number;
-  CephContext *m_cct;
-
-  ContextWQ *m_op_work_queue;
-
-  SafeTimer &m_timer;
-  Mutex &m_timer_lock;
-
-  Handler *m_handler;
-
-  uint8_t m_order;
-  uint64_t m_soft_max_size;
-
-  uint32_t m_flush_interval;
-  uint64_t m_flush_bytes;
-  double m_flush_age;
-
-  FlushHandler m_flush_handler;
-
-  Context *m_append_task = nullptr;
-
-  mutable std::shared_ptr<Mutex> m_lock;
-  AppendBuffers m_append_buffers;
-  uint64_t m_append_tid;
-  uint32_t m_pending_bytes;
-
-  InFlightTids m_in_flight_tids;
-  InFlightAppends m_in_flight_appends;
-  uint64_t m_size;
-  bool m_overflowed;
-  bool m_object_closed;
-
-  bufferlist m_prefetch_bl;
-
-  bool m_in_flight_flushes;
-  Cond m_in_flight_flushes_cond;
-
-  AppendBuffers m_pending_buffers;
-  bool m_aio_scheduled;
-
-  void handle_append_task();
-  void cancel_append_task();
-  void schedule_append_task();
-
-  bool append(const AppendBuffer &append_buffer, bool *schedule_append);
-  bool flush_appends(bool force);
-  void handle_append_flushed(uint64_t tid, int r);
-  void append_overflowed();
-  void send_appends(AppendBuffers *append_buffers);
-  void send_appends_aio();
-
-  void notify_handler_unlock();
-};
-
-} // namespace journal
-
-#endif // CEPH_JOURNAL_OBJECT_RECORDER_H