c语言 - aio_write on Large Files

Question

我试图使用aio_read(3)和aio_write(3)以异步方式模仿sendfile(2)的功能。

一切似乎都运行良好，除了测试大型(> 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 bytesn", 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_handler()内部多次呼叫aio_write()。

感谢您的帮助！

Answer 1

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

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