| 3311 | } |
| 3312 | |
| 3313 | bool AccumulatedMutations::isComplete() const { |
| 3314 | if (lastChunkNumber >= 0) { |
| 3315 | StringRefReader reader(serializedMutations, restore_corrupted_data()); |
| 3316 | |
| 3317 | Version protocolVersion = reader.consume<uint64_t>(); |
| 3318 | if (protocolVersion <= 0x0FDB00A200090001) { |
| 3319 | throw incompatible_protocol_version(); |
| 3320 | } |
| 3321 | |
| 3322 | uint32_t vLen = reader.consume<uint32_t>(); |
| 3323 | return vLen == reader.remainder().size(); |
| 3324 | } |
| 3325 | |
| 3326 | return false; |
| 3327 | } |
| 3328 | |
| 3329 | // Returns true if a complete chunk contains any MutationRefs which intersect with any |
| 3330 | // range in ranges. |
no test coverage detected