复用iocb的问题

kdsfan

1. #include <stdio.h>
   
2. #include <errno.h>
   
3. #include <libaio.h>
   
4. #include <sys/eventfd.h>
   
5. #include <sys/epoll.h>
   
6. #include <stdlib.h>
   
7. #include <sys/types.h>
   
8. #include <unistd.h>
   
9. #include <stdint.h>
   
10. #include <sys/stat.h>
    
11. #include <fcntl.h>
    
12. #include <inttypes.h>
    
13. #include <string.h>
    
14. 
    
15. #define TEST_FILE   "/home/sqg/aio_test_file"
    
16. #define TEST_FILE_SIZE  (127 * 1024)
    
17. #define NUM_EVENTS  64
    
18. #define ALIGN_SIZE  512
    
19. #define RD_WR_SIZE  1024
    
20. 
    
21. struct custom_iocb
    
22. {
    
23.     struct iocb iocb;
    
24.     int nth_request;
    
25. };
    
26. 
    
27. void aio_callback(io_context_t ctx, struct iocb *iocb, long res, long res2)
    
28. {
    
29.     struct custom_iocb *iocbp = (struct custom_iocb *)iocb;
    
30.     printf("nth_request: %d, request_type: %s, offset: %lld, length: %lu, res: %ld, res2: %ld\n",
    
31.             iocbp->nth_request, (iocb->aio_lio_opcode == IO_CMD_PREAD) ? "READ" : "WRITE",
    
32.             iocb->u.c.offset, iocb->u.c.nbytes, res, res2);
    
33. 
    
34.     printf("%s\n", (char*)iocb->u.c.buf);
    
35. }
    
36. 
    
37. 
    
38. int main(int argc, char *argv[])
    
39. {
    
40.         int fd_EventObj;
    
41.         int fd_File;
    
42. 
    
43.         io_context_t pContext;
    
44.         struct timespec tTimeSpec;
    
45.         struct io_event atIOEvent[NUM_EVENTS];
    
46.         struct custom_iocb atCustomIOCB[NUM_EVENTS];
    
47.         struct iocb *apIOCB[NUM_EVENTS];
    
48.         struct custom_iocb *apCustomIOCB;
    
49.         int i, j, r;
    
50.         void *buf;
    
51. 
    
52.         fd_EventObj = eventfd(0, EFD_NONBLOCK | EFD_CLOEXEC);
    
53.         if (fd_EventObj == -1)
    
54.         {
    
55.                 perror("eventfd");
    
56.                 return 2;
    
57.         }
    
58. 
    
59.         //O_DIRECT这个很重要
    
60.         fd_File = open(TEST_FILE, O_RDWR | O_CREAT | O_DIRECT, 0644);
    
61.         if (fd_File == -1)
    
62.         {
    
63.                 perror("open");
    
64.                 return 3;
    
65.         }
    
66. 
    
67.         pContext = 0;
    
68.         if (io_setup(NUM_EVENTS, &pContext))
    
69.         {
    
70.                 perror("io_setup");
    
71.                 return 4;
    
72.         }
    
73. 
    
74. 
    
75.         for (i = 0, apCustomIOCB = atCustomIOCB; i < NUM_EVENTS; ++i, ++apCustomIOCB)
    
76.         {
    
77.                 if (posix_memalign(&buf, ALIGN_SIZE, RD_WR_SIZE))//可以说size是alignment倍数，alignment必须是2的幂，还是void指针的大小的倍数
    
78.                 {
    
79.                         perror("posix_memalign");
    
80.                         return 5;
    
81.                 }
    
82.                 apIOCB[i] = &apCustomIOCB->iocb;
    
83.                 io_prep_pread(&apCustomIOCB->iocb, fd_File, buf, RD_WR_SIZE, i * RD_WR_SIZE);
    
84.                 io_set_eventfd(&apCustomIOCB->iocb, fd_EventObj);
    
85.                 io_set_callback(&apCustomIOCB->iocb, aio_callback);
    
86.                 apCustomIOCB->nth_request = i + 1;
    
87.         }
    
88. 
    
89.         if (io_submit(pContext, NUM_EVENTS, apIOCB) != NUM_EVENTS)
    
90.         {
    
91.                 perror("io_submit");
    
92.                 return 6;
    
93.         }
    
94. 
    
95. 
    
96.     tTimeSpec.tv_sec = 0;
    
97.     tTimeSpec.tv_nsec = 0;
    
98.     r = io_getevents(pContext, 1, NUM_EVENTS, atIOEvent, &tTimeSpec);
    
99.     if (r > 0)
    
100.     {
     
101.         for (j = 0; j < r; ++j)
     
102.         {
     
103.             //atIOEvent[j].obj是iocb的指针
     
104.             ((io_callback_t)(atIOEvent[j].data))(pContext, atIOEvent[j].obj, atIOEvent[j].res, atIOEvent[j].res2);
     
105.         }
     
106.     }
     
107. 
     
108. 
     
109. 
     
110.         free(buf);
     
111.         io_destroy(pContext);
     
112.         close(fd_File);
     
113.         close(fd_EventObj);
     
114.         remove(TEST_FILE);
     
115. 
     
116.         return 0;
     
117. }

复制代码

上面代码是从网上抄的，下面是我的疑问
一、
下面现象，不知为啥(我printf 时加了\n怎么还会交错)：
1、顺序打印了20-64
“nth_request: %d, request_type: %s, offset: %lld, length: %lu, res: %ld, res2: %ld”
2、然后再打印文件中的内容（里面交错包含了19从的nth_request: %d, request_type: %s, offset: %lld, length: %lu, res: %ld, res2: %ld）
3、printf("%s\n", (char*)iocb->u.c.buf);

二、
#define  NUM_EVENTS 64  
//这个宏意味着缓存大小
        for (i = 0, apCustomIOCB = atCustomIOCB; i < NUM_EVENTS; ++i, ++apCustomIOCB)
        {
                if (posix_memalign(&buf, ALIGN_SIZE, RD_WR_SIZE))//相当于new出缓存
               
我试了，如果文件太大的话是读取不全的，而事实上缓存大小也不可能大于真实文件的，那么这就意味着iocb是需要反复利用，这样的代码怎么写？               

三、
上面那个例子是从一个已有的文件中读取数据，那如果我现在想改下代码，从网络收取文件（非epoll，每包大小约为28K，整个文件最小为8G），应该怎么写？
io_prep_pwrite(&apCustomIOCB->iocb, fd_File, buf, RD_WR_SIZE, i * RD_WR_SIZE);