Lines Matching refs:sqe
100 let sqe = self.submit_queue_entries.get_mut(index).unwrap(); in prep_next_sqe() localVariable
102 f(sqe, self.io_vecs[index].as_mut()); in prep_next_sqe()
148 self.prep_next_sqe(|sqe, iovec| { in add_rw_op()
151 sqe.opcode = op; in add_rw_op()
152 sqe.addr = iovec as *const _ as *const libc::c_void as u64; in add_rw_op()
153 sqe.len = 1; in add_rw_op()
154 sqe.__bindgen_anon_1.off = offset; in add_rw_op()
155 sqe.__bindgen_anon_3.__bindgen_anon_1.buf_index = 0; in add_rw_op()
156 sqe.ioprio = 0; in add_rw_op()
157 sqe.user_data = user_data; in add_rw_op()
158 sqe.flags = 0; in add_rw_op()
159 sqe.fd = fd; in add_rw_op()
356 self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| { in add_writev()
357 sqe.opcode = IORING_OP_WRITEV as u8; in add_writev()
358 sqe.addr = iovecs.as_ptr() as *const _ as *const libc::c_void as u64; in add_writev()
359 sqe.len = iovecs.len() as u32; in add_writev()
360 sqe.__bindgen_anon_1.off = offset; in add_writev()
361 sqe.__bindgen_anon_3.__bindgen_anon_1.buf_index = 0; in add_writev()
362 sqe.ioprio = 0; in add_writev()
363 sqe.user_data = user_data; in add_writev()
364 sqe.flags = 0; in add_writev()
365 sqe.fd = fd; in add_writev()
414 self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| { in add_readv()
415 sqe.opcode = IORING_OP_READV as u8; in add_readv()
416 sqe.addr = iovecs.as_ptr() as *const _ as *const libc::c_void as u64; in add_readv()
417 sqe.len = iovecs.len() as u32; in add_readv()
418 sqe.__bindgen_anon_1.off = offset; in add_readv()
419 sqe.__bindgen_anon_3.__bindgen_anon_1.buf_index = 0; in add_readv()
420 sqe.ioprio = 0; in add_readv()
421 sqe.user_data = user_data; in add_readv()
422 sqe.flags = 0; in add_readv()
423 sqe.fd = fd; in add_readv()
432 self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| { in add_nop()
433 sqe.opcode = IORING_OP_NOP as u8; in add_nop()
434 sqe.fd = -1; in add_nop()
435 sqe.user_data = user_data; in add_nop()
437 sqe.addr = 0; in add_nop()
438 sqe.len = 0; in add_nop()
439 sqe.__bindgen_anon_1.off = 0; in add_nop()
440 sqe.__bindgen_anon_3.__bindgen_anon_1.buf_index = 0; in add_nop()
441 sqe.__bindgen_anon_2.rw_flags = 0; in add_nop()
442 sqe.ioprio = 0; in add_nop()
443 sqe.flags = 0; in add_nop()
450 self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| { in add_fsync()
451 sqe.opcode = IORING_OP_FSYNC as u8; in add_fsync()
452 sqe.fd = fd; in add_fsync()
453 sqe.user_data = user_data; in add_fsync()
455 sqe.addr = 0; in add_fsync()
456 sqe.len = 0; in add_fsync()
457 sqe.__bindgen_anon_1.off = 0; in add_fsync()
458 sqe.__bindgen_anon_3.__bindgen_anon_1.buf_index = 0; in add_fsync()
459 sqe.__bindgen_anon_2.rw_flags = 0; in add_fsync()
460 sqe.ioprio = 0; in add_fsync()
461 sqe.flags = 0; in add_fsync()
476 self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| { in add_fallocate()
477 sqe.opcode = IORING_OP_FALLOCATE as u8; in add_fallocate()
479 sqe.fd = fd; in add_fallocate()
480 sqe.addr = len; in add_fallocate()
481 sqe.len = mode; in add_fallocate()
482 sqe.__bindgen_anon_1.off = offset; in add_fallocate()
483 sqe.user_data = user_data; in add_fallocate()
485 sqe.__bindgen_anon_3.__bindgen_anon_1.buf_index = 0; in add_fallocate()
486 sqe.__bindgen_anon_2.rw_flags = 0; in add_fallocate()
487 sqe.ioprio = 0; in add_fallocate()
488 sqe.flags = 0; in add_fallocate()
503 self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| { in add_poll_fd()
504 sqe.opcode = IORING_OP_POLL_ADD as u8; in add_poll_fd()
505 sqe.fd = fd; in add_poll_fd()
506 sqe.user_data = user_data; in add_poll_fd()
507 sqe.__bindgen_anon_2.poll_events = events.get_raw() as u16; in add_poll_fd()
509 sqe.addr = 0; in add_poll_fd()
510 sqe.len = 0; in add_poll_fd()
511 sqe.__bindgen_anon_1.off = 0; in add_poll_fd()
512 sqe.__bindgen_anon_3.__bindgen_anon_1.buf_index = 0; in add_poll_fd()
513 sqe.ioprio = 0; in add_poll_fd()
514 sqe.flags = 0; in add_poll_fd()
525 self.submit_ring.lock().prep_next_sqe(|sqe, _iovec| { in remove_poll_fd()
526 sqe.opcode = IORING_OP_POLL_REMOVE as u8; in remove_poll_fd()
527 sqe.fd = fd; in remove_poll_fd()
528 sqe.user_data = user_data; in remove_poll_fd()
529 sqe.__bindgen_anon_2.poll_events = events.get_raw() as u16; in remove_poll_fd()
531 sqe.addr = 0; in remove_poll_fd()
532 sqe.len = 0; in remove_poll_fd()
533 sqe.__bindgen_anon_1.off = 0; in remove_poll_fd()
534 sqe.__bindgen_anon_3.__bindgen_anon_1.buf_index = 0; in remove_poll_fd()
535 sqe.ioprio = 0; in remove_poll_fd()
536 sqe.flags = 0; in remove_poll_fd()