sharedfileset.h File Reference

#include "storage/dsm.h"
#include "storage/fd.h"
#include "storage/spin.h"

Include dependency graph for sharedfileset.h:

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

Go to the source code of this file.

Data Structures
struct	SharedFileSet

Typedefs
typedef struct SharedFileSet	SharedFileSet

Functions
void	SharedFileSetInit (SharedFileSet *fileset, dsm_segment *seg)
void	SharedFileSetAttach (SharedFileSet *fileset, dsm_segment *seg)
File	SharedFileSetCreate (SharedFileSet *fileset, const char *name)
File	SharedFileSetOpen (SharedFileSet *fileset, const char *name)
bool	SharedFileSetDelete (SharedFileSet *fileset, const char *name, bool error_on_failure)
void	SharedFileSetDeleteAll (SharedFileSet *fileset)

Typedef Documentation

SharedFileSet

typedef struct SharedFileSet SharedFileSet

Function Documentation

SharedFileSetAttach()

void SharedFileSetAttach	(	SharedFileSet *	fileset,
		dsm_segment *	seg
	)

Definition at line 78 of file sharedfileset.c.

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

{
    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));
}

SharedFileSetCreate()

File SharedFileSetCreate	(	SharedFileSet *	fileset,
		const char *	name
	)

Definition at line 105 of file sharedfileset.c.

References ChooseTablespace(), MAXPGPATH, PathNameCreateTemporaryDir(), PathNameCreateTemporaryFile(), SharedFilePath(), SharedFileSetPath(), tablespace, and TempTablespacePath().

Referenced by MakeNewSharedSegment().

{
    char        path[MAXPGPATH];
    File        file;

    SharedFilePath(path, fileset, name);
    file = PathNameCreateTemporaryFile(path, false);

    /* If we failed, see if we need to create the directory on demand. */
    if (file <= 0)
    {
        char        tempdirpath[MAXPGPATH];
        char        filesetpath[MAXPGPATH];
        Oid         tablespace = ChooseTablespace(fileset, name);

        TempTablespacePath(tempdirpath, tablespace);
        SharedFileSetPath(filesetpath, fileset, tablespace);
        PathNameCreateTemporaryDir(tempdirpath, filesetpath);
        file = PathNameCreateTemporaryFile(path, true);
    }

    return file;
}

SharedFileSetDelete()

bool SharedFileSetDelete	(	SharedFileSet *	fileset,
		const char *	name,
		bool	error_on_failure
	)

Definition at line 150 of file sharedfileset.c.

References MAXPGPATH, PathNameDeleteTemporaryFile(), and SharedFilePath().

Referenced by BufFileDeleteShared(), and MakeNewSharedSegment().

{
    char        path[MAXPGPATH];

    SharedFilePath(path, fileset, name);

    return PathNameDeleteTemporaryFile(path, error_on_failure);
}

SharedFileSetDeleteAll()

void SharedFileSetDeleteAll

(

SharedFileSet *

fileset

)

Definition at line 164 of file sharedfileset.c.

References i, MAXPGPATH, SharedFileSet::ntablespaces, PathNameDeleteTemporaryDir(), SharedFileSetPath(), and SharedFileSet::tablespaces.

Referenced by ExecHashJoinReInitializeDSM(), and SharedFileSetOnDetach().

{
    char        dirpath[MAXPGPATH];
    int         i;

    /*
     * Delete the directory we created in each tablespace.  Doesn't fail
     * because we use this in error cleanup paths, but can generate LOG
     * message on IO error.
     */
    for (i = 0; i < fileset->ntablespaces; ++i)
    {
        SharedFileSetPath(dirpath, fileset, fileset->tablespaces[i]);
        PathNameDeleteTemporaryDir(dirpath);
    }
}

SharedFileSetInit()

void SharedFileSetInit	(	SharedFileSet *	fileset,
		dsm_segment *	seg
	)

Definition at line 49 of file sharedfileset.c.

References SharedFileSet::creator_pid, GetTempTablespaces(), lengthof, SharedFileSet::mutex, MyProcPid, SharedFileSet::ntablespaces, SharedFileSet::number, on_dsm_detach(), PointerGetDatum, PrepareTempTablespaces(), SharedFileSet::refcnt, SharedFileSetOnDetach(), SpinLockInit, and SharedFileSet::tablespaces.

Referenced by ExecHashJoinInitializeDSM(), and tuplesort_initialize_shared().

{
    static uint32 counter = 0;

    SpinLockInit(&fileset->mutex);
    fileset->refcnt = 1;
    fileset->creator_pid = MyProcPid;
    fileset->number = counter;
    counter = (counter + 1) % INT_MAX;

    /* Capture the tablespace OIDs so that all backends agree on them. */
    PrepareTempTablespaces();
    fileset->ntablespaces =
        GetTempTablespaces(&fileset->tablespaces[0],
                           lengthof(fileset->tablespaces));
    if (fileset->ntablespaces == 0)
    {
        fileset->tablespaces[0] = DEFAULTTABLESPACE_OID;
        fileset->ntablespaces = 1;
    }

    /* Register our cleanup callback. */
    on_dsm_detach(seg, SharedFileSetOnDetach, PointerGetDatum(fileset));
}

SharedFileSetOpen()

File SharedFileSetOpen	(	SharedFileSet *	fileset,
		const char *	name
	)

Definition at line 134 of file sharedfileset.c.

References MAXPGPATH, PathNameOpenTemporaryFile(), and SharedFilePath().

Referenced by BufFileOpenShared().

{
    char        path[MAXPGPATH];
    File        file;

    SharedFilePath(path, fileset, name);
    file = PathNameOpenTemporaryFile(path);

    return file;
}