Changeset d3605f8 for libcfa/src/concurrency/io.cfa
- Timestamp:
- Nov 29, 2021, 4:58:54 PM (2 years ago)
- Branches:
- ADT, ast-experimental, enum, forall-pointer-decay, master, pthread-emulation, qualifiedEnum
- Children:
- 03cdad6
- Parents:
- 3bb4f85
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
libcfa/src/concurrency/io.cfa
r3bb4f85 rd3605f8 33 33 #include <sys/syscall.h> 34 34 #include <sys/eventfd.h> 35 #include <sys/uio.h> 35 36 36 37 #include <linux/io_uring.h> … … 502 503 } 503 504 504 #if defined( IO_URING_IDLE)505 bool __kernel_read(processor * proc, io_future_t & future, char buf[], int fd) {505 #if defined(CFA_WITH_IO_URING_IDLE) 506 bool __kernel_read(processor * proc, io_future_t & future, iovec & iov, int fd) { 506 507 $io_context * ctx = proc->io.ctx; 507 508 /* paranoid */ verify( ! __preemption_enabled() ); … … 518 519 __fill( &sqe, 1, &idx, ctx ); 519 520 520 sqe->opcode = IORING_OP_READ;521 521 sqe->user_data = (uintptr_t)&future; 522 522 sqe->flags = 0; 523 sqe->ioprio = 0;524 523 sqe->fd = fd; 525 524 sqe->off = 0; 525 sqe->ioprio = 0; 526 526 sqe->fsync_flags = 0; 527 527 sqe->__pad2[0] = 0; 528 528 sqe->__pad2[1] = 0; 529 529 sqe->__pad2[2] = 0; 530 sqe->addr = (uintptr_t)buf; 531 sqe->len = sizeof(uint64_t); 530 531 #if defined(CFA_HAVE_IORING_OP_READ) 532 sqe->opcode = IORING_OP_READ; 533 sqe->addr = (uint64_t)iov.iov_base; 534 sqe->len = iov.iov_len; 535 #elif defined(CFA_HAVE_READV) && defined(CFA_HAVE_IORING_OP_READV) 536 sqe->opcode = IORING_OP_READV; 537 sqe->addr = (uintptr_t)&iov; 538 sqe->len = 1; 539 #else 540 #error CFA_WITH_IO_URING_IDLE but none of CFA_HAVE_READV, CFA_HAVE_IORING_OP_READV or CFA_HAVE_IORING_OP_READ defined 541 #endif 532 542 533 543 asm volatile("": : :"memory");
Note: See TracChangeset
for help on using the changeset viewer.