| 560 | |
| 561 | |
| 562 | Option<Log::Position> LogWriterProcess::__start( |
| 563 | const Option<uint64_t>& position) |
| 564 | { |
| 565 | if (position.isNone()) { |
| 566 | LOG(INFO) << "Could not start the writer, but can be retried"; |
| 567 | return None(); |
| 568 | } |
| 569 | |
| 570 | LOG(INFO) << "Writer started with ending position " << position.get(); |
| 571 | |
| 572 | return Log::Position(position.get()); |
| 573 | } |
| 574 | |
| 575 | |
| 576 | Future<Option<Log::Position>> LogWriterProcess::append(const string& bytes) |