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

diff --git a/src/ceph/src/os/filestore/JournalingObjectStore.h b/src/ceph/src/os/filestore/JournalingObjectStore.h
deleted file mode 100644
index 17dc2ab..0000000
--- a/src/ceph/src/os/filestore/JournalingObjectStore.h
+++ /dev/null
@@ -1,147 +0,0 @@
-// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
-// vim: ts=8 sw=2 smarttab
-/*
- * Ceph - scalable distributed file system
- *
- * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
- *
- * This is free software; you can redistribute it and/or
- * modify it under the terms of the GNU Lesser General Public
- * License version 2.1, as published by the Free Software
- * Foundation.  See file COPYING.
- *
- */
-
-#ifndef CEPH_JOURNALINGOBJECTSTORE_H
-#define CEPH_JOURNALINGOBJECTSTORE_H
-
-#include "os/ObjectStore.h"
-#include "Journal.h"
-#include "FileJournal.h"
-#include "common/RWLock.h"
-#include "osd/OpRequest.h"
-
-class JournalingObjectStore : public ObjectStore {
-protected:
-  Journal *journal;
-  Finisher finisher;
-
-
-  class SubmitManager {
-    CephContext* cct;
-    Mutex lock;
-    uint64_t op_seq;
-    uint64_t op_submitted;
-  public:
-    SubmitManager(CephContext* cct) :
-      cct(cct), lock("JOS::SubmitManager::lock", false, true, false, cct),
-      op_seq(0), op_submitted(0)
-    {}
-    uint64_t op_submit_start();
-    void op_submit_finish(uint64_t op);
-    void set_op_seq(uint64_t seq) {
-      Mutex::Locker l(lock);
-      op_submitted = op_seq = seq;
-    }
-    uint64_t get_op_seq() {
-      return op_seq;
-    }
-  } submit_manager;
-
-  class ApplyManager {
-    CephContext* cct;
-    Journal *&journal;
-    Finisher &finisher;
-
-    Mutex apply_lock;
-    bool blocked;
-    Cond blocked_cond;
-    int open_ops;
-    uint64_t max_applied_seq;
-
-    Mutex com_lock;
-    map<version_t, vector<Context*> > commit_waiters;
-    uint64_t committing_seq, committed_seq;
-
-  public:
-    ApplyManager(CephContext* cct, Journal *&j, Finisher &f) :
-      cct(cct), journal(j), finisher(f),
-      apply_lock("JOS::ApplyManager::apply_lock", false, true, false, cct),
-      blocked(false),
-      open_ops(0),
-      max_applied_seq(0),
-      com_lock("JOS::ApplyManager::com_lock", false, true, false, cct),
-      committing_seq(0), committed_seq(0) {}
-    void reset() {
-      assert(open_ops == 0);
-      assert(blocked == false);
-      max_applied_seq = 0;
-      committing_seq = 0;
-      committed_seq = 0;
-    }
-    void add_waiter(uint64_t, Context*);
-    uint64_t op_apply_start(uint64_t op);
-    void op_apply_finish(uint64_t op);
-    bool commit_start();
-    void commit_started();
-    void commit_finish();
-    bool is_committing() {
-      Mutex::Locker l(com_lock);
-      return committing_seq != committed_seq;
-    }
-    uint64_t get_committed_seq() {
-      Mutex::Locker l(com_lock);
-      return committed_seq;
-    }
-    uint64_t get_committing_seq() {
-      Mutex::Locker l(com_lock);
-      return committing_seq;
-    }
-    void init_seq(uint64_t fs_op_seq) {
-      {
-	Mutex::Locker l(com_lock);
-	committed_seq = fs_op_seq;
-	committing_seq = fs_op_seq;
-      }
-      {
-	Mutex::Locker l(apply_lock);
-	max_applied_seq = fs_op_seq;
-      }
-    }
-  } apply_manager;
-
-  bool replaying;
-
-protected:
-  void journal_start();
-  void journal_stop();
-  void journal_write_close();
-  int journal_replay(uint64_t fs_op_seq);
-
-  void _op_journal_transactions(bufferlist& tls, uint32_t orig_len, uint64_t op,
-				Context *onjournal, TrackedOpRef osd_op);
-
-  virtual int do_transactions(vector<ObjectStore::Transaction>& tls, uint64_t op_seq) = 0;
-
-public:
-  bool is_committing() {
-    return apply_manager.is_committing();
-  }
-  uint64_t get_committed_seq() {
-    return apply_manager.get_committed_seq();
-  }
-
-public:
-  JournalingObjectStore(CephContext* cct, const std::string& path)
-    : ObjectStore(cct, path),
-      journal(NULL),
-      finisher(cct, "JournalObjectStore", "fn_jrn_objstore"),
-      submit_manager(cct),
-      apply_manager(cct, journal, finisher),
-      replaying(false) {}
-
-  ~JournalingObjectStore() override {
-  }
-};
-
-#endif