(path: &str,
table_name: &str,
total_page_size: usize)
| 28 | |
| 29 | impl DiskLog { |
| 30 | pub fn open (path: &str, |
| 31 | table_name: &str, |
| 32 | total_page_size: usize) -> Result<Self, LogError> |
| 33 | { |
| 34 | match Context::open(path, table_name, total_page_size) { |
| 35 | Ok(context) => { |
| 36 | Ok(DiskLog { |
| 37 | context |
| 38 | }) |
| 39 | } |
| 40 | Err(e) => { |
| 41 | return Err(e) |
| 42 | } |
| 43 | } |
| 44 | |
| 45 | } |
| 46 | |
| 47 | pub fn run_service(mut self) -> Session { |
| 48 | let (sx, mut rx) = mpsc::channel(DISKLOG_BUFFER_SIZE); |
nothing calls this directly
no test coverage detected