full_commit_seq = seq;
full_restart_seq = seq+1;
while (!writeq.empty()) {
- writing_seq.push_back(writeq.front().seq);
- writing_fin.push_back(writeq.front().fin);
+ if (writeq.front().fin) {
+ writing_seq.push_back(writeq.front().seq);
+ writing_fin.push_back(writeq.front().fin);
+ }
writeq.pop_front();
}
print_header();
// not journaling this. restart writing no sooner than seq + 1.
full_restart_seq = seq+1;
dout(10) << " journal is/was full, will restart no sooner than seq " << full_restart_seq << dendl;
- writing_seq.push_back(seq);
- writing_fin.push_back(oncommit);
+ if (oncommit) {
+ writing_seq.push_back(seq);
+ writing_fin.push_back(oncommit);
+ }
}
}