]> git.apps.os.sepia.ceph.com Git - ceph-ci.git/commitdiff
keep original format of Finisher.cc
authorPan Liu <pan.liu@istuary.com>
Thu, 27 Oct 2016 10:16:28 +0000 (18:16 +0800)
committerPan Liu <pan.liu@istuary.com>
Thu, 27 Oct 2016 10:16:28 +0000 (18:16 +0800)
Signed-off-by: Pan Liu pan.liu@istuary.com
src/common/Finisher.cc

index a4301f064e847decf280047ce2e4762a53edf934..7e2625768a84b8dbe6a7cf9bf59922b7d4b88e9c 100644 (file)
@@ -63,25 +63,25 @@ void *Finisher::finisher_thread_entry()
 
       // Now actually process the contexts.
       for (vector<Context*>::iterator p = ls.begin();
-           p != ls.end();
-           ++p) {
-        if (*p) {
-          (*p)->complete(0);
-        } else {
-          // When an item is NULL in the finisher_queue, it means
-          // we should instead process an item from finisher_queue_rval,
-          // which has a parameter for complete() other than zero.
-          // This preserves the order while saving some storage.
-          assert(!ls_rval.empty());
-          Context *c = ls_rval.front().first;
-          c->complete(ls_rval.front().second);
-          ls_rval.pop_front();
-        }
-        if (logger) {
-          logger->dec(l_finisher_queue_len);
+          p != ls.end();
+          ++p) {
+       if (*p) {
+         (*p)->complete(0);
+       } else {
+         // When an item is NULL in the finisher_queue, it means
+         // we should instead process an item from finisher_queue_rval,
+         // which has a parameter for complete() other than zero.
+         // This preserves the order while saving some storage.
+         assert(!ls_rval.empty());
+         Context *c = ls_rval.front().first;
+         c->complete(ls_rval.front().second);
+         ls_rval.pop_front();
+       }
+       if (logger) {
+         logger->dec(l_finisher_queue_len);
           end = ceph_clock_now(cct);
-          logger->tinc(l_finisher_complete_lat, end - start);
-          start = end;
+         logger->tinc(l_finisher_complete_lat, end - start);
+         start = end;
         }
       }
       ldout(cct, 10) << "finisher_thread done with " << ls << dendl;