#include "postgres.h"
#include "storage/aio.h"
#include "storage/aio_internal.h"
#include "storage/smgr.h"

Include dependency graph for aio_target.c:

Functions
bool	pgaio_io_has_target (PgAioHandle *ioh)

const char *	pgaio_io_get_target_name (PgAioHandle *ioh)

void	pgaio_io_set_target (PgAioHandle *ioh, PgAioTargetID targetid)

PgAioTargetData *	pgaio_io_get_target_data (PgAioHandle *ioh)

char *	pgaio_io_get_target_description (PgAioHandle *ioh)

bool	pgaio_io_can_reopen (PgAioHandle *ioh)

void	pgaio_io_reopen (PgAioHandle *ioh)

Variables
static const PgAioTargetInfo *	pgaio_target_info []

Function Documentation

◆ pgaio_io_can_reopen()

bool pgaio_io_can_reopen ( PgAioHandle * ioh )

Definition at line 99 of file aio_target.c.

{
    return pgaio_target_info[ioh->target]->reopen != NULL;
}

References pgaio_target_info, PgAioTargetInfo::reopen, and PgAioHandle::target.

Referenced by pgaio_worker_needs_synchronous_execution().

◆ pgaio_io_get_target_data()

PgAioTargetData * pgaio_io_get_target_data ( PgAioHandle * ioh )

Definition at line 72 of file aio_target.c.

{
    return &ioh->target_data;
}

References PgAioHandle::target_data.

Referenced by buffer_readv_complete(), md_readv_complete(), pgaio_io_set_target_smgr(), shared_buffer_readv_complete_local(), and smgr_aio_reopen().

◆ pgaio_io_get_target_description()

char * pgaio_io_get_target_description ( PgAioHandle * ioh )

Definition at line 83 of file aio_target.c.

{
    return pgaio_target_info[ioh->target]->describe_identity(&ioh->target_data);
}

References PgAioTargetInfo::describe_identity, pgaio_target_info, PgAioHandle::target, and PgAioHandle::target_data.

Referenced by pg_get_aios().

◆ pgaio_io_get_target_name()

const char * pgaio_io_get_target_name ( PgAioHandle * ioh )

Definition at line 50 of file aio_target.c.

{
    Assert(ioh->target >= 0 && ioh->target < PGAIO_TID_COUNT);
 
    return pgaio_target_info[ioh->target]->name;
}

References Assert(), PgAioTargetInfo::name, pgaio_target_info, PGAIO_TID_COUNT, and PgAioHandle::target.

Referenced by pg_get_aios().

◆ pgaio_io_has_target()

bool pgaio_io_has_target ( PgAioHandle * ioh )

Definition at line 40 of file aio_target.c.

{
    return ioh->target != PGAIO_TID_INVALID;
}

References PGAIO_TID_INVALID, and PgAioHandle::target.

Referenced by pgaio_io_before_start(), and pgaio_io_stage().

◆ pgaio_io_reopen()

void pgaio_io_reopen ( PgAioHandle * ioh )

Definition at line 110 of file aio_target.c.

{
    Assert(ioh->target >= 0 && ioh->target < PGAIO_TID_COUNT);
    Assert(ioh->op >= 0 && ioh->op < PGAIO_OP_COUNT);
 
    pgaio_target_info[ioh->target]->reopen(ioh);
}

References Assert(), PgAioHandle::op, PGAIO_OP_COUNT, pgaio_target_info, PGAIO_TID_COUNT, PgAioTargetInfo::reopen, and PgAioHandle::target.

Referenced by IoWorkerMain().

◆ pgaio_io_set_target()

void pgaio_io_set_target	(	PgAioHandle *	ioh,
		PgAioTargetID	targetid
	)

Definition at line 63 of file aio_target.c.

{
    Assert(ioh->state == PGAIO_HS_HANDED_OUT);
    Assert(ioh->target == PGAIO_TID_INVALID);
 
    ioh->target = targetid;
}

References Assert(), PGAIO_HS_HANDED_OUT, PGAIO_TID_INVALID, PgAioHandle::state, and PgAioHandle::target.

Referenced by pgaio_io_set_target_smgr().

Variable Documentation

◆ pgaio_target_info

const PgAioTargetInfo* pgaio_target_info[]

static

Initial value:

= {
    [PGAIO_TID_INVALID] = &(PgAioTargetInfo) {
        .name = "invalid",
    },
    [PGAIO_TID_SMGR] = &aio_smgr_target_info,
}

Definition at line 25 of file aio_target.c.

Referenced by pgaio_io_can_reopen(), pgaio_io_get_target_description(), pgaio_io_get_target_name(), and pgaio_io_reopen().

Functions

Variables