stats.record_batch_stats.increment(rg.get_size());
for (const record_t& r : rg.records) {
- auto src = r.type;
+ auto src = r.trans_type;
assert(is_modify_transaction(src));
auto& trans_stats = get_by_src(stats.stats_by_src, src);
++(trans_stats.num_records);
std::ostream &operator<<(std::ostream& out, const record_t& r)
{
return out << "record_t("
- << "type=" << r.type
+ << "trans_type=" << r.trans_type
<< ", num_extents=" << r.extents.size()
<< ", num_deltas=" << r.deltas.size()
<< ", modify_time=" << sea_time_point_printer_t{r.modify_time}
for (auto& r: record_group.records) {
record_header_t rheader{
- r.type,
+ r.trans_type,
(extent_len_t)r.deltas.size(),
(extent_len_t)r.extents.size(),
timepoint_to_mod(r.modify_time)
std::ostream &operator<<(std::ostream&, const record_size_t&);
struct record_t {
- transaction_type_t type = TRANSACTION_TYPE_NULL;
+ transaction_type_t trans_type = TRANSACTION_TYPE_NULL;
std::vector<extent_t> extents;
std::vector<delta_info_t> deltas;
record_size_t size;
sea_time_point modify_time = NULL_TIME;
- record_t(transaction_type_t type) : type{type} { }
+ record_t(transaction_type_t t_type) : trans_type{t_type} { }
// unit test only
record_t() {
- type = transaction_type_t::MUTATE;
+ trans_type = transaction_type_t::MUTATE;
}
// unit test only
for (auto& d: _deltas) {
push_back(std::move(d));
}
- type = transaction_type_t::MUTATE;
+ trans_type = transaction_type_t::MUTATE;
}
bool is_empty() const {