X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fmessages%2FMMDSSlaveRequest.h;fp=src%2Fceph%2Fsrc%2Fmessages%2FMMDSSlaveRequest.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=9e7510c9a6df803bb86042758802261496a8cde0;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/messages/MMDSSlaveRequest.h b/src/ceph/src/messages/MMDSSlaveRequest.h deleted file mode 100644 index 9e7510c..0000000 --- a/src/ceph/src/messages/MMDSSlaveRequest.h +++ /dev/null @@ -1,211 +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_MMDSSLAVEREQUEST_H -#define CEPH_MMDSSLAVEREQUEST_H - -#include "msg/Message.h" -#include "mds/mdstypes.h" - -class MMDSSlaveRequest : public Message { - public: - static const int OP_XLOCK = 1; - static const int OP_XLOCKACK = -1; - static const int OP_UNXLOCK = 2; - static const int OP_AUTHPIN = 3; - static const int OP_AUTHPINACK = -3; - - static const int OP_LINKPREP = 4; - static const int OP_UNLINKPREP = 5; - static const int OP_LINKPREPACK = -4; - - static const int OP_RENAMEPREP = 7; - static const int OP_RENAMEPREPACK = -7; - - static const int OP_WRLOCK = 8; - static const int OP_WRLOCKACK = -8; - static const int OP_UNWRLOCK = 9; - - static const int OP_RMDIRPREP = 10; - static const int OP_RMDIRPREPACK = -10; - - static const int OP_DROPLOCKS = 11; - - static const int OP_RENAMENOTIFY = 12; - static const int OP_RENAMENOTIFYACK = -12; - - static const int OP_FINISH = 17; - static const int OP_COMMITTED = -18; - - static const int OP_ABORT = 20; // used for recovery only - //static const int OP_COMMIT = 21; // used for recovery only - - - const static char *get_opname(int o) { - switch (o) { - case OP_XLOCK: return "xlock"; - case OP_XLOCKACK: return "xlock_ack"; - case OP_UNXLOCK: return "unxlock"; - case OP_AUTHPIN: return "authpin"; - case OP_AUTHPINACK: return "authpin_ack"; - - case OP_LINKPREP: return "link_prep"; - case OP_LINKPREPACK: return "link_prep_ack"; - case OP_UNLINKPREP: return "unlink_prep"; - - case OP_RENAMEPREP: return "rename_prep"; - case OP_RENAMEPREPACK: return "rename_prep_ack"; - - case OP_FINISH: return "finish"; // commit - case OP_COMMITTED: return "committed"; - - case OP_WRLOCK: return "wrlock"; - case OP_WRLOCKACK: return "wrlock_ack"; - case OP_UNWRLOCK: return "unwrlock"; - - case OP_RMDIRPREP: return "rmdir_prep"; - case OP_RMDIRPREPACK: return "rmdir_prep_ack"; - - case OP_DROPLOCKS: return "drop_locks"; - - case OP_RENAMENOTIFY: return "rename_notify"; - case OP_RENAMENOTIFYACK: return "rename_notify_ack"; - - case OP_ABORT: return "abort"; - //case OP_COMMIT: return "commit"; - - default: ceph_abort(); return 0; - } - } - - private: - metareqid_t reqid; - __u32 attempt; - __s16 op; - __u16 flags; - - static const unsigned FLAG_NONBLOCK = 1<<0; - static const unsigned FLAG_WOULDBLOCK = 1<<1; - static const unsigned FLAG_NOTJOURNALED = 1<<2; - static const unsigned FLAG_EROFS = 1<<3; - static const unsigned FLAG_ABORT = 1<<4; - static const unsigned FLAG_INTERRUPTED = 1<<5; - - // for locking - __u16 lock_type; // lock object type - MDSCacheObjectInfo object_info; - - // for authpins - vector authpins; - - public: - // for rename prep - filepath srcdnpath; - filepath destdnpath; - set witnesses; - bufferlist inode_export; - version_t inode_export_v; - bufferlist srci_replica; - mds_rank_t srcdn_auth; - utime_t op_stamp; - - bufferlist stray; // stray dir + dentry - -public: - metareqid_t get_reqid() { return reqid; } - __u32 get_attempt() const { return attempt; } - int get_op() { return op; } - bool is_reply() { return op < 0; } - - int get_lock_type() { return lock_type; } - MDSCacheObjectInfo &get_object_info() { return object_info; } - MDSCacheObjectInfo &get_authpin_freeze() { return object_info; } - - vector& get_authpins() { return authpins; } - void mark_nonblock() { flags |= FLAG_NONBLOCK; } - bool is_nonblock() { return (flags & FLAG_NONBLOCK); } - void mark_error_wouldblock() { flags |= FLAG_WOULDBLOCK; } - bool is_error_wouldblock() { return (flags & FLAG_WOULDBLOCK); } - void mark_not_journaled() { flags |= FLAG_NOTJOURNALED; } - bool is_not_journaled() { return (flags & FLAG_NOTJOURNALED); } - void mark_error_rofs() { flags |= FLAG_EROFS; } - bool is_error_rofs() { return (flags & FLAG_EROFS); } - bool is_abort() { return (flags & FLAG_ABORT); } - void mark_abort() { flags |= FLAG_ABORT; } - bool is_interrupted() { return (flags & FLAG_INTERRUPTED); } - void mark_interrupted() { flags |= FLAG_INTERRUPTED; } - - void set_lock_type(int t) { lock_type = t; } - - - // ---- - MMDSSlaveRequest() : Message(MSG_MDS_SLAVE_REQUEST) { } - MMDSSlaveRequest(metareqid_t ri, __u32 att, int o) : - Message(MSG_MDS_SLAVE_REQUEST), - reqid(ri), attempt(att), op(o), flags(0), lock_type(0), - inode_export_v(0), srcdn_auth(MDS_RANK_NONE) { } -private: - ~MMDSSlaveRequest() override {} - -public: - void encode_payload(uint64_t features) override { - ::encode(reqid, payload); - ::encode(attempt, payload); - ::encode(op, payload); - ::encode(flags, payload); - ::encode(lock_type, payload); - ::encode(object_info, payload); - ::encode(authpins, payload); - ::encode(srcdnpath, payload); - ::encode(destdnpath, payload); - ::encode(witnesses, payload); - ::encode(op_stamp, payload); - ::encode(inode_export, payload); - ::encode(inode_export_v, payload); - ::encode(srcdn_auth, payload); - ::encode(srci_replica, payload); - ::encode(stray, payload); - } - void decode_payload() override { - bufferlist::iterator p = payload.begin(); - ::decode(reqid, p); - ::decode(attempt, p); - ::decode(op, p); - ::decode(flags, p); - ::decode(lock_type, p); - ::decode(object_info, p); - ::decode(authpins, p); - ::decode(srcdnpath, p); - ::decode(destdnpath, p); - ::decode(witnesses, p); - ::decode(op_stamp, p); - ::decode(inode_export, p); - ::decode(inode_export_v, p); - ::decode(srcdn_auth, p); - ::decode(srci_replica, p); - ::decode(stray, p); - } - - const char *get_type_name() const override { return "slave_request"; } - void print(ostream& out) const override { - out << "slave_request(" << reqid - << "." << attempt - << " " << get_opname(op) - << ")"; - } - -}; - -#endif