| 204 | } |
| 205 | |
| 206 | void UndoBuffer::commitVersionInfo(UndoRecordType recordType, const uint8_t* record, |
| 207 | transaction_t commitTS) { |
| 208 | const auto& undoRecord = *reinterpret_cast<VersionRecord const*>(record); |
| 209 | switch (recordType) { |
| 210 | case UndoRecordType::INSERT_INFO: { |
| 211 | undoRecord.versionRecordHandler->applyFuncToChunkedGroups(&ChunkedNodeGroup::commitInsert, |
| 212 | undoRecord.nodeGroupIdx, undoRecord.startRow, undoRecord.numRows, commitTS); |
| 213 | } break; |
| 214 | case UndoRecordType::DELETE_INFO: { |
| 215 | undoRecord.versionRecordHandler->applyFuncToChunkedGroups(&ChunkedNodeGroup::commitDelete, |
| 216 | undoRecord.nodeGroupIdx, undoRecord.startRow, undoRecord.numRows, commitTS); |
| 217 | } break; |
| 218 | default: { |
| 219 | UNREACHABLE_CODE; |
| 220 | } |
| 221 | } |
| 222 | } |
| 223 | |
| 224 | void UndoBuffer::commitVectorUpdateInfo(const uint8_t* record, transaction_t commitTS) { |
| 225 | auto& undoRecord = *reinterpret_cast<VectorUpdateRecord const*>(record); |
nothing calls this directly
no test coverage detected