| 354 | |
| 355 | template <uint8_t _b> |
| 356 | void BitVector<_b>::decode_data(bufferlist::const_iterator& it, |
| 357 | uint64_t data_byte_offset) { |
| 358 | ceph_assert(data_byte_offset % BLOCK_SIZE == 0); |
| 359 | if (it.end()) { |
| 360 | return; |
| 361 | } |
| 362 | |
| 363 | uint64_t end_offset = data_byte_offset + it.get_remaining(); |
| 364 | if (end_offset > m_data.length()) { |
| 365 | throw buffer::end_of_buffer(); |
| 366 | } |
| 367 | |
| 368 | bufferlist data; |
| 369 | if (data_byte_offset > 0) { |
| 370 | data.substr_of(m_data, 0, data_byte_offset); |
| 371 | } |
| 372 | |
| 373 | while (data_byte_offset < end_offset) { |
| 374 | uint64_t len = std::min<uint64_t>(BLOCK_SIZE, end_offset - data_byte_offset); |
| 375 | |
| 376 | bufferptr ptr; |
| 377 | it.copy_deep(len, ptr); |
| 378 | |
| 379 | bufferlist bit; |
| 380 | bit.append(ptr); |
| 381 | if (m_crc_enabled && |
| 382 | m_data_crcs[data_byte_offset / BLOCK_SIZE].val != bit.crc32c(0)) { |
| 383 | throw buffer::malformed_input("invalid data block CRC"); |
| 384 | } |
| 385 | data.append(bit); |
| 386 | data_byte_offset += bit.length(); |
| 387 | } |
| 388 | |
| 389 | if (m_data.length() > end_offset) { |
| 390 | bufferlist tail; |
| 391 | tail.substr_of(m_data, end_offset, m_data.length() - end_offset); |
| 392 | data.append(tail); |
| 393 | } |
| 394 | ceph_assert(data.length() == m_data.length()); |
| 395 | data.swap(m_data); |
| 396 | } |
| 397 | |
| 398 | template <uint8_t _b> |
| 399 | void BitVector<_b>::get_data_extents(uint64_t offset, uint64_t length, |