X-Git-Url: https://git.proxmox.com/?p=ceph.git;a=blobdiff_plain;f=ceph%2Fsrc%2Fmds%2FPurgeQueue.cc;h=cec43ecd34704cc3972a5372712778d62b717203;hp=49e48b04cc6d12700a4ff97ab149177a8a2f5c2b;hb=28e407b858acd3bddc89f68583571f771bb42e46;hpb=dfcb7b53b2e4fcd2a5af0240d4975adc711ab96e diff --git a/ceph/src/mds/PurgeQueue.cc b/ceph/src/mds/PurgeQueue.cc index 49e48b04c..cec43ecd3 100644 --- a/ceph/src/mds/PurgeQueue.cc +++ b/ceph/src/mds/PurgeQueue.cc @@ -350,7 +350,6 @@ bool PurgeQueue::_consume() bool could_consume = false; while(can_consume()) { - could_consume = true; if (delayed_flush) { // We are now going to read from the journal, so any proactive @@ -376,6 +375,7 @@ bool PurgeQueue::_consume() return could_consume; } + could_consume = true; // The journaler is readable: consume an entry bufferlist bl; bool readable = journaler.try_read_entry(bl);