0

我试图从本质上模仿使用andsendfile(2)以异步方式的功能。aio_read(3)aio_write(3)

除了测试大（> 150k）文件外，一切似乎都运行良好。

我有一个简单的struct io_request用来跟踪转移的方法：

struct io_request {
    int status;
    struct aiocb *aiocbp;
    int sfd;
};

首先，我建立aio_read()电话：

struct io_request * ioreq = malloc(sizeof(struct io_request));
ioreq->status = EINPROGRESS;
ioreq->sfd = sfd;

struct aiocb * aiocbreq = malloc(sizeof(struct aiocb));
memset(aiocbreq, 0, sizeof(struct aiocb));

ioreq->aiocbp = aiocbreq;

ioreq->aiocbp->aio_fildes = ffd;

if (ioreq->aiocbp->aio_fildes == -1) {
    perror("aio_fildes");
}

ioreq->aiocbp->aio_buf = malloc(st.st_size);
if (ioreq->aiocbp->aio_buf == NULL) {
    perror("aio_buf malloc");
}

ioreq->aiocbp->aio_nbytes = st.st_size;
ioreq->aiocbp->aio_reqprio = 0;
ioreq->aiocbp->aio_offset = 0;
ioreq->aiocbp->aio_sigevent.sigev_signo = IO_READ_SIGNAL;
ioreq->aiocbp->aio_sigevent.sigev_value.sival_ptr = ioreq;
if (aio_read(ioreq->aiocbp) == -1) {
    perror("aio_read");
}

然后在IO_READ_SIGNAL处理程序中捕获：

static void
aio_read_handler(int sig, siginfo_t *si, void *ucontext)
{
    if (si->si_code == SI_ASYNCIO) {
        struct io_request *ioreq = si->si_value.sival_ptr;

        // Build the AIO write request
        struct aiocb aiocbreq;
        memset(&aiocbreq, 0, sizeof(struct aiocb));
        aiocbreq.aio_fildes = ioreq->sfd;
        aiocbreq.aio_buf = ioreq->aiocbp->aio_buf;
        aiocbreq.aio_nbytes = ioreq->aiocbp->aio_nbytes;
        aiocbreq.aio_sigevent.sigev_signo = IO_WRITE_SIGNAL;
        aiocbreq.aio_sigevent.sigev_value.sival_ptr = ioreq;

        if (aio_write((void *) &aiocbreq) == -1) {
            perror("aio_write");
        }
    }
}

我可以确认在处理程序内部，即使对于大文件，其内容ioreq->aiocbp->aio_buf也是完整的。

稍后，aio_write()在处理程序中捕获IO_WRITE_SIGNAL：

static void
aio_write_handler(int sig, siginfo_t *si, void *ucontext)
{
    if (si->si_code == SI_ASYNCIO) {
        struct io_request *ioreq = si->si_value.sival_ptr;

        ssize_t bytes_written = aio_return(ioreq->aiocbp);
        printf("Wrote %zu of %zu bytes\n", bytes_written, ioreq->aiocbp->aio_nbytes);
        //free(ioreq->aiocbp);
        //free(ioreq);

        if (aio_error(ioreq->aiocbp) != 0) {
            perror("aio_write_handler");
        }
    }
}

至此aio_write()应该已经完成​​了。我检查返回值并采取相应措施。两个调用都报告已写入适当数量的字节，并且在写入过程中没有出现错误。

更大的应用程序是 HTTP 服务器。我推测这个问题的出现是因为远程客户端的读取速度不够快，无法跟上aio_write(). 当我有这个实现时，我必须多次sendfile()调用才能完成文件传输。sendfile()

几个直接的问题：

  • 为什么不aio_return()报告aio_error()任何问题？
  • 我该如何解决这种行为？
  • 有没有办法缓冲aio_write()？我正在考虑将n_bytes内部struct aiocb传递给封顶，并从内部多次aio_write()调用。aio_write()aio_write_handler()

谢谢你的帮助！

4

1 回答 1

0

如果我理解正确，您aio_return之前使用的是aio_error. aio_return手册页说，

在aio_error (3) 返回EINPROGRESS以外的内容之后，对于任何给定的请求，该函数只应调用一次 。

于 2016-12-08T22:46:40.983 回答