()
| 310 | |
| 311 | #[tokio::test] |
| 312 | async fn renew_extends_lease() { |
| 313 | let store = test_store().await; |
| 314 | let l = lease(store, "replica-1", LEASE_TTL); |
| 315 | let mut guard = l.try_acquire().await.unwrap(); |
| 316 | let v1 = guard.resource_version; |
| 317 | |
| 318 | l.renew(&mut guard).await.unwrap(); |
| 319 | assert!(guard.resource_version > v1); |
| 320 | |
| 321 | let record = l.read().await.unwrap().unwrap(); |
| 322 | assert_eq!(record.holder, "replica-1"); |
| 323 | assert_eq!(record.resource_version, guard.resource_version); |
| 324 | } |
| 325 | |
| 326 | #[tokio::test] |
| 327 | async fn steal_rejected_when_lease_active() { |
nothing calls this directly
no test coverage detected