X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fos%2Ffilestore%2FJournal.h;fp=src%2Fceph%2Fsrc%2Fos%2Ffilestore%2FJournal.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=9c1206cd257db2738269b8a6d669ddb1693c12f7;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/os/filestore/Journal.h b/src/ceph/src/os/filestore/Journal.h deleted file mode 100644 index 9c1206c..0000000 --- a/src/ceph/src/os/filestore/Journal.h +++ /dev/null @@ -1,92 +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 - * - * 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_JOURNAL_H -#define CEPH_JOURNAL_H - -#include - -#include "include/buffer_fwd.h" -#include "include/Context.h" -#include "common/Finisher.h" -#include "common/TrackedOp.h" -#include "os/ObjectStore.h" -#include "common/zipkin_trace.h" - -class PerfCounters; - -class Journal { -protected: - uuid_d fsid; - Finisher *finisher; -public: - CephContext* cct; - PerfCounters *logger; -protected: - Cond *do_sync_cond; - bool wait_on_full; - -public: - Journal(CephContext* cct, uuid_d f, Finisher *fin, Cond *c=0) : - fsid(f), finisher(fin), cct(cct), logger(NULL), - do_sync_cond(c), - wait_on_full(false) { } - virtual ~Journal() { } - - virtual int check() = 0; ///< check if journal appears valid - virtual int create() = 0; ///< create a fresh journal - virtual int open(uint64_t fs_op_seq) = 0; ///< open an existing journal - virtual void close() = 0; ///< close an open journal - - virtual void flush() = 0; - - /** - * reserve_throttle_and_backoff - * - * Implementation may throttle or backoff based on ops - * reserved here but not yet released using committed_thru. - */ - virtual void reserve_throttle_and_backoff(uint64_t count) = 0; - - virtual int dump(ostream& out) { return -EOPNOTSUPP; } - - void set_wait_on_full(bool b) { wait_on_full = b; } - - // writes - virtual bool is_writeable() = 0; - virtual int make_writeable() = 0; - virtual void submit_entry(uint64_t seq, bufferlist& e, uint32_t orig_len, - Context *oncommit, - TrackedOpRef osd_op = TrackedOpRef()) = 0; - virtual void commit_start(uint64_t seq) = 0; - virtual void committed_thru(uint64_t seq) = 0; - - /// Read next journal entry - asserts on invalid journal - virtual bool read_entry( - bufferlist &bl, ///< [out] payload on successful read - uint64_t &seq ///< [in,out] sequence number on last successful read - ) = 0; ///< @return true on successful read, false on journal end - - virtual bool should_commit_now() = 0; - - virtual int prepare_entry(vector& tls, bufferlist* tbl) = 0; - - virtual off64_t get_journal_size_estimate() { return 0; } - - // reads/recovery - -}; - -#endif