Method enqueue

src/mds/ScrubStack.cc:169–208

}

int ScrubStack::enqueue(CInode *in, ScrubHeaderRef& header, bool top)
{
  // abort in progress
  if (clear_stack)
    return -EAGAIN;

  header->set_origin(in->ino());
  auto ret = scrubbing_map.emplace(header->get_tag(), header);
  if (!ret.second) {
    dout(10) << __func__ << " with {" << *in << "}"
	     << ", conflicting tag " << header->get_tag() << dendl;
    return -EEXIST;
  }
  if (header->get_scrub_mdsdir()) {
    filepath fp;
    mds_rank_t rank;
    rank = mdcache->mds->get_nodeid();
    if(rank >= 0 && rank < MAX_MDS) {
      fp.set_path("", MDS_INO_MDSDIR(rank));
    }
    int r = _enqueue(mdcache->get_inode(fp.get_ino()), header, true);
    if (r < 0) {
      return r;
    }
    //to make sure mdsdir is always on the top
    top = false;
  }

  std::string path;
  in->make_path_string(path);
  init_scrub_counters(path, header->get_tag());
  int r = _enqueue(in, header, top);
  if (r < 0)
    return r;

  clog_scrub_summary(in);

  kick_off_scrubs();
  return 0;
}

void ScrubStack::add_to_waiting(MDSCacheObject *obj)
{