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

Include dependency graph for aio_target.c:

Variables
static const PgAioTargetInfo *	pgaio_target_info []

Function Documentation

◆ pgaio_io_can_reopen()

bool pgaio_io_can_reopen ( PgAioHandle * ioh )

Definition at line 103 of file aio_target.c.

{
    Assert(ioh->target > PGAIO_TID_INVALID && ioh->target < PGAIO_TID_COUNT);
 
    return pgaio_target_info[ioh->target]->reopen != NULL;
}

References Assert, fb(), pgaio_target_info, PGAIO_TID_COUNT, PGAIO_TID_INVALID, and PgAioTargetInfo::reopen.

Referenced by pgaio_worker_needs_synchronous_execution().

◆ pgaio_io_get_target_data()

PgAioTargetData * pgaio_io_get_target_data ( PgAioHandle * ioh )

Definition at line 73 of file aio_target.c.

{
    return &ioh->target_data;
}

References fb().

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 84 of file aio_target.c.

{
    /* disallow INVALID, there wouldn't be a description */
    Assert(ioh->target > PGAIO_TID_INVALID && ioh->target < PGAIO_TID_COUNT);
 
    return pgaio_target_info[ioh->target]->describe_identity(&ioh->target_data);
}

References Assert, PgAioTargetInfo::describe_identity, fb(), pgaio_target_info, PGAIO_TID_COUNT, and PGAIO_TID_INVALID.

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.

{
    /* explicitly allow INVALID here, function used by debug messages */
    Assert(ioh->target >= PGAIO_TID_INVALID && ioh->target < PGAIO_TID_COUNT);
 
    return pgaio_target_info[ioh->target]->name;
}

References Assert, fb(), PgAioTargetInfo::name, pgaio_target_info, PGAIO_TID_COUNT, and PGAIO_TID_INVALID.

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

Referenced by pgaio_io_before_start(), and pgaio_io_stage().

◆ pgaio_io_reopen()

void pgaio_io_reopen ( PgAioHandle * ioh )

Definition at line 116 of file aio_target.c.

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

References Assert, fb(), PGAIO_OP_COUNT, PGAIO_OP_INVALID, pgaio_target_info, PGAIO_TID_COUNT, PGAIO_TID_INVALID, and PgAioTargetInfo::reopen.

Referenced by IoWorkerMain().

◆ pgaio_io_set_target()

void pgaio_io_set_target	(	PgAioHandle *	ioh,
		PgAioTargetID	targetid
	)

Definition at line 64 of file aio_target.c.

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

References Assert, fb(), PGAIO_HS_HANDED_OUT, and PGAIO_TID_INVALID.

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.

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

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

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)

Functions

Variables