| 241 | |
| 242 | |
| 243 | Future<Nothing> LogStorageProcess::start() |
| 244 | { |
| 245 | if (starting.isSome()) { |
| 246 | return starting.get(); |
| 247 | } |
| 248 | |
| 249 | VLOG(2) << "Starting the writer"; |
| 250 | |
| 251 | starting = writer.start() |
| 252 | .then(defer(self(), &Self::_start, lambda::_1)); |
| 253 | |
| 254 | return starting.get(); |
| 255 | } |
| 256 | |
| 257 | |
| 258 | Future<Nothing> LogStorageProcess::_start( |