Submit the buffered data via io_uring write + fsync, and wait for completion. This is the group commit point: all records appended since the last `submit_and_sync()` become durable after this returns.
(&mut self)
| 195 | /// This is the group commit point: all records appended since the last |
| 196 | /// `submit_and_sync()` become durable after this returns. |
| 197 | pub fn submit_and_sync(&mut self) -> Result<()> { |
| 198 | if self.buffer.is_empty() { |
| 199 | return Ok(()); |
| 200 | } |
| 201 | self.submit_and_wait_write()?; |
| 202 | self.submit_and_wait_fsync()?; |
| 203 | Ok(()) |
| 204 | } |
| 205 | |
| 206 | /// Submit a write SQE and wait for the CQE. |
| 207 | /// |