aio_io.c File Reference

#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:

Go to the source code of this file.

Functions
static void	pgaio_io_before_start (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_start_readv (PgAioHandle *ioh, int fd, int iovcnt, uint64 offset)
void	pgaio_io_start_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)
bool	pgaio_io_uses_fd (PgAioHandle *ioh, int fd)
int	pgaio_io_get_iovec_length (PgAioHandle *ioh, struct iovec **iov)

Function Documentation

pgaio_io_before_start()

static void pgaio_io_before_start ( 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);
 
    /*
     * Otherwise the FDs referenced by the IO could be closed due to interrupt
     * processing.
     */
    Assert(!INTERRUPTS_CAN_BE_PROCESSED());
}

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

Referenced by pgaio_io_start_readv(), and pgaio_io_start_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.

Referenced by mdstartreadv().

pgaio_io_get_iovec_length()

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

Definition at line 219 of file aio_io.c.

{
    Assert(ioh->state >= PGAIO_HS_DEFINED);
 
    *iov = &pgaio_ctl->iovecs[ioh->iovec_off];
 
    switch (ioh->op)
    {
        case PGAIO_OP_READV:
            return ioh->op_data.read.iov_length;
        case PGAIO_OP_WRITEV:
            return ioh->op_data.write.iov_length;
        default:
            pg_unreachable();
            return 0;
    }
}

References Assert(), PgAioOpData::iov_length, PgAioHandle::iovec_off, PgAioCtl::iovecs, PgAioHandle::op, PgAioHandle::op_data, pg_unreachable, pgaio_ctl, PGAIO_HS_DEFINED, PGAIO_OP_READV, PGAIO_OP_WRITEV, PgAioOpData::read, PgAioHandle::state, and PgAioOpData::write.

Referenced by IoWorkerMain().

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.

Referenced by smgr_aio_reopen().

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.

Referenced by smgr_aio_reopen().

pgaio_io_get_op_name()

const char * pgaio_io_get_op_name

(

PgAioHandle *

ioh

)

Definition at line 175 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.

Referenced by pg_get_aios().

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_start_readv()

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

Definition at line 78 of file aio_io.c.

{
    pgaio_io_before_start(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_start(), pgaio_io_stage(), PGAIO_OP_READV, and PgAioOpData::read.

Referenced by FileStartReadV().

pgaio_io_start_writev()

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

Definition at line 91 of file aio_io.c.

{
    pgaio_io_before_start(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_start(), pgaio_io_stage(), PGAIO_OP_WRITEV, and PgAioOpData::write.

pgaio_io_uses_fd()

bool pgaio_io_uses_fd	(	PgAioHandle *	ioh,
		int	fd
	)

Definition at line 197 of file aio_io.c.

{
    Assert(ioh->state >= PGAIO_HS_DEFINED);
 
    switch (ioh->op)
    {
        case PGAIO_OP_READV:
            return ioh->op_data.read.fd == fd;
        case PGAIO_OP_WRITEV:
            return ioh->op_data.write.fd == fd;
        case PGAIO_OP_INVALID:
            return false;
    }
 
    return false;               /* silence compiler */
}

References Assert(), PgAioOpData::fd, fd(), PgAioHandle::op, PgAioHandle::op_data, PGAIO_HS_DEFINED, PGAIO_OP_INVALID, PGAIO_OP_READV, PGAIO_OP_WRITEV, PgAioOpData::read, PgAioHandle::state, and PgAioOpData::write.

Referenced by pgaio_closing_fd().