快速业务通道

关于异步IO使用的一个例子

作者 佚名技术 来源 Linux系统 浏览 发布时间 2012-04-14

#include <errno.h>
#include <stdio.h>
#include <fcntl.h>
#include <unistd.h>
#include <string.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <libaio.h>

int main()
{
io_context_t ctx;
unsigned nr_events = 10;

memset(&ctx, 0, sizeof(ctx));

int errcode = io_setup(nr_events, &ctx);
if (errcode == 0)
printf("io_setup successn");
else
printf("io_setup error: :%d:%sn", errcode, strerror(-errcode));


int fd = open("direct.txt", O_CREAT|O_DIRECT|O_WRONLY, S_IRWXU|S_IRWXG|S_IROTH);
printf("open: %sn", strerror(errno));

char * buf;
errcode = posix_memalign((void**)&buf, sysconf(_SC_PAGESIZE), sysconf(_SC_PAGESIZE));
printf("posix_memalign: %sn", strerror(errcode));

strcpy(buf, "hello xxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxxx");

struct iocb *iocbpp = (struct iocb *)malloc(sizeof(struct iocb));
memset(iocbpp, 0, sizeof(struct iocb));

iocbpp[0].data = buf;
iocbpp[0].aio_lio_opcode = IO_CMD_PWRITE;
iocbpp[0].aio_reqprio = 0;
iocbpp[0].aio_fildes = fd;

iocbpp[0].u.c.buf = buf;
iocbpp[0].u.c.nbytes = sysconf(_SC_PAGESIZE);
iocbpp[0].u.c.offset = 0;


int n = io_submit(ctx, 1, &iocbpp);
printf("==io_submit==: %d:n", n);

struct io_event events[10];
struct timespec timeout = {1, 100};

//n = io_getevents(ctx, 1, 10, events, &timeout);
//printf("io_getevents: %d:n", n);

close(fd);
io_destroy(ctx);

return 0;
}
编译方法:gcc -0 myaio myaio.c -laio -D_GNU_SOURCE

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务,公司网站:http://www.lingzhong.cn 为了给广大客户了解更多的技术信息,本技术文章收集来源于网络,凌众科技尊重文章作者的版权,如果有涉及你的版权有必要删除你的文章,请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息,谢谢!

分享到: 更多

Copyright ©1999-2011 厦门凌众科技有限公司 厦门优通互联科技开发有限公司 All rights reserved

地址(ADD):厦门软件园二期望海路63号701E(东南融通旁) 邮编(ZIP):361008

电话:0592-5908028 传真:0592-5908039 咨询信箱:web@lingzhong.cn 咨询OICQ:173723134

《中华人民共和国增值电信业务经营许可证》闽B2-20100024  ICP备案:闽ICP备05037997号