| 234 | } |
| 235 | |
| 236 | void ChunkedCSRNodeGroup::scanCSRHeader(MemoryManager& memoryManager, |
| 237 | CSRNodeGroupCheckpointState& csrState) const { |
| 238 | if (!csrState.oldHeader) { |
| 239 | csrState.oldHeader = std::make_unique<InMemChunkedCSRHeader>(memoryManager, |
| 240 | false /*enableCompression*/, StorageConfig::NODE_GROUP_SIZE); |
| 241 | } |
| 242 | ChunkState headerChunkState; |
| 243 | DASSERT(csrHeader.offset->getResidencyState() == ResidencyState::ON_DISK); |
| 244 | DASSERT(csrHeader.length->getResidencyState() == ResidencyState::ON_DISK); |
| 245 | csrHeader.offset->initializeScanState(headerChunkState, csrState.csrOffsetColumn); |
| 246 | DASSERT(csrState.csrOffsetColumn && csrState.csrLengthColumn); |
| 247 | csrState.csrOffsetColumn->scan(headerChunkState, csrState.oldHeader->offset.get()); |
| 248 | csrHeader.length->initializeScanState(headerChunkState, csrState.csrLengthColumn); |
| 249 | csrState.csrLengthColumn->scan(headerChunkState, csrState.oldHeader->length.get()); |
| 250 | } |
| 251 | |
| 252 | void ChunkedCSRNodeGroup::serialize(Serializer& serializer) const { |
| 253 | DASSERT(csrHeader.offset && csrHeader.length); |
no test coverage detected