| 137 | } |
| 138 | |
| 139 | pub struct BufferManager { |
| 140 | file: Arc<RwLock<File>>, |
| 141 | regions: LRUCache<u64, Arc<BufferRegion>>, |
| 142 | cursors: RwLock<HashMap<u64, Cursor>>, |
| 143 | next_cursor_id: AtomicU64, |
| 144 | file_size: RwLock<u64>, |
| 145 | buffer_size: usize, |
| 146 | } |
| 147 | |
| 148 | impl BufferManager { |
| 149 | pub fn new(mut file: File, buffer_size: usize) -> io::Result<Self> { |
nothing calls this directly
no outgoing calls
no test coverage detected