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

diff --git a/src/ceph/src/mds/PurgeQueue.h b/src/ceph/src/mds/PurgeQueue.h
deleted file mode 100644
index 6a13a57..0000000
--- a/src/ceph/src/mds/PurgeQueue.h
+++ /dev/null
@@ -1,192 +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) 2015 Red Hat
- *
- * 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 PURGE_QUEUE_H_
-#define PURGE_QUEUE_H_
-
-#include "include/compact_set.h"
-#include "mds/MDSMap.h"
-#include "osdc/Journaler.h"
-
-
-/**
- * Descriptor of the work associated with purging a file.  We record
- * the minimal amount of information from the inode such as the size
- * and layout: all other un-needed inode metadata (times, permissions, etc)
- * has been discarded.
- */
-class PurgeItem
-{
-public:
-  enum Action : uint8_t {
-    NONE = 0,
-    PURGE_FILE = 1,
-    TRUNCATE_FILE,
-    PURGE_DIR
-  };
-
-  Action action;
-  inodeno_t ino;
-  uint64_t size;
-  file_layout_t layout;
-  compact_set<int64_t> old_pools;
-  SnapContext snapc;
-  fragtree_t fragtree;
-
-  PurgeItem()
-   : action(NONE), ino(0), size(0)
-  {}
-
-  void encode(bufferlist &bl) const;
-  void decode(bufferlist::iterator &p);
-};
-WRITE_CLASS_ENCODER(PurgeItem)
-
-enum {
-  l_pq_first = 3500,
-
-  // How many items have been finished by PurgeQueue
-  l_pq_executing_ops,
-  l_pq_executing,
-  l_pq_executed,
-  l_pq_last
-};
-
-/**
- * A persistent queue of PurgeItems.  This class both writes and reads
- * to the queue.  There is one of these per MDS rank.
- *
- * Note that this class does not take a reference to MDSRank: we are
- * independent of all the metadata structures and do not need to
- * take mds_lock for anything.
- */
-class PurgeQueue
-{
-protected:
-  CephContext *cct;
-  const mds_rank_t rank;
-  Mutex lock;
-
-  int64_t metadata_pool;
-
-  // Don't use the MDSDaemon's Finisher and Timer, because this class
-  // operates outside of MDSDaemon::mds_lock
-  Finisher finisher;
-  SafeTimer timer;
-  Filer filer;
-  Objecter *objecter;
-  std::unique_ptr<PerfCounters> logger;
-
-  Journaler journaler;
-
-  Context *on_error;
-
-  // Map of Journaler offset to PurgeItem
-  std::map<uint64_t, PurgeItem> in_flight;
-
-  // Throttled allowances
-  uint64_t ops_in_flight;
-
-  // Dynamic op limit per MDS based on PG count
-  uint64_t max_purge_ops;
-
-  uint32_t _calculate_ops(const PurgeItem &item) const;
-
-  bool can_consume();
-
-  // How many bytes were remaining when drain() was first called,
-  // used for indicating progress.
-  uint64_t drain_initial;
-
-  // Has drain() ever been called on this instance?
-  bool draining;
-
-  // recover the journal write_pos (drop any partial written entry)
-  void _recover();
-
-  /**
-   * @return true if we were in a position to try and consume something:
-   *         does not mean we necessarily did.
-   */
-  bool _consume();
-
-  // Do we currently have a flush timer event waiting?
-  Context *delayed_flush;
-
-  void _execute_item(
-      const PurgeItem &item,
-      uint64_t expire_to);
-  void _execute_item_complete(
-      uint64_t expire_to);
-
-  bool recovered;
-  std::list<Context*> waiting_for_recovery;
-
-public:
-  void init();
-  void activate();
-  void shutdown();
-
-  void create_logger();
-
-  // Write an empty queue, use this during MDS rank creation
-  void create(Context *completion);
-
-  // Read the Journaler header for an existing queue and start consuming
-  void open(Context *completion);
-
-  void wait_for_recovery(Context *c);
-
-  // Submit one entry to the work queue.  Call back when it is persisted
-  // to the queue (there is no callback for when it is executed)
-  void push(const PurgeItem &pi, Context *completion);
-
-  // If the on-disk queue is empty and we are not currently processing
-  // anything.
-  bool is_idle() const;
-
-  /**
-   * Signal to the PurgeQueue that you would like it to hurry up and
-   * finish consuming everything in the queue.  Provides progress
-   * feedback.
-   *
-   * @param progress: bytes consumed since we started draining
-   * @param progress_total: max bytes that were outstanding during purge
-   * @param in_flight_count: number of file purges currently in flight
-   *
-   * @returns true if drain is complete
-   */
-  bool drain(
-    uint64_t *progress,
-    uint64_t *progress_total,
-    size_t *in_flight_count);
-
-  void update_op_limit(const MDSMap &mds_map);
-
-  void handle_conf_change(const struct md_config_t *conf,
-                          const std::set <std::string> &changed,
-                          const MDSMap &mds_map);
-
-  PurgeQueue(
-      CephContext *cct_,
-      mds_rank_t rank_,
-      const int64_t metadata_pool_,
-      Objecter *objecter_,
-      Context *on_error);
-  ~PurgeQueue();
-};
-
-
-#endif
-