Advanced Programming in the UNIX® Environment

ptg10805159

Section 14.5 Asynchronous I/O 519

numop++;

}

break;

case READ_PENDING:

if ((err = aio_error(&bufs[i].aiocb)) == EINPROGRESS)

continue;

if (err != 0) {

if (err == -1)

err_sys("aio_error failed");

else

err_exit(err, "read failed");

}

/*

*Aread is complete; translate the buffer

*and write it.

*/

if ((n = aio_return(&bufs[i].aiocb)) < 0)

err_sys("aio_return failed");

if (n != BSZ && !bufs[i].last)

err_quit("short read (%d/%d)", n, BSZ);

for (j = 0; j < n; j++)

bufs[i].data[j] = translate(bufs[i].data[j]);

bufs[i].op = WRITE_PENDING;

bufs[i].aiocb.aio_fildes = ofd;

bufs[i].aiocb.aio_nbytes = n;

if (aio_write(&bufs[i].aiocb) < 0)

err_sys("aio_write failed");

/* retain our spot in aiolist */

break;

case WRITE_PENDING:

if ((err = aio_error(&bufs[i].aiocb)) == EINPROGRESS)

continue;

if (err != 0) {

if (err == -1)

err_sys("aio_error failed");

else

err_exit(err, "write failed");

}

/*

*Awrite is complete; mark the buffer as unused.

*/

if ((n = aio_return(&bufs[i].aiocb)) < 0)

err_sys("aio_return failed");

if (n != bufs[i].aiocb.aio_nbytes)

err_quit("short write (%d/%d)", n, BSZ);

aiolist[i] = NULL;

bufs[i].op = UNUSED;