#include "postgres.h"
#include "miscadmin.h"
#include "storage/aio.h"
#include "storage/aio_internal.h"
#include "storage/fd.h"
#include "utils/wait_event.h"

Include dependency graph for aio_io.c:

Functions
static void	pgaio_io_before_prep (PgAioHandle *ioh)

int	pgaio_io_get_iovec (PgAioHandle ioh, struct iovec *iov)

PgAioOp	pgaio_io_get_op (PgAioHandle *ioh)

PgAioOpData *	pgaio_io_get_op_data (PgAioHandle *ioh)

void	pgaio_io_prep_readv (PgAioHandle *ioh, int fd, int iovcnt, uint64 offset)

void	pgaio_io_prep_writev (PgAioHandle *ioh, int fd, int iovcnt, uint64 offset)

void	pgaio_io_perform_synchronously (PgAioHandle *ioh)

const char *	pgaio_io_get_op_name (PgAioHandle *ioh)

Function Documentation

◆ pgaio_io_before_prep()

static void pgaio_io_before_prep ( PgAioHandle * ioh )

static

Definition at line 156 of file aio_io.c.

{
    Assert(ioh->state == PGAIO_HS_HANDED_OUT);
    Assert(pgaio_my_backend->handed_out_io == ioh);
    Assert(pgaio_io_has_target(ioh));
    Assert(ioh->op == PGAIO_OP_INVALID);
}

References Assert(), PgAioBackend::handed_out_io, PgAioHandle::op, PGAIO_HS_HANDED_OUT, pgaio_io_has_target(), pgaio_my_backend, PGAIO_OP_INVALID, and PgAioHandle::state.

Referenced by pgaio_io_prep_readv(), and pgaio_io_prep_writev().

◆ pgaio_io_get_iovec()

int pgaio_io_get_iovec	(	PgAioHandle *	ioh,
		struct iovec **	iov
	)

Definition at line 42 of file aio_io.c.

{
    Assert(ioh->state == PGAIO_HS_HANDED_OUT);
 
    *iov = &pgaio_ctl->iovecs[ioh->iovec_off];
 
    return PG_IOV_MAX;
}

References Assert(), PgAioHandle::iovec_off, PgAioCtl::iovecs, PG_IOV_MAX, pgaio_ctl, PGAIO_HS_HANDED_OUT, and PgAioHandle::state.

◆ pgaio_io_get_op()

PgAioOp pgaio_io_get_op ( PgAioHandle * ioh )

Definition at line 52 of file aio_io.c.

{
    return ioh->op;
}

References PgAioHandle::op.

◆ pgaio_io_get_op_data()

PgAioOpData * pgaio_io_get_op_data ( PgAioHandle * ioh )

Definition at line 58 of file aio_io.c.

{
    return &ioh->op_data;
}

References PgAioHandle::op_data.

◆ pgaio_io_get_op_name()

const char * pgaio_io_get_op_name ( PgAioHandle * ioh )

Definition at line 169 of file aio_io.c.

{
    Assert(ioh->op >= 0 && ioh->op < PGAIO_OP_COUNT);
 
    switch (ioh->op)
    {
        case PGAIO_OP_INVALID:
            return "invalid";
        case PGAIO_OP_READV:
            return "read";
        case PGAIO_OP_WRITEV:
            return "write";
    }
 
    return NULL;                /* silence compiler */
}

References Assert(), PgAioHandle::op, PGAIO_OP_COUNT, PGAIO_OP_INVALID, PGAIO_OP_READV, and PGAIO_OP_WRITEV.

◆ pgaio_io_perform_synchronously()

void pgaio_io_perform_synchronously ( PgAioHandle * ioh )

Definition at line 116 of file aio_io.c.

{
    ssize_t     result = 0;
    struct iovec *iov = &pgaio_ctl->iovecs[ioh->iovec_off];
 
    START_CRIT_SECTION();
 
    /* Perform IO. */
    switch (ioh->op)
    {
        case PGAIO_OP_READV:
            pgstat_report_wait_start(WAIT_EVENT_DATA_FILE_READ);
            result = pg_preadv(ioh->op_data.read.fd, iov,
                               ioh->op_data.read.iov_length,
                               ioh->op_data.read.offset);
            pgstat_report_wait_end();
            break;
        case PGAIO_OP_WRITEV:
            pgstat_report_wait_start(WAIT_EVENT_DATA_FILE_WRITE);
            result = pg_pwritev(ioh->op_data.write.fd, iov,
                                ioh->op_data.write.iov_length,
                                ioh->op_data.write.offset);
            pgstat_report_wait_end();
            break;
        case PGAIO_OP_INVALID:
            elog(ERROR, "trying to execute invalid IO operation");
    }
 
    ioh->result = result < 0 ? -errno : result;
 
    pgaio_io_process_completion(ioh, ioh->result);
 
    END_CRIT_SECTION();
}

References elog, END_CRIT_SECTION, ERROR, PgAioOpData::fd, PgAioOpData::iov_length, PgAioHandle::iovec_off, PgAioCtl::iovecs, PgAioOpData::offset, PgAioHandle::op, PgAioHandle::op_data, pg_preadv(), pg_pwritev(), pgaio_ctl, pgaio_io_process_completion(), PGAIO_OP_INVALID, PGAIO_OP_READV, PGAIO_OP_WRITEV, pgstat_report_wait_end(), pgstat_report_wait_start(), PgAioOpData::read, PgAioHandle::result, START_CRIT_SECTION, and PgAioOpData::write.

Referenced by IoWorkerMain(), pgaio_io_stage(), and pgaio_worker_submit_internal().

◆ pgaio_io_prep_readv()

void pgaio_io_prep_readv	(	PgAioHandle *	ioh,
		int	fd,
		int	iovcnt,
		uint64	offset
	)

Definition at line 78 of file aio_io.c.

{
    pgaio_io_before_prep(ioh);
 
    ioh->op_data.read.fd = fd;
    ioh->op_data.read.offset = offset;
    ioh->op_data.read.iov_length = iovcnt;
 
    pgaio_io_stage(ioh, PGAIO_OP_READV);
}

References PgAioOpData::fd, fd(), PgAioOpData::iov_length, PgAioOpData::offset, PgAioHandle::op_data, pgaio_io_before_prep(), pgaio_io_stage(), PGAIO_OP_READV, and PgAioOpData::read.

◆ pgaio_io_prep_writev()

void pgaio_io_prep_writev	(	PgAioHandle *	ioh,
		int	fd,
		int	iovcnt,
		uint64	offset
	)

Definition at line 91 of file aio_io.c.

{
    pgaio_io_before_prep(ioh);
 
    ioh->op_data.write.fd = fd;
    ioh->op_data.write.offset = offset;
    ioh->op_data.write.iov_length = iovcnt;
 
    pgaio_io_stage(ioh, PGAIO_OP_WRITEV);
}

References PgAioOpData::fd, fd(), PgAioOpData::iov_length, PgAioOpData::offset, PgAioHandle::op_data, pgaio_io_before_prep(), pgaio_io_stage(), PGAIO_OP_WRITEV, and PgAioOpData::write.

Functions