+++ /dev/null
-// -*- 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.
- *
- */
-
-#include "CInode.h"
-#include "MDCache.h"
-#include "MDSRank.h"
-#include "Locker.h"
-#include "osdc/Filer.h"
-
-#include "RecoveryQueue.h"
-
-#define dout_context g_ceph_context
-#define dout_subsys ceph_subsys_mds
-#undef dout_prefix
-#define dout_prefix *_dout << "mds." << mds->get_nodeid() << " RecoveryQueue::" << __func__ << " "
-
-class C_MDC_Recover : public MDSIOContextBase {
-protected:
- RecoveryQueue *rq;
- CInode *in;
- void finish(int r) override {
- rq->_recovered(in, r, size, mtime);
- }
-
- MDSRank *get_mds() override {
- return rq->mds;
- }
-
-public:
- uint64_t size;
- utime_t mtime;
-
- C_MDC_Recover(RecoveryQueue *rq_, CInode *i) : rq(rq_), in(i), size(0) {
- assert(rq != NULL);
- }
-};
-
-
-RecoveryQueue::RecoveryQueue(MDSRank *mds_)
- : mds(mds_), logger(NULL), filer(mds_->objecter, mds_->finisher)
-{}
-
-
-/**
- * Progress the queue. Call this after enqueuing something or on
- * completion of something.
- */
-void RecoveryQueue::advance()
-{
- dout(10) << file_recover_queue.size() << " queued, "
- << file_recover_queue_front.size() << " prioritized, "
- << file_recovering.size() << " recovering" << dendl;
-
- while (file_recovering.size() < g_conf->mds_max_file_recover) {
- if (!file_recover_queue_front.empty()) {
- CInode *in = *file_recover_queue_front.begin();
- file_recover_queue_front.erase(file_recover_queue_front.begin());
- file_recover_queue.erase(in);
- _start(in);
- } else if (!file_recover_queue.empty()) {
- CInode *in = *file_recover_queue.begin();
- file_recover_queue.erase(file_recover_queue.begin());
- _start(in);
- } else {
- break;
- }
- }
-
- logger->set(l_mdc_num_recovering_processing, file_recovering.size());
- logger->set(l_mdc_num_recovering_enqueued, file_recover_queue.size());
- logger->set(l_mdc_num_recovering_prioritized, file_recover_queue_front.size());
-}
-
-void RecoveryQueue::_start(CInode *in)
-{
- inode_t *pi = in->get_projected_inode();
-
- // blech
- if (pi->client_ranges.size() && !pi->get_max_size()) {
- mds->clog->warn() << "bad client_range " << pi->client_ranges
- << " on ino " << pi->ino;
- }
-
- if (pi->client_ranges.size() && pi->get_max_size()) {
- dout(10) << "starting " << in->inode.size << " " << pi->client_ranges
- << " " << *in << dendl;
- file_recovering.insert(in);
-
- C_MDC_Recover *fin = new C_MDC_Recover(this, in);
- filer.probe(in->inode.ino, &in->inode.layout, in->last,
- pi->get_max_size(), &fin->size, &fin->mtime, false,
- 0, fin);
- } else {
- dout(10) << "skipping " << in->inode.size << " " << *in << dendl;
- in->state_clear(CInode::STATE_RECOVERING);
- mds->locker->eval(in, CEPH_LOCK_IFILE);
- in->auth_unpin(this);
- }
-}
-
-void RecoveryQueue::prioritize(CInode *in)
-{
- if (file_recovering.count(in)) {
- dout(10) << "already working on " << *in << dendl;
- return;
- }
-
- if (file_recover_queue.count(in)) {
- dout(20) << *in << dendl;
- file_recover_queue_front.insert(in);
- logger->set(l_mdc_num_recovering_prioritized, file_recover_queue_front.size());
- return;
- }
-
- dout(10) << "not queued " << *in << dendl;
-}
-
-
-/**
- * Given an authoritative inode which is in the cache,
- * enqueue it for recovery.
- */
-void RecoveryQueue::enqueue(CInode *in)
-{
- dout(15) << "RecoveryQueue::enqueue " << *in << dendl;
- assert(logger); // Caller should have done set_logger before using me
- assert(in->is_auth());
-
- in->state_clear(CInode::STATE_NEEDSRECOVER);
- if (!in->state_test(CInode::STATE_RECOVERING)) {
- in->state_set(CInode::STATE_RECOVERING);
- in->auth_pin(this);
- logger->inc(l_mdc_recovery_started);
- }
- file_recover_queue.insert(in);
- logger->set(l_mdc_num_recovering_enqueued, file_recover_queue.size());
-}
-
-
-/**
- * Call back on completion of Filer probe on an inode.
- */
-void RecoveryQueue::_recovered(CInode *in, int r, uint64_t size, utime_t mtime)
-{
- dout(10) << "_recovered r=" << r << " size=" << size << " mtime=" << mtime
- << " for " << *in << dendl;
-
- if (r != 0) {
- dout(0) << "recovery error! " << r << dendl;
- if (r == -EBLACKLISTED) {
- mds->respawn();
- return;
- } else {
- // Something wrong on the OSD side trying to recover the size
- // of this inode. In principle we could record this as a piece
- // of per-inode damage, but it's actually more likely that
- // this indicates something wrong with the MDS (like maybe
- // it has the wrong auth caps?)
- mds->clog->error() << " OSD read error while recovering size for inode 0x"
- << std::hex << in->ino() << std::dec;
- mds->damaged();
- }
- }
-
- file_recovering.erase(in);
- logger->set(l_mdc_num_recovering_processing, file_recovering.size());
- logger->inc(l_mdc_recovery_completed);
- in->state_clear(CInode::STATE_RECOVERING);
-
- if (!in->get_parent_dn() && !in->get_projected_parent_dn()) {
- dout(10) << " inode has no parents, killing it off" << dendl;
- in->auth_unpin(this);
- mds->mdcache->remove_inode(in);
- } else {
- // journal
- mds->locker->check_inode_max_size(in, true, 0, size, mtime);
- mds->locker->eval(in, CEPH_LOCK_IFILE);
- in->auth_unpin(this);
- }
-
- advance();
-}
-
Code Review / stor4nfv.git / blobdiff