| 432 | } |
| 433 | |
| 434 | Version poppedVersion(LogRouterData* self, Tag tag) { |
| 435 | auto tagData = self->getTagData(tag); |
| 436 | if (!tagData) |
| 437 | return Version(0); |
| 438 | return tagData->popped; |
| 439 | } |
| 440 | |
| 441 | // Common logics to peek TLog and create TLogPeekReply that serves both streaming peek or normal peek request |
| 442 | ACTOR template <typename PromiseType> |
no test coverage detected