| 362 | |
| 363 | |
| 364 | Future<Log::Position> LogReaderProcess::_beginning() |
| 365 | { |
| 366 | CHECK_READY(recovering); |
| 367 | |
| 368 | return recovering.get()->beginning() |
| 369 | .then(lambda::bind(&Self::position, lambda::_1)); |
| 370 | } |
| 371 | |
| 372 | |
| 373 | Future<Log::Position> LogReaderProcess::ending() |