X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fmds%2FRecoveryQueue.h;fp=src%2Fceph%2Fsrc%2Fmds%2FRecoveryQueue.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=6750c5fcb495828dd8716548eced306e93d634b7;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/mds/RecoveryQueue.h b/src/ceph/src/mds/RecoveryQueue.h deleted file mode 100644 index 6750c5f..0000000 --- a/src/ceph/src/mds/RecoveryQueue.h +++ /dev/null @@ -1,51 +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. - * - */ - -//class C_MDC_Recover; -// -#ifndef RECOVERY_QUEUE_H -#define RECOVERY_QUEUE_H - -#include - -#include "osdc/Filer.h" - -class CInode; -class MDSRank; -class PerfCounters; - -class RecoveryQueue { -public: - void enqueue(CInode *in); - void advance(); - void prioritize(CInode *in); ///< do this inode now/soon - explicit RecoveryQueue(MDSRank *mds_); - - void set_logger(PerfCounters *p) {logger=p;} - -private: - void _start(CInode *in); ///< start recovering this file - - std::set file_recover_queue; ///< the queue - std::set file_recover_queue_front; ///< elevated priority items - std::set file_recovering; - void _recovered(CInode *in, int r, uint64_t size, utime_t mtime); - MDSRank *mds; - PerfCounters *logger; - Filer filer; - - friend class C_MDC_Recover; -}; - -#endif // RECOVERY_QUEUE_H