From: Abhishek Lekshmanan Date: Wed, 27 Jan 2016 22:16:00 +0000 (+0100) Subject: remove unused source file X-Git-Tag: v10.0.4~141^2~1 X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=e9420511028e15775afcc3081018e249ad458125;p=ceph-ci.git remove unused source file This file was possibly accidentally committed in the tree, thanks @BranchPredictor for bringing this up in irc Signed-off-by: Abhishek Lekshmanan --- diff --git a/src/messages/#MOSDOp.h# b/src/messages/#MOSDOp.h# deleted file mode 100644 index 8de809fab7c..00000000000 --- a/src/messages/#MOSDOp.h# +++ /dev/null @@ -1,397 +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_MOSDOP_H -#define CEPH_MOSDOP_H - -#include "msg/Message.h" -#include "osd/osd_types.h" -#include "include/ceph_features.h" - -/* - * OSD op - * - * oid - object id - * op - OSD_OP_DELETE, etc. - * - */ - -class OSD; - -class MOSDOp : public Message { - - static const int HEAD_VERSION = 5; - static const int COMPAT_VERSION = 3; - -private: - uint32_t client_inc; -/ __u32 osdmap_epoch; - __u32 flags; - utime_t mtime; - eversion_t reassert_version; - int32_t retry_attempt; // 0 is first attempt. -1 if we don't know. - -? object_t oid; - object_locator_t oloc; -/ pg_t pgid; -public: - vector ops; -private: - - snapid_t snapid; - snapid_t snap_seq; - vector snaps; - - uint64_t features; - -public: - friend class MOSDOpReply; - - // read - const snapid_t& get_snapid() { return snapid; } - void set_snapid(const snapid_t& s) { snapid = s; } - // writ - const snapid_t& get_snap_seq() const { return snap_seq; } - const vector &get_snaps() const { return snaps; } - void set_snaps(const vector& i) { - snaps = i; - } - void set_snap_seq(const snapid_t& s) { snap_seq = s; } - - osd_reqid_t get_reqid() const { - return osd_reqid_t(get_orig_source(), - client_inc, - header.tid); - } - int get_client_inc() { return client_inc; } - ceph_tid_t get_client_tid() { return header.tid; } - - object_t& get_oid() { return oid; } - - const pg_t& get_pg() const { return pgid; } - - const object_locator_t& get_object_locator() const { - return oloc; - } - - epoch_t get_map_epoch() { return osdmap_epoch; } - - const eversion_t& get_version() { return reassert_version; } - - utime_t get_mtime() { return mtime; } - - MOSDOp() - : Message(CEPH_MSG_OSD_OP, HEAD_VERSION, COMPAT_VERSION) { } - MOSDOp(int inc, long tid, - object_t& _oid, object_locator_t& _oloc, pg_t& _pgid, epoch_t _osdmap_epoch, - int _flags, uint64_t feat) - : Message(CEPH_MSG_OSD_OP, HEAD_VERSION, COMPAT_VERSION), - client_inc(inc), - osdmap_epoch(_osdmap_epoch), flags(_flags), retry_attempt(-1), - oid(_oid), oloc(_oloc), pgid(_pgid), - features(feat) { - set_tid(tid); - } -private: - ~MOSDOp() {} - -public: - void set_version(eversion_t v) { reassert_version = v; } - void set_mtime(utime_t mt) { mtime = mt; } - - // ops - void add_simple_op(int o, uint64_t off, uint64_t len) { - OSDOp osd_op; - osd_op.op.op = o; - osd_op.op.extent.offset = off; - osd_op.op.extent.length = len; - ops.push_back(osd_op); - } - void write(uint64_t off, uint64_t len, bufferlist& bl) { - add_simple_op(CEPH_OSD_OP_WRITE, off, len); - data.claim(bl); - header.data_off = off; - } - void writefull(bufferlist& bl) { - add_simple_op(CEPH_OSD_OP_WRITEFULL, 0, bl.length()); - data.claim(bl); - header.data_off = 0; - } - void zero(uint64_t off, uint64_t len) { - add_simple_op(CEPH_OSD_OP_ZERO, off, len); - } - void truncate(uint64_t off) { - add_simple_op(CEPH_OSD_OP_TRUNCATE, off, 0); - } - void remove() { - add_simple_op(CEPH_OSD_OP_DELETE, 0, 0); - } - - void read(uint64_t off, uint64_t len) { - add_simple_op(CEPH_OSD_OP_READ, off, len); - } - void stat() { - add_simple_op(CEPH_OSD_OP_STAT, 0, 0); - } - - uint64_t get_features() const { - if (features) - return features; - return get_connection()->get_features(); - } - - // flags - int get_flags() const { return flags; } - bool has_flag(__u32 flag) { return flags & flag; }; - - bool wants_ack() const { return flags & CEPH_OSD_FLAG_ACK; } - bool wants_ondisk() const { return flags & CEPH_OSD_FLAG_ONDISK; } - bool wants_onnvram() const { return flags & CEPH_OSD_FLAG_ONNVRAM; } - - void set_want_ack(bool b) { flags |= CEPH_OSD_FLAG_ACK; } - void set_want_onnvram(bool b) { flags |= CEPH_OSD_FLAG_ONNVRAM; } - void set_want_ondisk(bool b) { flags |= CEPH_OSD_FLAG_ONDISK; } - - bool is_retry_attempt() const { return flags & CEPH_OSD_FLAG_RETRY; } - void set_retry_attempt(unsigned a) { - if (a) - flags |= CEPH_OSD_FLAG_RETRY; - else - flags &= ~CEPH_OSD_FLAG_RETRY; - retry_attempt = a; - } - - /** - * get retry attempt - * - * 0 is the first attempt. - * - * @return retry attempt, or -1 if we don't know - */ - int get_retry_attempt() const { - return retry_attempt; - } - - // marshalling - virtual void encode_payload(uint64_t features) { - - OSDOp::merge_osd_op_vector_in_data(ops, data); - - if ((features & CEPH_FEATURE_OBJECTLOCATOR) == 0) { - // here is the old structure we are encoding to: // -#if 0 -struct ceph_osd_request_head { - __le32 client_inc; /* client incarnation */ - struct ceph_object_layout layout; /* pgid */ - __le32 osdmap_epoch; /* client's osdmap epoch */ - - __le32 flags; - - struct ceph_timespec mtime; /* for mutations only */ - struct ceph_eversion reassert_version; /* if we are replaying op */ - - __le32 object_len; /* length of object name */ - - __le64 snapid; /* snapid to read */ - __le64 snap_seq; /* writer's snap context */ - __le32 num_snaps; - - __le16 num_ops; - struct ceph_osd_op ops[]; /* followed by ops[], obj, ticket, snaps */ -} __attribute__ ((packed)); -#endif - header.version = 1; - - ::encode(client_inc, payload); - - __u32 su = 0; - ::encode(pgid, payload); - ::encode(su, payload); - - ::encode(osdmap_epoch, payload); - ::encode(flags, payload); - ::encode(mtime, payload); - ::encode(reassert_version, payload); - - __u32 oid_len = oid.name.length(); - ::encode(oid_len, payload); - ::encode(snapid, payload); - ::encode(snap_seq, payload); - __u32 num_snaps = snaps.size(); - ::encode(num_snaps, payload); - - //::encode(ops, payload); - __u16 num_ops = ops.size(); - ::encode(num_ops, payload); - for (unsigned i = 0; i < ops.size(); i++) - ::encode(ops[i].op, payload); - - ::encode_nohead(oid.name, payload); - ::encode_nohead(snaps, payload); - } else { - ::encode(client_inc, payload); - ::encode(osdmap_epoch, payload); - ::encode(flags, payload); - ::encode(mtime, payload); - ::encode(reassert_version, payload); - - ::encode(oloc, payload); - ::encode(pgid, payload); - ::encode(oid, payload); - - __u16 num_ops = ops.size(); - ::encode(num_ops, payload); - for (unsigned i = 0; i < ops.size(); i++) - ::encode(ops[i].op, payload); - - ::encode(snapid, payload); - ::encode(snap_seq, payload); - ::encode(snaps, payload); - - ::encode(retry_attempt, payload); - ::encode(features, payload); - } - } - - virtual void decode_payload() { - bufferlist::iterator p = payload.begin(); - - if (header.version < 2) { - // old decode - ::decode(client_inc, p); - - old_pg_t opgid; - ::decode_raw(opgid, p); - pgid = opgid; - - __u32 su; - ::decode(su, p); - oloc.pool = pgid.pool(); - - ::decode(osdmap_epoch, p); - ::decode(flags, p); - ::decode(mtime, p); - ::decode(reassert_version, p); - - __u32 oid_len; - ::decode(oid_len, p); - ::decode(snapid, p); - ::decode(snap_seq, p); - __u32 num_snaps; - ::decode(num_snaps, p); - - //::decode(ops, p); - __u16 num_ops; - ::decode(num_ops, p); - ops.resize(num_ops); - for (unsigned i = 0; i < num_ops; i++) - ::decode(ops[i].op, p); - - decode_nohead(oid_len, oid.name, p); - decode_nohead(num_snaps, snaps, p); - - // recalculate pgid hash value - pgid.set_ps(ceph_str_hash(CEPH_STR_HASH_RJENKINS, - oid.name.c_str(), - oid.name.length())); - - retry_attempt = -1; - features = 0; - } else { - // new decode - ::decode(client_inc, p); - ::decode(osdmap_epoch, p); - ::decode(flags, p); - ::decode(mtime, p); - ::decode(reassert_version, p); - - ::decode(oloc, p); - - if (header.version < 3) { - old_pg_t opgid; - ::decode_raw(opgid, p); - pgid = opgid; - } else { - ::decode(pgid, p); - } - - ::decode(oid, p); - - //::decode(ops, p); - __u16 num_ops; - ::decode(num_ops, p); - ops.resize(num_ops); - for (unsigned i = 0; i < num_ops; i++) - ::decode(ops[i].op, p); - - ::decode(snapid, p); - ::decode(snap_seq, p); - ::decode(snaps, p); - - if (header.version >= 4) - ::decode(retry_attempt, p); - else - retry_attempt = -1; - - if (header.version >= 5) - ::decode(features, p); - else - features = 0; - } - - OSDOp::split_osd_op_vector_in_data(ops, data); - } - - void clear_buffers() { - ops.clear(); - } - - const char *get_type_name() const { return "osd_op"; } - void print(ostream& out) const { - out << "osd_op(" << get_reqid(); - out << " "; - if (!oloc.nspace.empty()) - out << oloc.nspace << "/"; - out << oid; - -#if 0 - out << " "; - if (may_read()) - out << "r"; - if (may_write()) - out << "w"; -#endif - if (snapid != CEPH_NOSNAP) - out << "@" << snapid; - - if (oloc.key.size()) - out << " " << oloc; - - out << " " << ops; - out << " " << pgid; - if (is_retry_attempt()) - out << " RETRY=" << get_retry_attempt(); - if (reassert_version != eversion_t()) - out << " reassert_version=" << reassert_version; - if (get_snap_seq()) - out << " snapc " << get_snap_seq() << "=" << snaps; - out << " " << ceph_osd_flag_string(get_flags()); - out << " e" << osdmap_epoch; - out << ")"; - } -}; - - -#endif