| 512 | } |
| 513 | |
| 514 | void updatePopped(int64_t popped) { |
| 515 | int64_t pop0 = std::min(popped, files[0].size - files[0].popped); |
| 516 | files[0].popped += pop0; |
| 517 | files[1].popped += popped - pop0; |
| 518 | } |
| 519 | |
| 520 | // Set the starting point of the ring buffer, i.e., the first useful page to be read (and poped) |
| 521 | ACTOR static Future<Void> setPoppedPage(RawDiskQueue_TwoFiles* self, int file, int64_t page, int64_t debugSeq) { |