Signed-off-by: Yingxin Cheng <yingxin.cheng@intel.com>
assert(state != state_t::SUBMITTING);
assert(can_batch(record, block_size).value() == new_size);
- auto dlength_offset = pending.current_dlength;
+ auto dlength_offset = pending.size.dlength;
pending.push_back(
std::move(record), block_size);
assert(pending.size == new_size);
struct record_group_t {
std::vector<record_t> records;
record_group_size_t size;
- extent_len_t current_dlength = 0;
record_group_t() = default;
record_group_t(
record_t&& record,
extent_len_t block_size) {
size.account(record.size, block_size);
- current_dlength += record.size.dlength;
records.push_back(std::move(record));
assert(size.get_encoded_length() < MAX_SEG_OFF);
}
void clear() {
records.clear();
size = {};
- current_dlength = 0;
}
};