| 187 | } |
| 188 | } |
| 189 | if (zeroFillSize) { |
| 190 | CODE_PROBE(true, "Fixing a partial commit at the end of the tlog queue"); |
| 191 | for (int i = 0; i < zeroFillSize; i++) |
| 192 | self->queue->push(StringRef((const uint8_t*)"", 1)); |
| 193 | } |
| 194 | throw end_of_stream(); |
| 195 | } |
| 196 | }; |