libaio是glibc提供的还是kernel提供的?

yulihua49

xinglp 发表于 2017-02-08 12:04
这个aio自己不能等待一堆io么，就像epoll那样另外这个内核aio现在支持套接字了么

可以，可是你怎样组织一堆IO呢？
作为服务器，客户端的请求是随机的，你怎么把一堆客户端的请求一起处理又不让他们互相等待。

cdsfiui

windoze 发表于 2017-02-06 22:50
目前应该都是kernel aio了，除非你还在用2.4

你的意思是? 现在Libaio和glibc的aio都已经是kernel aio了，glibc也不再是调用posix aio了?

windoze

回复 12# cdsfiui

glibc的aio_XXX还是以前那个吊样，libaio里面的是io_XXX，这个是新的kernel AIO，但是在2.4版本下不能用，必须要2.6或者更新的kernel。

yulihua49

windoze 发表于 2017-02-08 22:02
回复 12# cdsfiui

glibc的aio_XXX还是以前那个吊样，libaio里面的是io_XXX，这个是新的kernel AIO，但 ...

1. /*******************************************
   
2. * 需要linux 2.6.22 以上版本
   
3. * 和libaio 3.107以上版本
   
4. * 如果不具备这个条件，在makefile里用SIO_fd.o
   
5. * 取代本模块
   
6. *******************************************/
   
7. 
   
8. #include <unistd.h>
   
9. #include <sys/stat.h>
   
10. #include <fcntl.h>
    
11. #include <sys/eventfd.h>
    
12. #include <libaio.h>
    
13. 
    
14. #include <scsrv.h>
    
15. 
    
16. static int AIO_oper(int fd,char *buff,size_t iosize,int flg)
    
17. {
    
18. io_context_t myctx;
    
19. int rc,num;
    
20. uint64_t finished_aio;
    
21. struct iocb _iocb,*io=&_iocb;
    
22. struct io_event event;
    
23. int        efd = eventfd(0, 0);
    
24. T_YIELD yield=get_yield();
    
25. 
    
26.         if (efd == -1) {   
    
27.                 return flg?write(fd,buff,iosize):read(fd,buff,iosize);
    
28.         }   
    
29. 
    
30.         memset(&myctx,0,sizeof(myctx));
    
31.         io_set_eventfd(io,efd);
    
32.         io_queue_init(1, &myctx);
    
33.         if(flg) io_prep_pread(io, fd, buff, iosize, 0);
    
34.         else        io_prep_pwrite(io, fd, buff, iosize, 0);
    
35.         rc = io_submit(myctx, 1, &io);
    
36.         if(rc<0) {
    
37.                 close(efd);
    
38.                 io_destroy(myctx);
    
39.                 return flg?write(fd,buff,iosize):read(fd,buff,iosize);
    
40.         }
    
41.         if(yield) {
    
42.                 rc = yield(efd,0,0);//efd提交给epoll，并yield and resume.
    
43.                 if(rc==0) eventfd_read(efd, &finished_aio);
    
44.         }
    
45.         close(efd);
    
46.         num = io_getevents(myctx, 1, 1, &event, NULL);
    
47.         if(num>0) {
    
48.                 if(event.res2==0) num=event.res;
    
49.                 else num=-1;
    
50.         }
    
51.         io_destroy(myctx);
    
52.         return num;
    
53. }
    
54. 
    
55. int AIO_read(int fd,char *buff,size_t iosize)
    
56. {
    
57.         return AIO_oper(fd,buff,iosize,0);
    
58. }
    
59. 
    
60. int AIO_write(int fd,char *buff,size_t iosize)
    
61. {
    
62.         return AIO_oper(fd,buff,iosize,1);
    
63. }
    

复制代码

yulihua49

yulihua49 发表于 2017-02-08 22:21

看31行，与eventfd结合，然后，在yield时，提交epoll。
还是一个原则，能异步就异步，不能异步就同步，反正事情是不能耽误的。

xinglp

yulihua49 发表于 2017-02-08 17:02
可以，可是你怎样组织一堆IO呢？
作为服务器，客户端的请求是随机的，你怎么把一堆客户端的请求一起处理 ...

我的意思是这个内核的aio没有epoll或者kqueue那样的等待接口么

sditmaner

楼主加油，我们都看好你哦

yulihua49

xinglp 发表于 2017-02-09 11:13
我的意思是这个内核的aio没有epoll或者kqueue那样的等待接口么

没有。必须是libaio，107以上版本。