()
| 383 | |
| 384 | #[test] |
| 385 | fn pool_buffers_are_reused() { |
| 386 | let dir = tempfile::tempdir().unwrap(); |
| 387 | let p1 = create_test_file(dir.path(), "a.col", 1024); |
| 388 | let p2 = create_test_file(dir.path(), "b.col", 2048); |
| 389 | |
| 390 | let mut reader = UringReader::with_config(8, 2, 4096).unwrap(); |
| 391 | |
| 392 | let r1 = reader.read_files(&[p1.as_path(), p2.as_path()]); |
| 393 | assert_eq!(r1[0].len(), 1024); |
| 394 | assert_eq!(r1[1].len(), 2048); |
| 395 | assert_eq!(reader.free.len(), 2); |
| 396 | |
| 397 | let r2 = reader.read_files(&[p1.as_path()]); |
| 398 | assert_eq!(r2[0].len(), 1024); |
| 399 | assert_eq!(reader.free.len(), 2); |
| 400 | } |
| 401 | } |
nothing calls this directly
no test coverage detected