| 128 | } |
| 129 | |
| 130 | void ValidWriteIdList::InitFrom(const TValidWriteIdList& valid_write_ids) { |
| 131 | if (valid_write_ids.__isset.high_watermark) { |
| 132 | high_water_mark_ = valid_write_ids.high_watermark; |
| 133 | } else { |
| 134 | high_water_mark_ = std::numeric_limits<int64_t>::max(); |
| 135 | } |
| 136 | invalid_write_ids_.clear(); |
| 137 | for (int64_t invalid_write_id : valid_write_ids.invalid_write_ids) { |
| 138 | invalid_write_ids_.insert(invalid_write_id); |
| 139 | } |
| 140 | } |
| 141 | |
| 142 | bool ValidWriteIdList::IsWriteIdValid(int64_t write_id) const { |
| 143 | if (write_id > high_water_mark_) { |