(&mut self, user_data: Option<u64>)
| 182 | } |
| 183 | |
| 184 | fn fsync(&mut self, user_data: Option<u64>) -> AsyncIoResult<()> { |
| 185 | self.metadata.flush().map_err(AsyncIoError::Fsync)?; |
| 186 | if let Some(user_data) = user_data { |
| 187 | self.completion_list.push_back((user_data, 0)); |
| 188 | self.eventfd.write(1).unwrap(); |
| 189 | } |
| 190 | Ok(()) |
| 191 | } |
| 192 | |
| 193 | fn next_completed_request(&mut self) -> Option<(u64, i32)> { |
| 194 | // Drain io_uring completions first, then synthetic ones. |