X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fmessages%2FMMDSResolve.h;fp=src%2Fceph%2Fsrc%2Fmessages%2FMMDSResolve.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=baf581b4bd0bca930e4ecf10e45c8ad1115b47a7;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/messages/MMDSResolve.h b/src/ceph/src/messages/MMDSResolve.h deleted file mode 100644 index baf581b..0000000 --- a/src/ceph/src/messages/MMDSResolve.h +++ /dev/null @@ -1,94 +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. - * - */ - -#ifndef CEPH_MMDSRESOLVE_H -#define CEPH_MMDSRESOLVE_H - -#include "msg/Message.h" - -#include "include/types.h" - -class MMDSResolve : public Message { -public: - map > subtrees; - map > ambiguous_imports; - - struct slave_request { - bufferlist inode_caps; - bool committing; - slave_request() : committing(false) {} - void encode(bufferlist &bl) const { - ::encode(inode_caps, bl); - ::encode(committing, bl); - } - void decode(bufferlist::iterator &bl) { - ::decode(inode_caps, bl); - ::decode(committing, bl); - } - }; - WRITE_CLASS_ENCODER(slave_request) - - map slave_requests; - - MMDSResolve() : Message(MSG_MDS_RESOLVE) {} -private: - ~MMDSResolve() override {} - -public: - const char *get_type_name() const override { return "mds_resolve"; } - - void print(ostream& out) const override { - out << "mds_resolve(" << subtrees.size() - << "+" << ambiguous_imports.size() - << " subtrees +" << slave_requests.size() << " slave requests)"; - } - - void add_subtree(dirfrag_t im) { - subtrees[im].clear(); - } - void add_subtree_bound(dirfrag_t im, dirfrag_t ex) { - subtrees[im].push_back(ex); - } - - void add_ambiguous_import(dirfrag_t im, const vector& m) { - ambiguous_imports[im] = m; - } - - void add_slave_request(metareqid_t reqid, bool committing) { - slave_requests[reqid].committing = committing; - } - - void add_slave_request(metareqid_t reqid, bufferlist& bl) { - slave_requests[reqid].inode_caps.claim(bl); - } - - void encode_payload(uint64_t features) override { - ::encode(subtrees, payload); - ::encode(ambiguous_imports, payload); - ::encode(slave_requests, payload); - } - void decode_payload() override { - bufferlist::iterator p = payload.begin(); - ::decode(subtrees, p); - ::decode(ambiguous_imports, p); - ::decode(slave_requests, p); - } -}; - -inline ostream& operator<<(ostream& out, const MMDSResolve::slave_request&) { - return out; -} - -WRITE_CLASS_ENCODER(MMDSResolve::slave_request) -#endif