(
&self,
reservation: JournalTurnReservation,
source: JournalCheckpointSource,
now: i64,
)
| 327 | } |
| 328 | |
| 329 | fn prepare_checkpoint( |
| 330 | &self, |
| 331 | reservation: JournalTurnReservation, |
| 332 | source: JournalCheckpointSource, |
| 333 | now: i64, |
| 334 | ) -> Result<JournalCheckpointAttempt, String> { |
| 335 | let repository = self.repository.clone(); |
| 336 | run_outside_async_runtime(move || { |
| 337 | let response = request_with_reconnect( |
| 338 | &repository, |
| 339 | OwnerRequest::PrepareCheckpoint { |
| 340 | provenance_id: reservation.provenance_id, |
| 341 | expected_generation: reservation.generation, |
| 342 | reuse_frozen_changes: source.change_hashes.is_empty(), |
| 343 | source: to_store_checkpoint_source(source), |
| 344 | now, |
| 345 | }, |
| 346 | )?; |
| 347 | match response { |
| 348 | OwnerResponse::CheckpointPrepared { attempt } => Ok(to_journal_checkpoint_attempt( |
| 349 | reservation.provenance_id, |
| 350 | attempt, |
| 351 | )), |
| 352 | other => Err(unexpected_response("prepare checkpoint", other)), |
| 353 | } |
| 354 | }) |
| 355 | .map_err(|error| error.to_string()) |
| 356 | } |
| 357 | |
| 358 | fn load_frozen_envelopes( |
| 359 | &self, |
nothing calls this directly
no test coverage detected