return;
}
- dout(5) << "submit_entry " << journaler->get_write_pos() << " : " << *le << dendl;
-
// let the event register itself in the segment
assert(!segments.empty());
le->_segment = segments.rbegin()->second;
bufferlist bl;
::encode(le->_type, bl);
le->encode(bl);
-
+
+ dout(5) << "submit_entry " << journaler->get_write_pos() << "~" << bl.length()
+ << " : " << *le << dendl;
+
// journal it.
journaler->append_entry(bl); // bl is destroyed.
}
// have we seen an import map yet?
if (segments.empty()) {
- dout(10) << "_replay " << pos << " / " << journaler->get_write_pos()
+ dout(10) << "_replay " << pos << "~" << bl.length() << " / " << journaler->get_write_pos()
<< " -- waiting for subtree_map. (skipping " << *le << ")" << dendl;
} else {
- dout(10) << "_replay " << pos << " / " << journaler->get_write_pos()
+ dout(10) << "_replay " << pos << "~" << bl.length() << " / " << journaler->get_write_pos()
<< " : " << *le << dendl;
le->_segment = get_current_segment(); // replay may need this
le->_segment->num_events++;