From: Sage Weil <sage@inktank.com>
Date: Thu, 27 Mar 2014 20:51:15 +0000 (-0700)
Subject: osd/ReplicatedPG: improve clone vs head checking
X-Git-Tag: v0.79~72^2~1
X-Git-Url: http://git.apps.os.sepia.ceph.com/?a=commitdiff_plain;h=6508d5efe31f8c6d058a65f693c7faa788f6213e;p=ceph.git

osd/ReplicatedPG: improve clone vs head checking

- notice when we are missing a clone (that isn't at the end of the list)
- notice when we are missing a clone on the last object in the scrub map
- do not assert when we are missing a clone

There is still more we could do to improve this (like noticing one missing
clone but still checking the others), but we'll leave that aside for just
a moment...

Signed-off-by: Sage Weil <sage@inktank.com>
---

diff --git a/src/osd/ReplicatedPG.cc b/src/osd/ReplicatedPG.cc
index 1e9584b4be7a1..53c877a292997 100644
--- a/src/osd/ReplicatedPG.cc
+++ b/src/osd/ReplicatedPG.cc
@@ -11028,6 +11028,7 @@ void ReplicatedPG::_scrub(ScrubMap& scrubmap)
   hobject_t head;
   SnapSet snapset;
   vector<snapid_t>::reverse_iterator curclone;
+  hobject_t next_clone;
 
   bufferlist last_data;
 
@@ -11066,6 +11067,7 @@ void ReplicatedPG::_scrub(ScrubMap& scrubmap)
       else {
 	curclone = snapset.clones.rbegin();
 	head = p->first;
+	next_clone = hobject_t();
 	dout(20) << "  snapset " << snapset << dendl;
       }
 
@@ -11121,6 +11123,12 @@ void ReplicatedPG::_scrub(ScrubMap& scrubmap)
     //assert(data.length() == p->size);
     //
 
+    if (!next_clone.is_min() && next_clone != soid) {
+      osd->clog.error() << mode << " " << info.pgid << " " << soid
+			<< " expected clone " << next_clone;
+      ++scrubber.shallow_errors;
+    }
+
     if (soid.snap == CEPH_NOSNAP) {
       if (!snapset.head_exists) {
 	osd->clog.error() << mode << " " << info.pgid << " " << soid
@@ -11128,6 +11136,12 @@ void ReplicatedPG::_scrub(ScrubMap& scrubmap)
         ++scrubber.shallow_errors;
 	continue;
       }
+      if (curclone == snapset.clones.rend()) {
+	next_clone = hobject_t();
+      } else {
+	next_clone = soid;
+	next_clone.snap = *curclone;
+      }
     } else if (soid.snap) {
       // it's a clone
       stat.num_object_clones++;
@@ -11140,16 +11154,13 @@ void ReplicatedPG::_scrub(ScrubMap& scrubmap)
       }
 
       if (soid.snap != *curclone) {
-	osd->clog.error() << mode << " " << info.pgid << " " << soid
-			  << " expected clone " << *curclone;
-        ++scrubber.shallow_errors;
-	assert(soid.snap == *curclone);
+	continue; // we warn above.  we could do better here...
       }
 
       if (oi.size != snapset.clone_size[*curclone]) {
 	osd->clog.error() << mode << " " << info.pgid << " " << soid
 			  << " size " << oi.size << " != clone_size "
-			  << snapset.cloen_size[*curclone];
+			  << snapset.clone_size[*curclone];
 	++scrubber.shallow_errors;
       }
 
@@ -11157,19 +11168,30 @@ void ReplicatedPG::_scrub(ScrubMap& scrubmap)
       // ...
 
       // what's next?
-      if (curclone != snapset.clones.rend())
+      if (curclone != snapset.clones.rend()) {
 	++curclone;
-
-      if (curclone == snapset.clones.rend())
+      }
+      if (curclone == snapset.clones.rend()) {
 	head = hobject_t();
+	next_clone = hobject_t();
+      } else {
+	next_clone.snap = *curclone;
+      }
 
     } else {
       // it's unversioned.
+      next_clone = hobject_t();
     }
 
     string cat; // fixme
     scrub_cstat.add(stat, cat);
   }
+
+  if (!next_clone.is_min()) {
+    osd->clog.error() << mode << " " << info.pgid
+		      << " expected clone " << next_clone;
+    ++scrubber.shallow_errors;
+  }
   
   dout(10) << "_scrub (" << mode << ") finish" << dendl;
 }