src/ceph/src/messages/MMDSResolve.h

   1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
   2 // vim: ts=8 sw=2 smarttab
   3 /*
   4  * Ceph - scalable distributed file system
   5  *
   6  * Copyright (C) 2004-2006 Sage Weil <sage@newdream.net>
   7  *
   8  * This is free software; you can redistribute it and/or
   9  * modify it under the terms of the GNU Lesser General Public
  10  * License version 2.1, as published by the Free Software
  11  * Foundation.  See file COPYING.
  12  *
  13  */
  14
  15 #ifndef CEPH_MMDSRESOLVE_H
  16 #define CEPH_MMDSRESOLVE_H
  17
  18 #include "msg/Message.h"
  19
  20 #include "include/types.h"
  21
  22 class MMDSResolve : public Message {
  23 public:
  24   map<dirfrag_t, vector<dirfrag_t> > subtrees;
  25   map<dirfrag_t, vector<dirfrag_t> > ambiguous_imports;
  26
  27   struct slave_request {
  28     bufferlist inode_caps;
  29     bool committing;
  30     slave_request() : committing(false) {}
  31     void encode(bufferlist &bl) const {
  32       ::encode(inode_caps, bl);
  33       ::encode(committing, bl);
  34     }
  35     void decode(bufferlist::iterator &bl) {
  36       ::decode(inode_caps, bl);
  37       ::decode(committing, bl);
  38     }
  39   };
  40   WRITE_CLASS_ENCODER(slave_request)
  41
  42   map<metareqid_t, slave_request> slave_requests;
  43
  44   MMDSResolve() : Message(MSG_MDS_RESOLVE) {}
  45 private:
  46   ~MMDSResolve() override {}
  47
  48 public:
  49   const char *get_type_name() const override { return "mds_resolve"; }
  50
  51   void print(ostream& out) const override {
  52     out << "mds_resolve(" << subtrees.size()
  53         << "+" << ambiguous_imports.size()
  54         << " subtrees +" << slave_requests.size() << " slave requests)";
  55   }
  56
  57   void add_subtree(dirfrag_t im) {
  58     subtrees[im].clear();
  59   }
  60   void add_subtree_bound(dirfrag_t im, dirfrag_t ex) {
  61     subtrees[im].push_back(ex);
  62   }
  63
  64   void add_ambiguous_import(dirfrag_t im, const vector<dirfrag_t>& m) {
  65     ambiguous_imports[im] = m;
  66   }
  67
  68   void add_slave_request(metareqid_t reqid, bool committing) {
  69     slave_requests[reqid].committing = committing;
  70   }
  71
  72   void add_slave_request(metareqid_t reqid, bufferlist& bl) {
  73     slave_requests[reqid].inode_caps.claim(bl);
  74   }
  75
  76   void encode_payload(uint64_t features) override {
  77     ::encode(subtrees, payload);
  78     ::encode(ambiguous_imports, payload);
  79     ::encode(slave_requests, payload);
  80   }
  81   void decode_payload() override {
  82     bufferlist::iterator p = payload.begin();
  83     ::decode(subtrees, p);
  84     ::decode(ambiguous_imports, p);
  85     ::decode(slave_requests, p);
  86   }
  87 };
  88
  89 inline ostream& operator<<(ostream& out, const MMDSResolve::slave_request&) {
  90     return out;
  91 }
  92
  93 WRITE_CLASS_ENCODER(MMDSResolve::slave_request)
  94 #endif