OSD::PeeringWQ::_dequeue(PG*) drop pg refs

Signed-off-by: Samuel Just <sam.just@inktank.com>

diff --git a/src/osd/OSD.h b/src/osd/OSD.h
index 2fefde1ac32e42461d66768a638806c9651dbb60..bfbecca3cf1b2f9207930fd8670b82194d5b389b 100644 (file)
--- a/src/osd/OSD.h
+++ b/src/osd/OSD.h
@@ -581,10 +581,12 @@ private:
       for (list<PG*>::iterator i = peering_queue.begin();
           i != peering_queue.end();
           ) {
-       if (*i == pg)
+       if (*i == pg) {
          peering_queue.erase(i++);
-       else
+         pg->put();
+       } else {
          ++i;
+       }
       }
     }
     bool _enqueue(PG *pg) {