(
&self,
checkpoint: &JournalCheckpointAttempt,
manifest_hash: Hash,
completed_at: i64,
)
| 427 | } |
| 428 | |
| 429 | fn acknowledge_checkpoint( |
| 430 | &self, |
| 431 | checkpoint: &JournalCheckpointAttempt, |
| 432 | manifest_hash: Hash, |
| 433 | completed_at: i64, |
| 434 | ) -> Result<(), String> { |
| 435 | let repository = self.repository.clone(); |
| 436 | let provenance_id = checkpoint.provenance_id; |
| 437 | let expected_generation = checkpoint.attempt_generation; |
| 438 | run_outside_async_runtime(move || { |
| 439 | match request_with_reconnect( |
| 440 | &repository, |
| 441 | OwnerRequest::AcknowledgeCheckpoint { |
| 442 | provenance_id, |
| 443 | expected_generation, |
| 444 | manifest_hash, |
| 445 | completed_at, |
| 446 | }, |
| 447 | )? { |
| 448 | OwnerResponse::CheckpointAcknowledged => Ok(()), |
| 449 | other => Err(unexpected_response("acknowledge checkpoint", other)), |
| 450 | } |
| 451 | }) |
| 452 | .map_err(|error| error.to_string()) |
| 453 | } |
| 454 | |
| 455 | fn stop_turn( |
| 456 | &self, |
nothing calls this directly
no test coverage detected