+++ /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_MCLIENTREPLY_H
-#define CEPH_MCLIENTREPLY_H
-
-#include "include/types.h"
-#include "include/fs_types.h"
-#include "MClientRequest.h"
-
-#include "msg/Message.h"
-#include "include/ceph_features.h"
-#include "common/errno.h"
-
-/***
- *
- * MClientReply - container message for MDS reply to a client's MClientRequest
- *
- * key fields:
- * long tid - transaction id, so the client can match up with pending request
- * int result - error code, or fh if it was open
- *
- * for most requests:
- * trace is a vector of InodeStat's tracing from root to the file/dir/whatever
- * the operation referred to, so that the client can update it's info about what
- * metadata lives on what MDS.
- *
- * for readdir replies:
- * dir_contents is a vector of InodeStat*'s.
- *
- * that's mostly it, i think!
- *
- */
-
-
-struct LeaseStat {
- // this matches ceph_mds_reply_lease
- __u16 mask;
- __u32 duration_ms;
- __u32 seq;
-
- LeaseStat() : mask(0), duration_ms(0), seq(0) {}
-
- void encode(bufferlist &bl) const {
- ::encode(mask, bl);
- ::encode(duration_ms, bl);
- ::encode(seq, bl);
- }
- void decode(bufferlist::iterator &bl) {
- ::decode(mask, bl);
- ::decode(duration_ms, bl);
- ::decode(seq, bl);
- }
-};
-WRITE_CLASS_ENCODER(LeaseStat)
-
-inline ostream& operator<<(ostream& out, const LeaseStat& l) {
- return out << "lease(mask " << l.mask << " dur " << l.duration_ms << ")";
-}
-
-struct DirStat {
- // mds distribution hints
- frag_t frag;
- __s32 auth;
- set<__s32> dist;
-
- DirStat() : auth(CDIR_AUTH_PARENT) {}
- DirStat(bufferlist::iterator& p) {
- decode(p);
- }
-
- void encode(bufferlist& bl) {
- ::encode(frag, bl);
- ::encode(auth, bl);
- ::encode(dist, bl);
- }
- void decode(bufferlist::iterator& p) {
- ::decode(frag, p);
- ::decode(auth, p);
- ::decode(dist, p);
- }
-
- // see CDir::encode_dirstat for encoder.
-};
-
-struct InodeStat {
- vinodeno_t vino;
- uint32_t rdev;
- version_t version;
- version_t xattr_version;
- ceph_mds_reply_cap cap;
- file_layout_t layout;
- utime_t ctime, btime, mtime, atime;
- uint32_t time_warp_seq;
- uint64_t size, max_size;
- uint64_t change_attr;
- uint64_t truncate_size;
- uint32_t truncate_seq;
- uint32_t mode, uid, gid, nlink;
- frag_info_t dirstat;
- nest_info_t rstat;
-
- fragtree_t dirfragtree;
- string symlink; // symlink content (if symlink)
-
- ceph_dir_layout dir_layout;
-
- bufferlist xattrbl;
-
- bufferlist inline_data;
- version_t inline_version;
-
- quota_info_t quota;
-
- public:
- InodeStat() {}
- InodeStat(bufferlist::iterator& p, uint64_t features) {
- decode(p, features);
- }
-
- void decode(bufferlist::iterator &p, uint64_t features) {
- ::decode(vino.ino, p);
- ::decode(vino.snapid, p);
- ::decode(rdev, p);
- ::decode(version, p);
- ::decode(xattr_version, p);
- ::decode(cap, p);
- {
- ceph_file_layout legacy_layout;
- ::decode(legacy_layout, p);
- layout.from_legacy(legacy_layout);
- }
- ::decode(ctime, p);
- ::decode(mtime, p);
- ::decode(atime, p);
- ::decode(time_warp_seq, p);
- ::decode(size, p);
- ::decode(max_size, p);
- ::decode(truncate_size, p);
- ::decode(truncate_seq, p);
- ::decode(mode, p);
- ::decode(uid, p);
- ::decode(gid, p);
- ::decode(nlink, p);
- ::decode(dirstat.nfiles, p);
- ::decode(dirstat.nsubdirs, p);
- ::decode(rstat.rbytes, p);
- ::decode(rstat.rfiles, p);
- ::decode(rstat.rsubdirs, p);
- ::decode(rstat.rctime, p);
-
- ::decode(dirfragtree, p);
-
- ::decode(symlink, p);
-
- if (features & CEPH_FEATURE_DIRLAYOUTHASH)
- ::decode(dir_layout, p);
- else
- memset(&dir_layout, 0, sizeof(dir_layout));
-
- ::decode(xattrbl, p);
-
- if (features & CEPH_FEATURE_MDS_INLINE_DATA) {
- ::decode(inline_version, p);
- ::decode(inline_data, p);
- } else {
- inline_version = CEPH_INLINE_NONE;
- }
-
- if (features & CEPH_FEATURE_MDS_QUOTA)
- ::decode(quota, p);
- else
- memset("a, 0, sizeof(quota));
-
- if ((features & CEPH_FEATURE_FS_FILE_LAYOUT_V2))
- ::decode(layout.pool_ns, p);
- if ((features & CEPH_FEATURE_FS_BTIME)) {
- ::decode(btime, p);
- ::decode(change_attr, p);
- } else {
- btime = utime_t();
- change_attr = 0;
- }
- }
-
- // see CInode::encode_inodestat for encoder.
-};
-
-
-class MClientReply : public Message {
- // reply data
-public:
- struct ceph_mds_reply_head head;
- bufferlist trace_bl;
- bufferlist extra_bl;
- bufferlist snapbl;
-
- public:
- int get_op() const { return head.op; }
-
- void set_mdsmap_epoch(epoch_t e) { head.mdsmap_epoch = e; }
- epoch_t get_mdsmap_epoch() const { return head.mdsmap_epoch; }
-
- int get_result() const {
- return ceph_to_hostos_errno((__s32)(__u32)head.result);
- }
-
- void set_result(int r) { head.result = r; }
-
- void set_unsafe() { head.safe = 0; }
-
- bool is_safe() const { return head.safe; }
-
- MClientReply() : Message(CEPH_MSG_CLIENT_REPLY) {}
- MClientReply(MClientRequest *req, int result = 0) :
- Message(CEPH_MSG_CLIENT_REPLY) {
- memset(&head, 0, sizeof(head));
- header.tid = req->get_tid();
- head.op = req->get_op();
- head.result = result;
- head.safe = 1;
- }
-private:
- ~MClientReply() override {}
-
-public:
- const char *get_type_name() const override { return "creply"; }
- void print(ostream& o) const override {
- o << "client_reply(???:" << get_tid();
- o << " = " << get_result();
- if (get_result() <= 0) {
- o << " " << cpp_strerror(get_result());
- }
- if (head.op & CEPH_MDS_OP_WRITE) {
- if (head.safe)
- o << " safe";
- else
- o << " unsafe";
- }
- o << ")";
- }
-
- // serialization
- void decode_payload() override {
- bufferlist::iterator p = payload.begin();
- ::decode(head, p);
- ::decode(trace_bl, p);
- ::decode(extra_bl, p);
- ::decode(snapbl, p);
- assert(p.end());
- }
- void encode_payload(uint64_t features) override {
- ::encode(head, payload);
- ::encode(trace_bl, payload);
- ::encode(extra_bl, payload);
- ::encode(snapbl, payload);
- }
-
-
- // dir contents
- void set_extra_bl(bufferlist& bl) {
- extra_bl.claim(bl);
- }
- bufferlist &get_extra_bl() {
- return extra_bl;
- }
-
- // trace
- void set_trace(bufferlist& bl) {
- trace_bl.claim(bl);
- }
- bufferlist& get_trace_bl() {
- return trace_bl;
- }
-};
-
-#endif
Code Review / stor4nfv.git / blobdiff