用户:pdeantihuman/沙盒liburing

io_uring 是一个新的 Linux IO 接口,2019年1月8日提交补丁,2019年3月8日合并到了 Linux v5.1-rc1,旨在成为 Linux 的异步文件 IO 接口[1],替代 Linux 的旧异步文件 IO 接口 AIO。io_uring 利用两个循环缓冲区在内核和用户态程序之间交换数据,一个用来提交IO请求,另一个用来接收IO结果,前者称为提交队列(SQ),后者称为完成队列(CQ)。

从新接口的名字 io_uring 也可看出,该接口是 “yet another ring buffer“。

程序接口

编辑

io_uring 现在的状态是开发中,接口一直在变化中。

int io_uring_setup(int entries, struct io_uring_params *params);

创建新的 io_uring 实例,entries 表示与该io_uring实例相对应的循环缓冲区应有多大。entries 必须是一个 2 的幂次,大小必须在 1-4096 之间。返回值是一个与 io_uring 实例相对应的文件描述符。 因为提交队列和完成队列是用户态程序与内核共享的,你需要 MMAP 来访问这两个队列。将这两个

int io_uring_enter(unsigned int fd, unsigned int to_submit, unsigned int min_complete, unsigned int flags, sigset_t sig);

io_uring_enter 用来通知内核收割提交队列上已经就绪的IO请求。fd 指的是 io_uring 相对应的文件描述符,to_submit 指已经提交了多少个请求,min_complete 指的是等待多少个请求完成后返回。因此,发起IO请求和等待IO完成事件可以用同一个系统调用。

提交队列排序 

编辑

提交到提交队列中的IO请求称为SQE(Submission Queue Entry)。

SQE 之间默认是独立的,意思是任何一个 SQE 的执行不影响另一个 SQE 的执行或者排序。因此 SQE 的排序实际上很自由。

io_uring 支持通过同步指令清空请求队列。方式是开发者可以提交一个必须等待前面所有 SQE 完成后才能开始执行的 SQE,在这个SQE的 flags 属性设置IOSQE_IO_DRAIN即可实现。不过注意这会暂停所有后续的IO请求,它创造的流水线空泡可能比想象中大得多。如果你需要经常为了数据完整性使用这类排序操作,应当使用一个单独的 IO 上下文来避免对无关IO操作的影响。IOSQE_IO_DRAIN是一个非常重量级的流水线屏障。

SQE 链

编辑

开发者如果希望两个SQE之间有依赖关系,io_uring 支持通过SQE链的方式表示一个SQE与另一个SQE之间的依赖关系。如果SQE的flags上设置了IOSQE_IO_LINK,那么这个SQE就会等待它前面一个SQE完成后才会开始执行。

比如,需要将数据从一个文件读出写入缓冲区,然后缓冲区向另一个文件写入,是一个非常常见的需求,这种时候你就可以创建一个 SQE 链。

示例 

编辑

应用程式通过 MMAP 访问提交队列

编辑
struct app_sq_ring app_setup_sq_ring(int ring_fd, struct io_uring_params *p)
{
   // 应用程序需要一个结构体变量 sring 存放循环缓冲区的指针
   struct app_sq_ring sqring;
   void *ptr;
   ptr = mmap(NULL, psq_off.array + psq_entries * sizeof(__u32),
     PROT_READ | PROT_WRITE, MAP_SHARED | MAP_POPULATE,
     ring_fd, IORING_OFF_SQ_RING);
   sringhead = ptr + psq_off.head;
   sringtail = ptr + psq_off.tail;
   sringring_mask = ptr + psq_off.ring_mask;
   sringring_entries = ptr + psq_off.ring_entries;
   sringflags = ptr + psq_off.flags;
   sringdropped = ptr + psq_off.dropped;
   sringarray = ptr + psq_off.array;
   return sring;
}

相关条目

编辑

参考资料

编辑
  1. ^ io_uring.pdf (PDF). 

外部链接

编辑