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 161 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, fb(), PgAioBackend::handed_out_io, INTERRUPTS_CAN_BE_PROCESSED, PGAIO_HS_HANDED_OUT, pgaio_io_has_target(), pgaio_my_backend, and PGAIO_OP_INVALID.

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, fb(), PgAioCtl::iovecs, PG_IOV_MAX, pgaio_ctl, and PGAIO_HS_HANDED_OUT.

Referenced by mdstartreadv().

pgaio_io_get_iovec_length()

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

Definition at line 224 of file aio_io.c.

{
    Assert(ioh->state >= PGAIO_HS_DEFINED);
 
    *iov = &pgaio_ctl->iovecs[ioh->iovec_off];
 
    switch ((PgAioOp) 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, fb(), PgAioCtl::iovecs, pg_unreachable, pgaio_ctl, PGAIO_HS_DEFINED, PGAIO_OP_READV, and PGAIO_OP_WRITEV.

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 fb().

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 fb().

Referenced by smgr_aio_reopen().

pgaio_io_get_op_name()

const char * pgaio_io_get_op_name

(

PgAioHandle *

ioh

)

Definition at line 180 of file aio_io.c.

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

References Assert, fb(), PGAIO_OP_COUNT, PGAIO_OP_INVALID, PGAIO_OP_READV, and PGAIO_OP_WRITEV.

Referenced by IoWorkerMain(), and 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 ((PgAioOp) 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");
    }
 
    /*
     * ssize_t to int conversion should be ok because result should be no more
     * than PG_IOV_MAX times BLCKSZ.
     */
    Assert(result <= INT_MAX);
    ioh->result = result < 0 ? -errno : result;
 
    pgaio_io_process_completion(ioh, ioh->result);
 
    END_CRIT_SECTION();
}

References Assert, elog, END_CRIT_SECTION, ERROR, fb(), PgAioCtl::iovecs, 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(), result, and START_CRIT_SECTION.

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

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 fb(), fd(), pgaio_io_before_start(), pgaio_io_stage(), and PGAIO_OP_READV.

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 fb(), fd(), pgaio_io_before_start(), pgaio_io_stage(), and PGAIO_OP_WRITEV.

pgaio_io_uses_fd()

bool pgaio_io_uses_fd	(	PgAioHandle *	ioh,
		int	fd
	)

Definition at line 202 of file aio_io.c.

{
    Assert(ioh->state >= PGAIO_HS_DEFINED);
 
    switch ((PgAioOp) 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, fb(), fd(), PGAIO_HS_DEFINED, PGAIO_OP_INVALID, PGAIO_OP_READV, and PGAIO_OP_WRITEV.

Referenced by pgaio_closing_fd().