fileset.h File Reference

#include "storage/fd.h"

Include dependency graph for fileset.h:

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

Go to the source code of this file.

Data Structures
struct	FileSet

Typedefs
typedef struct FileSet	FileSet

Functions
void	FileSetInit (FileSet *fileset)
File	FileSetCreate (FileSet *fileset, const char *name)
File	FileSetOpen (FileSet *fileset, const char *name, int mode)
bool	FileSetDelete (FileSet *fileset, const char *name, bool error_on_failure)
void	FileSetDeleteAll (FileSet *fileset)

Typedef Documentation

FileSet

typedef struct FileSet FileSet

Function Documentation

FileSetCreate()

File FileSetCreate	(	FileSet *	fileset,
		const char *	name
	)

Definition at line 95 of file fileset.c.

{
    char        path[MAXPGPATH];
    File        file;
 
    FilePath(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);
        FileSetPath(filesetpath, fileset, tablespace);
        PathNameCreateTemporaryDir(tempdirpath, filesetpath);
        file = PathNameCreateTemporaryFile(path, true);
    }
 
    return file;
}

References ChooseTablespace(), FilePath(), FileSetPath(), MAXPGPATH, name, PathNameCreateTemporaryDir(), PathNameCreateTemporaryFile(), tablespace, and TempTablespacePath().

Referenced by MakeNewFileSetSegment().

FileSetDelete()

bool FileSetDelete	(	FileSet *	fileset,
		const char *	name,
		bool	error_on_failure
	)

Definition at line 139 of file fileset.c.

{
    char        path[MAXPGPATH];
 
    FilePath(path, fileset, name);
 
    return PathNameDeleteTemporaryFile(path, error_on_failure);
}

References FilePath(), MAXPGPATH, name, and PathNameDeleteTemporaryFile().

Referenced by BufFileDeleteFileSet(), BufFileTruncateFileSet(), and MakeNewFileSetSegment().

FileSetDeleteAll()

void FileSetDeleteAll

(

FileSet *

fileset

)

Definition at line 153 of file fileset.c.

{
    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)
    {
        FileSetPath(dirpath, fileset, fileset->tablespaces[i]);
        PathNameDeleteTemporaryDir(dirpath);
    }
}

References FileSetPath(), i, MAXPGPATH, FileSet::ntablespaces, PathNameDeleteTemporaryDir(), and FileSet::tablespaces.

Referenced by logicalrep_worker_onexit(), SharedFileSetDeleteAll(), and SharedFileSetOnDetach().

FileSetInit()

void FileSetInit

(

FileSet *

fileset

)

Definition at line 55 of file fileset.c.

{
    static uint32 counter = 0;
 
    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)
    {
        /* If the GUC is empty, use current database's default tablespace */
        fileset->tablespaces[0] = MyDatabaseTableSpace;
        fileset->ntablespaces = 1;
    }
    else
    {
        int         i;
 
        /*
         * An entry of InvalidOid means use the default tablespace for the
         * current database.  Replace that now, to be sure that all users of
         * the FileSet agree on what to do.
         */
        for (i = 0; i < fileset->ntablespaces; i++)
        {
            if (fileset->tablespaces[i] == InvalidOid)
                fileset->tablespaces[i] = MyDatabaseTableSpace;
        }
    }
}

References FileSet::creator_pid, GetTempTablespaces(), i, InvalidOid, lengthof, MyDatabaseTableSpace, MyProcPid, FileSet::ntablespaces, FileSet::number, PrepareTempTablespaces(), and FileSet::tablespaces.

Referenced by SharedFileSetInit(), and stream_start_internal().

FileSetOpen()

File FileSetOpen	(	FileSet *	fileset,
		const char *	name,
		int	mode
	)

Definition at line 122 of file fileset.c.

{
    char        path[MAXPGPATH];
    File        file;
 
    FilePath(path, fileset, name);
    file = PathNameOpenTemporaryFile(path, mode);
 
    return file;
}

References FilePath(), MAXPGPATH, mode, name, and PathNameOpenTemporaryFile().

Referenced by BufFileOpenFileSet().