X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;f=src%2Fceph%2Fsrc%2Fosd%2FECMsgTypes.h;fp=src%2Fceph%2Fsrc%2Fosd%2FECMsgTypes.h;h=0000000000000000000000000000000000000000;hb=7da45d65be36d36b880cc55c5036e96c24b53f00;hp=bfcb5361ae1f04c4be19862c14cbbb85a666f802;hpb=691462d09d0987b47e112d6ee8740375df3c51b2;p=stor4nfv.git diff --git a/src/ceph/src/osd/ECMsgTypes.h b/src/ceph/src/osd/ECMsgTypes.h deleted file mode 100644 index bfcb536..0000000 --- a/src/ceph/src/osd/ECMsgTypes.h +++ /dev/null @@ -1,139 +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) 2013 Inktank Storage, Inc. - * - * 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 ECBMSGTYPES_H -#define ECBMSGTYPES_H - -#include "osd_types.h" -#include "include/buffer.h" -#include "os/ObjectStore.h" -#include "boost/tuple/tuple.hpp" - -struct ECSubWrite { - pg_shard_t from; - ceph_tid_t tid; - osd_reqid_t reqid; - hobject_t soid; - pg_stat_t stats; - ObjectStore::Transaction t; - eversion_t at_version; - eversion_t trim_to; - eversion_t roll_forward_to; - vector log_entries; - set temp_added; - set temp_removed; - boost::optional updated_hit_set_history; - bool backfill = false; - ECSubWrite() : tid(0) {} - ECSubWrite( - pg_shard_t from, - ceph_tid_t tid, - osd_reqid_t reqid, - hobject_t soid, - const pg_stat_t &stats, - const ObjectStore::Transaction &t, - eversion_t at_version, - eversion_t trim_to, - eversion_t roll_forward_to, - vector log_entries, - boost::optional updated_hit_set_history, - const set &temp_added, - const set &temp_removed, - bool backfill) - : from(from), tid(tid), reqid(reqid), - soid(soid), stats(stats), t(t), - at_version(at_version), - trim_to(trim_to), roll_forward_to(roll_forward_to), - log_entries(log_entries), - temp_added(temp_added), - temp_removed(temp_removed), - updated_hit_set_history(updated_hit_set_history), - backfill(backfill) - {} - void claim(ECSubWrite &other) { - from = other.from; - tid = other.tid; - reqid = other.reqid; - soid = other.soid; - stats = other.stats; - t.swap(other.t); - at_version = other.at_version; - trim_to = other.trim_to; - roll_forward_to = other.roll_forward_to; - log_entries.swap(other.log_entries); - temp_added.swap(other.temp_added); - temp_removed.swap(other.temp_removed); - updated_hit_set_history = other.updated_hit_set_history; - backfill = other.backfill; - } - void encode(bufferlist &bl) const; - void decode(bufferlist::iterator &bl); - void dump(Formatter *f) const; - static void generate_test_instances(list& o); -private: - // no outside copying -- slow - ECSubWrite(ECSubWrite& other); - const ECSubWrite& operator=(const ECSubWrite& other); -}; -WRITE_CLASS_ENCODER(ECSubWrite) - -struct ECSubWriteReply { - pg_shard_t from; - ceph_tid_t tid; - eversion_t last_complete; - bool committed; - bool applied; - ECSubWriteReply() : tid(0), committed(false), applied(false) {} - void encode(bufferlist &bl) const; - void decode(bufferlist::iterator &bl); - void dump(Formatter *f) const; - static void generate_test_instances(list& o); -}; -WRITE_CLASS_ENCODER(ECSubWriteReply) - -struct ECSubRead { - pg_shard_t from; - ceph_tid_t tid; - map >> to_read; - set attrs_to_read; - void encode(bufferlist &bl, uint64_t features) const; - void decode(bufferlist::iterator &bl); - void dump(Formatter *f) const; - static void generate_test_instances(list& o); -}; -WRITE_CLASS_ENCODER_FEATURES(ECSubRead) - -struct ECSubReadReply { - pg_shard_t from; - ceph_tid_t tid; - map >> buffers_read; - map> attrs_read; - map errors; - void encode(bufferlist &bl) const; - void decode(bufferlist::iterator &bl); - void dump(Formatter *f) const; - static void generate_test_instances(list& o); -}; -WRITE_CLASS_ENCODER(ECSubReadReply) - -std::ostream &operator<<( - std::ostream &lhs, const ECSubWrite &rhs); -std::ostream &operator<<( - std::ostream &lhs, const ECSubWriteReply &rhs); -std::ostream &operator<<( - std::ostream &lhs, const ECSubRead &rhs); -std::ostream &operator<<( - std::ostream &lhs, const ECSubReadReply &rhs); - -#endif