+++ /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.
- *
- */
-
-
-#ifndef CEPH_MDISCOVERREPLY_H
-#define CEPH_MDISCOVERREPLY_H
-
-#include "msg/Message.h"
-#include "include/filepath.h"
-
-#include <string>
-
-
-
-/**
- * MDiscoverReply - return new replicas (of inodes, dirs, dentries)
- *
- * we group returned items by (dir, dentry, inode). each
- * item in each set shares an index (it's "depth").
- *
- * we can start and end with any type.
- * no_base_dir = true if the first group has an inode but no dir
- * no_base_dentry = true if the first group has an inode but no dentry
- * they are false if there is no returned data, ie the first group is empty.
- *
- * we also return errors:
- * error_flag_dn(std::string) - the specified dentry dne
- * error_flag_dir - the last item wasn't a dir, so we couldn't continue.
- *
- * and sometimes,
- * dir_auth_hint - where we think the dir auth is
- *
- * depth() gives us the number of depth units/indices for which we have
- * information. this INCLUDES those for which we have errors but no data.
- *
- * see MDCache::handle_discover, handle_discover_reply.
- *
- *
- * so basically, we get
- *
- * dir den ino i
- * x 0
- * x x x 1
- * or
- * x x 0
- * x x x 1
- * or
- * x x x 0
- * x x x 1
- * ...and trail off however we want.
- *
- *
- */
-
-class MDiscoverReply : public Message {
-
- static const int HEAD_VERSION = 2;
-
- // info about original request
- inodeno_t base_ino;
- frag_t base_dir_frag;
- bool wanted_base_dir;
- bool wanted_xlocked;
- snapid_t wanted_snapid;
-
- // and the response
- bool flag_error_dn;
- bool flag_error_dir;
- std::string error_dentry; // dentry that was not found (to trigger waiters on asker)
- bool unsolicited;
-
- mds_rank_t dir_auth_hint;
-
- public:
- __u8 starts_with;
- bufferlist trace;
-
- enum { DIR, DENTRY, INODE };
-
- // accessors
- inodeno_t get_base_ino() { return base_ino; }
- frag_t get_base_dir_frag() { return base_dir_frag; }
- bool get_wanted_base_dir() { return wanted_base_dir; }
- bool get_wanted_xlocked() { return wanted_xlocked; }
- snapid_t get_wanted_snapid() { return wanted_snapid; }
-
- bool is_flag_error_dn() { return flag_error_dn; }
- bool is_flag_error_dir() { return flag_error_dir; }
- std::string& get_error_dentry() { return error_dentry; }
-
- int get_starts_with() { return starts_with; }
-
- mds_rank_t get_dir_auth_hint() const { return dir_auth_hint; }
-
- bool is_unsolicited() { return unsolicited; }
- void mark_unsolicited() { unsolicited = true; }
-
- void set_base_dir_frag(frag_t df) { base_dir_frag = df; }
-
- // cons
- MDiscoverReply() : Message(MSG_MDS_DISCOVERREPLY, HEAD_VERSION) { }
- MDiscoverReply(MDiscover *dis) :
- Message(MSG_MDS_DISCOVERREPLY, HEAD_VERSION),
- base_ino(dis->get_base_ino()),
- base_dir_frag(dis->get_base_dir_frag()),
- wanted_base_dir(dis->wants_base_dir()),
- wanted_xlocked(dis->wants_xlocked()),
- wanted_snapid(dis->get_snapid()),
- flag_error_dn(false),
- flag_error_dir(false),
- unsolicited(false),
- dir_auth_hint(CDIR_AUTH_UNKNOWN),
- starts_with(DIR)
- {
- header.tid = dis->get_tid();
- }
- MDiscoverReply(dirfrag_t df) :
- Message(MSG_MDS_DISCOVERREPLY, HEAD_VERSION),
- base_ino(df.ino),
- base_dir_frag(df.frag),
- wanted_base_dir(false),
- wanted_xlocked(false),
- wanted_snapid(CEPH_NOSNAP),
- flag_error_dn(false),
- flag_error_dir(false),
- unsolicited(false),
- dir_auth_hint(CDIR_AUTH_UNKNOWN),
- starts_with(DIR)
- {
- header.tid = 0;
- }
-private:
- ~MDiscoverReply() override {}
-
-public:
- const char *get_type_name() const override { return "discover_reply"; }
- void print(ostream& out) const override {
- out << "discover_reply(" << header.tid << " " << base_ino << ")";
- }
-
- // builders
- bool is_empty() {
- return trace.length() == 0 &&
- !flag_error_dn &&
- !flag_error_dir &&
- dir_auth_hint == CDIR_AUTH_UNKNOWN;
- }
-
- // void set_flag_forward() { flag_forward = true; }
- void set_flag_error_dn(const std::string& dn) {
- flag_error_dn = true;
- error_dentry = dn;
- }
- void set_flag_error_dir() {
- flag_error_dir = true;
- }
- void set_dir_auth_hint(int a) {
- dir_auth_hint = a;
- }
- void set_error_dentry(const std::string& dn) {
- error_dentry = dn;
- }
-
-
- // ...
- void decode_payload() override {
- bufferlist::iterator p = payload.begin();
- ::decode(base_ino, p);
- ::decode(base_dir_frag, p);
- ::decode(wanted_base_dir, p);
- ::decode(wanted_xlocked, p);
- ::decode(wanted_snapid, p);
- ::decode(flag_error_dn, p);
- ::decode(flag_error_dir, p);
- ::decode(error_dentry, p);
- ::decode(dir_auth_hint, p);
- ::decode(unsolicited, p);
-
- ::decode(starts_with, p);
- ::decode(trace, p);
- }
- void encode_payload(uint64_t features) override {
- ::encode(base_ino, payload);
- ::encode(base_dir_frag, payload);
- ::encode(wanted_base_dir, payload);
- ::encode(wanted_xlocked, payload);
- ::encode(wanted_snapid, payload);
- ::encode(flag_error_dn, payload);
- ::encode(flag_error_dir, payload);
- ::encode(error_dentry, payload);
- ::encode(dir_auth_hint, payload);
- ::encode(unsolicited, payload);
-
- ::encode(starts_with, payload);
- ::encode(trace, payload);
- }
-};
-
-#endif
Code Review / stor4nfv.git / blobdiff