sharedfileset.c File Reference

#include "postgres.h"
#include <limits.h>
#include "storage/dsm.h"
#include "storage/sharedfileset.h"

Include dependency graph for sharedfileset.c:

Go to the source code of this file.

Functions
static void	SharedFileSetOnDetach (dsm_segment *segment, Datum datum)
void	SharedFileSetInit (SharedFileSet *fileset, dsm_segment *seg)
void	SharedFileSetAttach (SharedFileSet *fileset, dsm_segment *seg)
void	SharedFileSetDeleteAll (SharedFileSet *fileset)

Function Documentation

SharedFileSetAttach()

void SharedFileSetAttach	(	SharedFileSet *	fileset,
		dsm_segment *	seg
	)

Definition at line 56 of file sharedfileset.c.

{
    bool        success;
 
    SpinLockAcquire(&fileset->mutex);
    if (fileset->refcnt == 0)
        success = false;
    else
    {
        ++fileset->refcnt;
        success = true;
    }
    SpinLockRelease(&fileset->mutex);
 
    if (!success)
        ereport(ERROR,
                (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
                 errmsg("could not attach to a SharedFileSet that is already destroyed")));
 
    /* Register our cleanup callback. */
    on_dsm_detach(seg, SharedFileSetOnDetach, PointerGetDatum(fileset));
}

References ereport, errcode(), errmsg(), ERROR, SharedFileSet::mutex, on_dsm_detach(), PointerGetDatum(), SharedFileSet::refcnt, SharedFileSetOnDetach(), SpinLockAcquire, SpinLockRelease, and success.

Referenced by ExecHashJoinInitializeWorker(), and tuplesort_attach_shared().

SharedFileSetDeleteAll()

void SharedFileSetDeleteAll

(

SharedFileSet *

fileset

)

Definition at line 83 of file sharedfileset.c.

{
    FileSetDeleteAll(&fileset->fs);
}

References FileSetDeleteAll(), and SharedFileSet::fs.

Referenced by ExecHashJoinReInitializeDSM().

SharedFileSetInit()

void SharedFileSetInit	(	SharedFileSet *	fileset,
		dsm_segment *	seg
	)

Definition at line 38 of file sharedfileset.c.

{
    /* Initialize the shared fileset specific members. */
    SpinLockInit(&fileset->mutex);
    fileset->refcnt = 1;
 
    /* Initialize the fileset. */
    FileSetInit(&fileset->fs);
 
    /* Register our cleanup callback. */
    if (seg)
        on_dsm_detach(seg, SharedFileSetOnDetach, PointerGetDatum(fileset));
}

References FileSetInit(), SharedFileSet::fs, SharedFileSet::mutex, on_dsm_detach(), PointerGetDatum(), SharedFileSet::refcnt, SharedFileSetOnDetach(), and SpinLockInit.

Referenced by ExecHashJoinInitializeDSM(), and tuplesort_initialize_shared().

SharedFileSetOnDetach()

static void SharedFileSetOnDetach ( dsm_segment *  segment, Datum  datum  )

static

Definition at line 96 of file sharedfileset.c.

{
    bool        unlink_all = false;
    SharedFileSet *fileset = (SharedFileSet *) DatumGetPointer(datum);
 
    SpinLockAcquire(&fileset->mutex);
    Assert(fileset->refcnt > 0);
    if (--fileset->refcnt == 0)
        unlink_all = true;
    SpinLockRelease(&fileset->mutex);
 
    /*
     * If we are the last to detach, we delete the directory in all
     * tablespaces.  Note that we are still actually attached for the rest of
     * this function so we can safely access its data.
     */
    if (unlink_all)
        FileSetDeleteAll(&fileset->fs);
}

References Assert, DatumGetPointer(), FileSetDeleteAll(), SharedFileSet::fs, SharedFileSet::mutex, SharedFileSet::refcnt, SpinLockAcquire, and SpinLockRelease.

Referenced by SharedFileSetAttach(), and SharedFileSetInit().