EIOCBQUEUED aio使用示例-DPDK中文网

在 Linux 内核中，EIOCBQUEUED 是一个返回值，表示异步 I/O 请求已成功排队。这通常与 AIO（Asynchronous I/O）操作相关。当你使用 AIO 进行读或写操作时，如果请求已经被成功放入排队状态，就会返回 EIOCBQUEUED。

以下是一个基本的示例，展示如何使用 AIO 和处理 EIOCBQUEUED 的情况。这个示例包括了设备驱动的简化版本以及如何提交 AIO 请求。

示例：简化的 AIO 驱动程序

#include <linux/module.h>
#include <linux/fs.h>
#include <linux/uio.h>
#include <linux/slab.h>
#include <linux/aio.h>

#define DEVICE_NAME "my_aio_device"

struct my_device {
    struct cdev cdev;
    // 其他设备特有数据
};

// 文件操作结构体
static struct file_operations my_fops = {
    .owner = THIS_MODULE,
    // 其他文件操作...
};

// 提交 AIO 请求的函数
static int my_aio_read(struct kiocb *kiocb, const struct iovec *iov,
                       unsigned long nr_segs, loff_t pos) {
    // 检查是否需要将请求排队
    if (/* 某种条件 */) {
        return -EIOCBQUEUED;  // 模拟请求已排队
    }

    // 处理实际读取逻辑...

    return 0; // 返回实际读取字节数或相应错误代码
}

// 初始化模块
static int __init my_driver_init(void) {
    dev_t dev;
    struct my_device *my_dev;

    alloc_chrdev_region(&dev, 0, 1, DEVICE_NAME);
    
    my_dev = kmalloc(sizeof(struct my_device), GFP_KERNEL);
    
    cdev_init(&my_dev->cdev, &my_fops);
    
    if (cdev_add(&my_dev->cdev, dev, 1)) {
        kfree(my_dev);
        return -1;
    }

    return 0;
}

// 清理模块
static void __exit my_driver_exit(void) {
   // 清理逻辑，例如卸载字符设备...
}

module_init(my_driver_init);
module_exit(my_driver_exit);

MODULE_LICENSE("GPL");

使用 `aio_read` 发起异步读请求

在用户空间，你可以使用 POSIX AIO 接口来发起异步读请求，如下所示：

#include <stdio.h>
#include <stdlib.h>
#include <fcntl.h>
#include <unistd.h>
#include <aio.h>
#include <string.h>

#define BUFFER_SIZE 1024

int main() {
    int fd;
    struct aiocb cb;
    char buffer[BUFFER_SIZE];

    fd = open("/dev/my_aio_device", O_RDONLY | O_NONBLOCK);
  
    if (fd == -1) {
        perror("Error opening device");
        return EXIT_FAILURE;
    }

   memset(&cb, 0, sizeof(cb));
   cb.aio_fildes = fd;
   cb.aio_buf = buffer;
   cb.aio_nbytes = BUFFER_SIZE;

   if (aio_read(&cb) == -1) {
       perror("Error in aio_read");
       close(fd);
       return EXIT_FAILURE;
   }

   while (aio_error(&cb) == EINPROGRESS) { 
      /* 可以在此处执行其他任务 */
   }

   ssize_t bytes_read = aio_return(&cb); 
   
   if (bytes_read >= 0) {
       printf("Read %ld bytes: %s\n", bytes_read, buffer);
   } else {
       perror("Error in reading data");
   }
  
   close(fd);
   return EXIT_SUCCESS;
}