1 // -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
2 // vim: ts=8 sw=2 smarttab
4 #ifndef CEPH_SCRUB_TYPES_H
5 #define CEPH_SCRUB_TYPES_H
7 #include "osd/osd_types.h"
9 // wrappers around scrub types to offer the necessary bits other than
10 // the minimal set that the lirados requires
11 struct object_id_wrapper : public librados::object_id_t {
12 object_id_wrapper(const hobject_t& hoid)
13 : object_id_t{hoid.oid.name, hoid.nspace, hoid.get_key(), hoid.snap}
15 void encode(bufferlist& bl) const;
16 void decode(bufferlist::iterator& bl);
19 WRITE_CLASS_ENCODER(object_id_wrapper)
21 inline void decode(librados::object_id_t& obj, bufferlist::iterator& bp) {
22 reinterpret_cast<object_id_wrapper&>(obj).decode(bp);
25 struct osd_shard_wrapper : public librados::osd_shard_t {
26 void encode(bufferlist& bl) const;
27 void decode(bufferlist::iterator& bp);
30 WRITE_CLASS_ENCODER(osd_shard_wrapper)
33 inline void decode(librados::osd_shard_t& shard, bufferlist::iterator& bp) {
34 reinterpret_cast<osd_shard_wrapper&>(shard).decode(bp);
38 struct shard_info_wrapper : public librados::shard_info_t {
40 shard_info_wrapper() = default;
41 shard_info_wrapper(const ScrubMap::object& object) {
44 void set_object(const ScrubMap::object& object);
46 errors |= err_t::SHARD_MISSING;
48 void set_omap_digest_mismatch_oi() {
49 errors |= err_t::OMAP_DIGEST_MISMATCH_OI;
51 void set_size_mismatch_oi() {
52 errors |= err_t::SIZE_MISMATCH_OI;
54 void set_data_digest_mismatch_oi() {
55 errors |= err_t::DATA_DIGEST_MISMATCH_OI;
57 void set_read_error() {
58 errors |= err_t::SHARD_READ_ERR;
60 void set_stat_error() {
61 errors |= err_t::SHARD_STAT_ERR;
63 void set_ec_hash_mismatch() {
64 errors |= err_t::SHARD_EC_HASH_MISMATCH;
66 void set_ec_size_mismatch() {
67 errors |= err_t::SHARD_EC_SIZE_MISMATCH;
69 void set_oi_attr_missing() {
70 errors |= err_t::OI_ATTR_MISSING;
72 void set_oi_attr_corrupted() {
73 errors |= err_t::OI_ATTR_CORRUPTED;
75 void set_ss_attr_missing() {
76 errors |= err_t::SS_ATTR_MISSING;
78 void set_ss_attr_corrupted() {
79 errors |= err_t::SS_ATTR_CORRUPTED;
81 void set_obj_size_oi_mismatch() {
82 errors |= err_t::OBJ_SIZE_OI_MISMATCH;
84 void encode(bufferlist& bl) const;
85 void decode(bufferlist::iterator& bp);
88 WRITE_CLASS_ENCODER(shard_info_wrapper)
91 inline void decode(librados::shard_info_t& shard,
92 bufferlist::iterator& bp) {
93 reinterpret_cast<shard_info_wrapper&>(shard).decode(bp);
97 struct inconsistent_obj_wrapper : librados::inconsistent_obj_t {
98 inconsistent_obj_wrapper(const hobject_t& hoid);
100 void set_object_info_inconsistency() {
101 errors |= obj_err_t::OBJECT_INFO_INCONSISTENCY;
103 void set_omap_digest_mismatch() {
104 errors |= obj_err_t::OMAP_DIGEST_MISMATCH;
106 void set_data_digest_mismatch() {
107 errors |= obj_err_t::DATA_DIGEST_MISMATCH;
109 void set_size_mismatch() {
110 errors |= obj_err_t::SIZE_MISMATCH;
112 void set_attr_value_mismatch() {
113 errors |= obj_err_t::ATTR_VALUE_MISMATCH;
115 void set_attr_name_mismatch() {
116 errors |= obj_err_t::ATTR_NAME_MISMATCH;
118 void add_shard(const pg_shard_t& pgs, const shard_info_wrapper& shard);
119 void set_auth_missing(const hobject_t& hoid,
120 const map<pg_shard_t, ScrubMap*>&,
121 map<pg_shard_t, shard_info_wrapper>&,
122 int &shallow_errors, int &deep_errors,
123 const pg_shard_t &primary);
124 void set_version(uint64_t ver) { version = ver; }
125 void encode(bufferlist& bl) const;
126 void decode(bufferlist::iterator& bp);
129 WRITE_CLASS_ENCODER(inconsistent_obj_wrapper)
131 inline void decode(librados::inconsistent_obj_t& obj,
132 bufferlist::iterator& bp) {
133 reinterpret_cast<inconsistent_obj_wrapper&>(obj).decode(bp);
136 struct inconsistent_snapset_wrapper : public librados::inconsistent_snapset_t {
137 inconsistent_snapset_wrapper() = default;
138 inconsistent_snapset_wrapper(const hobject_t& head);
140 // soid claims that it is a head or a snapdir, but its SS_ATTR
142 void set_ss_attr_missing();
143 void set_oi_attr_missing();
144 void set_ss_attr_corrupted();
145 void set_oi_attr_corrupted();
146 // snapset with missing clone
147 void set_clone_missing(snapid_t);
148 // Clones that are there
149 void set_clone(snapid_t);
150 // the snapset is not consistent with itself
151 void set_snapset_mismatch();
152 // soid.snap inconsistent with snapset
153 void set_head_mismatch();
154 void set_size_mismatch();
156 void encode(bufferlist& bl) const;
157 void decode(bufferlist::iterator& bp);
160 WRITE_CLASS_ENCODER(inconsistent_snapset_wrapper)
163 inline void decode(librados::inconsistent_snapset_t& snapset,
164 bufferlist::iterator& bp) {
165 reinterpret_cast<inconsistent_snapset_wrapper&>(snapset).decode(bp);
169 struct scrub_ls_arg_t {
171 uint32_t get_snapsets;
172 librados::object_id_t start_after;
174 void encode(bufferlist& bl) const;
175 void decode(bufferlist::iterator& bl);
178 WRITE_CLASS_ENCODER(scrub_ls_arg_t);
180 struct scrub_ls_result_t {
182 std::vector<bufferlist> vals;
183 void encode(bufferlist& bl) const;
184 void decode(bufferlist::iterator& bl);
187 WRITE_CLASS_ENCODER(scrub_ls_result_t);