(&mut self, user_data: Option<u64>)
| 236 | } |
| 237 | |
| 238 | fn fsync(&mut self, user_data: Option<u64>) -> AsyncIoResult<()> { |
| 239 | self.metadata.flush().map_err(AsyncIoError::Fsync)?; |
| 240 | if let Some(user_data) = user_data { |
| 241 | self.completion_list.push_back((user_data, 0)); |
| 242 | self.eventfd.write(1).unwrap(); |
| 243 | } |
| 244 | Ok(()) |
| 245 | } |
| 246 | |
| 247 | fn next_completed_request(&mut self) -> Option<(u64, i32)> { |
| 248 | self.completion_list.pop_front() |