()
| 169 | |
| 170 | #[test] |
| 171 | fn reserve_commit() { |
| 172 | let mgr = GapFreeManager::new(); |
| 173 | let counter = AtomicI64::new(0); |
| 174 | |
| 175 | let handle = mgr |
| 176 | .reserve("1:test", || Ok(counter.fetch_add(1, Ordering::Relaxed) + 1)) |
| 177 | .unwrap(); |
| 178 | |
| 179 | assert_eq!(handle.value, 1); |
| 180 | mgr.commit(&handle); |
| 181 | assert_eq!(counter.load(Ordering::Relaxed), 1); |
| 182 | } |
| 183 | |
| 184 | #[test] |
| 185 | fn reserve_rollback() { |