slru_io.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Data Structures
struct	SlruSegState

Typedefs
typedef struct SlruSegState	SlruSegState

Functions
SlruSegState *	AllocSlruRead (const char *dir, bool long_segment_names)
char *	SlruReadSwitchPageSlow (SlruSegState *state, uint64 pageno)
void	FreeSlruRead (SlruSegState *state)
static char *	SlruReadSwitchPage (SlruSegState *state, uint64 pageno)
SlruSegState *	AllocSlruWrite (const char *dir, bool long_segment_names)
char *	SlruWriteSwitchPageSlow (SlruSegState *state, uint64 pageno)
void	FreeSlruWrite (SlruSegState *state)
static char *	SlruWriteSwitchPage (SlruSegState *state, uint64 pageno)

Typedef Documentation

SlruSegState

typedef struct SlruSegState SlruSegState

Function Documentation

AllocSlruRead()

SlruSegState * AllocSlruRead ( const char *  dir, bool  long_segment_names  )

extern

Definition at line 62 of file slru_io.c.

{
    SlruSegState *state = AllocSlruSegState(dir);
 
    state->writing = false;
    state->long_segment_names = long_segment_names;
 
    return state;
}

References AllocSlruSegState().

Referenced by AllocOldMultiXactRead().

AllocSlruWrite()

SlruSegState * AllocSlruWrite ( const char *  dir, bool  long_segment_names  )

extern

Definition at line 166 of file slru_io.c.

{
    SlruSegState *state = AllocSlruSegState(dir);
 
    state->writing = true;
    state->long_segment_names = long_segment_names;
 
    return state;
}

References AllocSlruSegState().

Referenced by rewrite_multixacts().

FreeSlruRead()

void FreeSlruRead ( SlruSegState *  state )

extern

Definition at line 153 of file slru_io.c.

{
    Assert(!state->writing);    /* read only mode */
 
    if (state->fd != -1)
        close(state->fd);
    pg_free(state);
}

References Assert, close, and pg_free().

Referenced by FreeOldMultiXactReader().

FreeSlruWrite()

void FreeSlruWrite ( SlruSegState *  state )

extern

Definition at line 260 of file slru_io.c.

{
    Assert(state->writing);
 
    SlruFlush(state);
 
    if (state->fd != -1)
        close(state->fd);
    pg_free(state);
}

References Assert, close, pg_free(), and SlruFlush().

Referenced by rewrite_multixacts().

SlruReadSwitchPage()

static char * SlruReadSwitchPage ( SlruSegState *  state, uint64  pageno  )

inlinestatic

Definition at line 33 of file slru_io.h.

{
    if (state->segno != -1 && pageno == state->pageno)
        return state->buf.data;
    return SlruReadSwitchPageSlow(state, pageno);
}

References SlruReadSwitchPageSlow().

Referenced by GetOldMultiXactIdSingleMember().

SlruReadSwitchPageSlow()

char * SlruReadSwitchPageSlow ( SlruSegState *  state, uint64  pageno  )

extern

Definition at line 85 of file slru_io.c.

{
    int64       segno;
    off_t       offset;
    ssize_t     bytes_read;
 
    Assert(!state->writing);    /* read only mode */
 
    if (state->segno != -1 && pageno == state->pageno)
        return state->buf.data;
 
    /* If the new page is on a different SLRU segment, open the new segment */
    segno = pageno / SLRU_PAGES_PER_SEGMENT;
    if (segno != state->segno)
    {
        if (state->segno != -1)
        {
            close(state->fd);
            state->fd = -1;
 
            pg_free(state->fn);
            state->fn = NULL;
 
            state->segno = -1;
        }
 
        state->fn = SlruFileName(state, segno);
        if ((state->fd = open(state->fn, O_RDONLY | PG_BINARY, 0)) < 0)
            pg_fatal("could not open file \"%s\": %m", state->fn);
        state->segno = segno;
    }
 
    offset = (pageno % SLRU_PAGES_PER_SEGMENT) * BLCKSZ;
    bytes_read = 0;
    while (bytes_read < BLCKSZ)
    {
        ssize_t     rc;
 
        rc = pg_pread(state->fd,
                      &state->buf.data[bytes_read],
                      BLCKSZ - bytes_read,
                      offset);
        if (rc < 0)
        {
            if (errno == EINTR)
                continue;
            pg_fatal("could not read file \"%s\": %m", state->fn);
        }
        if (rc == 0)
        {
            /* unexpected EOF */
            pg_log(PG_WARNING, "unexpected EOF reading file \"%s\" at offset %u, reading as zeros",
                   state->fn, (unsigned int) offset);
            memset(&state->buf.data[bytes_read], 0, BLCKSZ - bytes_read);
            break;
        }
        bytes_read += rc;
        offset += rc;
    }
    state->pageno = pageno;
 
    return state->buf.data;
}

References Assert, close, EINTR, fb(), PG_BINARY, pg_fatal, pg_free(), pg_log(), pg_pread, PG_WARNING, SLRU_PAGES_PER_SEGMENT, and SlruFileName().

Referenced by SlruReadSwitchPage().

SlruWriteSwitchPage()

static char * SlruWriteSwitchPage ( SlruSegState *  state, uint64  pageno  )

inlinestatic

Definition at line 45 of file slru_io.h.

{
    if (state->segno != -1 && pageno == state->pageno)
        return state->buf.data;
    return SlruWriteSwitchPageSlow(state, pageno);
}

References SlruWriteSwitchPageSlow().

Referenced by RecordMultiXactMembers(), RecordMultiXactOffset(), and rewrite_multixacts().

SlruWriteSwitchPageSlow()

char * SlruWriteSwitchPageSlow ( SlruSegState *  state, uint64  pageno  )

extern

Definition at line 187 of file slru_io.c.

{
    int64       segno;
    off_t       offset;
 
    Assert(state->writing);
 
    if (state->segno != -1 && pageno == state->pageno)
        return state->buf.data;
 
    segno = pageno / SLRU_PAGES_PER_SEGMENT;
    offset = (pageno % SLRU_PAGES_PER_SEGMENT) * BLCKSZ;
 
    SlruFlush(state);
    memset(state->buf.data, 0, BLCKSZ);
 
    if (segno != state->segno)
    {
        if (state->segno != -1)
        {
            close(state->fd);
            state->fd = -1;
 
            pg_free(state->fn);
            state->fn = NULL;
 
            state->segno = -1;
        }
 
        /* Create the segment */
        state->fn = SlruFileName(state, segno);
        if ((state->fd = open(state->fn, O_RDWR | O_CREAT | O_EXCL | PG_BINARY,
                              pg_file_create_mode)) < 0)
        {
            pg_fatal("could not create file \"%s\": %m", state->fn);
        }
 
        state->segno = segno;
 
        if (offset > 0)
        {
            if (pg_pwrite_zeros(state->fd, offset, 0) < 0)
                pg_fatal("could not write file \"%s\": %m", state->fn);
        }
    }
 
    state->pageno = pageno;
 
    return state->buf.data;
}

References Assert, close, fb(), PG_BINARY, pg_fatal, pg_file_create_mode, pg_free(), pg_pwrite_zeros(), SLRU_PAGES_PER_SEGMENT, SlruFileName(), and SlruFlush().

Referenced by SlruWriteSwitchPage().