Incorrect revisions sweep stats
@@ -89,9 +89,9 @@ public final class SweepHelper {
}
private void trackStats(Iterable<UpdateOp> ops) {
+ for (UpdateOp op : ops) {
boolean bcUpdate = false;
boolean revertUpdate = false;
- for (UpdateOp op : ops) {
for (UpdateOp.Operation o : op.getChanges().values()) {
if (o.type == SET_MAP_ENTRY) {
bcUpdate = true;
@@ -99,7 +99,6 @@ public final class SweepHelper {
revertUpdate = true;
}
}
- }
if (bcUpdate) {
bcUpdates.incrementAndGet();
}
@@ -107,6 +106,7 @@ public final class SweepHelper {
revertUpdates.incrementAndGet();
}
}
+ }
});
time = System.currentTimeMillis() - time;
// write back sweep revision if none was there or revisions were swept
