+++ /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_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<OSDOp> ops;
-private:
-
- snapid_t snapid;
- snapid_t snap_seq;
- vector<snapid_t> 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<snapid_t> &get_snaps() const { return snaps; }
- void set_snaps(const vector<snapid_t>& 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
projects / ceph-ci.git / commitdiff