adminpack.c File Reference

#include "postgres.h"
#include <sys/file.h>
#include <sys/stat.h>
#include <unistd.h>
#include "catalog/pg_authid.h"
#include "catalog/pg_type.h"
#include "funcapi.h"
#include "miscadmin.h"
#include "postmaster/syslogger.h"
#include "storage/fd.h"
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/datetime.h"

Include dependency graph for adminpack.c:

Go to the source code of this file.

Functions
	PG_FUNCTION_INFO_V1 (pg_file_write)
	PG_FUNCTION_INFO_V1 (pg_file_write_v1_1)
	PG_FUNCTION_INFO_V1 (pg_file_sync)
	PG_FUNCTION_INFO_V1 (pg_file_rename)
	PG_FUNCTION_INFO_V1 (pg_file_rename_v1_1)
	PG_FUNCTION_INFO_V1 (pg_file_unlink)
	PG_FUNCTION_INFO_V1 (pg_file_unlink_v1_1)
	PG_FUNCTION_INFO_V1 (pg_logdir_ls)
	PG_FUNCTION_INFO_V1 (pg_logdir_ls_v1_1)
static int64	pg_file_write_internal (text *file, text *data, bool replace)
static bool	pg_file_rename_internal (text *file1, text *file2, text *file3)
static Datum	pg_logdir_ls_internal (FunctionCallInfo fcinfo)
static char *	convert_and_check_filename (text *arg)
static void	requireSuperuser (void)
Datum	pg_file_write (PG_FUNCTION_ARGS)
Datum	pg_file_write_v1_1 (PG_FUNCTION_ARGS)
Datum	pg_file_sync (PG_FUNCTION_ARGS)
Datum	pg_file_rename (PG_FUNCTION_ARGS)
Datum	pg_file_rename_v1_1 (PG_FUNCTION_ARGS)
Datum	pg_file_unlink (PG_FUNCTION_ARGS)
Datum	pg_file_unlink_v1_1 (PG_FUNCTION_ARGS)
Datum	pg_logdir_ls (PG_FUNCTION_ARGS)
Datum	pg_logdir_ls_v1_1 (PG_FUNCTION_ARGS)

Variables
	PG_MODULE_MAGIC

Function Documentation

convert_and_check_filename()

static char* convert_and_check_filename ( text *  arg )

static

Definition at line 71 of file adminpack.c.

{
    char       *filename = text_to_cstring(arg);
 
    canonicalize_path(filename);    /* filename can change length here */
 
    /*
     * Members of the 'pg_write_server_files' role are allowed to access any
     * files on the server as the PG user, so no need to do any further checks
     * here.
     */
    if (has_privs_of_role(GetUserId(), ROLE_PG_WRITE_SERVER_FILES))
        return filename;
 
    /*
     * User isn't a member of the pg_write_server_files role, so check if it's
     * allowable
     */
    if (is_absolute_path(filename))
    {
        /* Allow absolute paths if within DataDir */
        if (!path_is_prefix_of_path(DataDir, filename))
            ereport(ERROR,
                    (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                     errmsg("absolute path not allowed")));
    }
    else if (!path_is_relative_and_below_cwd(filename))
        ereport(ERROR,
                (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                 errmsg("path must be in or below the data directory")));
 
    return filename;
}

References arg, canonicalize_path(), DataDir, ereport, errcode(), errmsg(), ERROR, filename, GetUserId(), has_privs_of_role(), is_absolute_path, path_is_prefix_of_path(), path_is_relative_and_below_cwd(), and text_to_cstring().

Referenced by pg_file_rename_internal(), pg_file_sync(), pg_file_unlink(), pg_file_unlink_v1_1(), and pg_file_write_internal().

pg_file_rename()

Datum pg_file_rename

(

PG_FUNCTION_ARGS

)

Definition at line 239 of file adminpack.c.

{
    text       *file1;
    text       *file2;
    text       *file3;
    bool        result;
 
    requireSuperuser();
 
    if (PG_ARGISNULL(0) || PG_ARGISNULL(1))
        PG_RETURN_NULL();
 
    file1 = PG_GETARG_TEXT_PP(0);
    file2 = PG_GETARG_TEXT_PP(1);
 
    if (PG_ARGISNULL(2))
        file3 = NULL;
    else
        file3 = PG_GETARG_TEXT_PP(2);
 
    result = pg_file_rename_internal(file1, file2, file3);
 
    PG_RETURN_BOOL(result);
}

References PG_ARGISNULL, pg_file_rename_internal(), PG_GETARG_TEXT_PP, PG_RETURN_BOOL, PG_RETURN_NULL, and requireSuperuser().

pg_file_rename_internal()

static bool pg_file_rename_internal ( text *  file1, text *  file2, text *  file3  )

static

Definition at line 303 of file adminpack.c.

{
    char       *fn1,
               *fn2,
               *fn3;
    int         rc;
 
    fn1 = convert_and_check_filename(file1);
    fn2 = convert_and_check_filename(file2);
 
    if (file3 == NULL)
        fn3 = NULL;
    else
        fn3 = convert_and_check_filename(file3);
 
    if (access(fn1, W_OK) < 0)
    {
        ereport(WARNING,
                (errcode_for_file_access(),
                 errmsg("file \"%s\" is not accessible: %m", fn1)));
 
        return false;
    }
 
    if (fn3 && access(fn2, W_OK) < 0)
    {
        ereport(WARNING,
                (errcode_for_file_access(),
                 errmsg("file \"%s\" is not accessible: %m", fn2)));
 
        return false;
    }
 
    rc = access(fn3 ? fn3 : fn2, W_OK);
    if (rc >= 0 || errno != ENOENT)
    {
        ereport(ERROR,
                (errcode(ERRCODE_DUPLICATE_FILE),
                 errmsg("cannot rename to target file \"%s\"",
                        fn3 ? fn3 : fn2)));
    }
 
    if (fn3)
    {
        if (rename(fn2, fn3) != 0)
        {
            ereport(ERROR,
                    (errcode_for_file_access(),
                     errmsg("could not rename \"%s\" to \"%s\": %m",
                            fn2, fn3)));
        }
        if (rename(fn1, fn2) != 0)
        {
            ereport(WARNING,
                    (errcode_for_file_access(),
                     errmsg("could not rename \"%s\" to \"%s\": %m",
                            fn1, fn2)));
 
            if (rename(fn3, fn2) != 0)
            {
                ereport(ERROR,
                        (errcode_for_file_access(),
                         errmsg("could not rename \"%s\" back to \"%s\": %m",
                                fn3, fn2)));
            }
            else
            {
                ereport(ERROR,
                        (errcode(ERRCODE_UNDEFINED_FILE),
                         errmsg("renaming \"%s\" to \"%s\" was reverted",
                                fn2, fn3)));
            }
        }
    }
    else if (rename(fn1, fn2) != 0)
    {
        ereport(ERROR,
                (errcode_for_file_access(),
                 errmsg("could not rename \"%s\" to \"%s\": %m", fn1, fn2)));
    }
 
    return true;
}

References convert_and_check_filename(), ereport, errcode(), errcode_for_file_access(), errmsg(), ERROR, and WARNING.

Referenced by pg_file_rename(), and pg_file_rename_v1_1().

pg_file_rename_v1_1()

Datum pg_file_rename_v1_1

(

PG_FUNCTION_ARGS

)

Definition at line 274 of file adminpack.c.

{
    text       *file1;
    text       *file2;
    text       *file3;
    bool        result;
 
    if (PG_ARGISNULL(0) || PG_ARGISNULL(1))
        PG_RETURN_NULL();
 
    file1 = PG_GETARG_TEXT_PP(0);
    file2 = PG_GETARG_TEXT_PP(1);
 
    if (PG_ARGISNULL(2))
        file3 = NULL;
    else
        file3 = PG_GETARG_TEXT_PP(2);
 
    result = pg_file_rename_internal(file1, file2, file3);
 
    PG_RETURN_BOOL(result);
}

References PG_ARGISNULL, pg_file_rename_internal(), PG_GETARG_TEXT_PP, PG_RETURN_BOOL, and PG_RETURN_NULL.

pg_file_sync()

Datum pg_file_sync

(

PG_FUNCTION_ARGS

)

Definition at line 214 of file adminpack.c.

{
    char       *filename;
    struct stat fst;
 
    filename = convert_and_check_filename(PG_GETARG_TEXT_PP(0));
 
    if (stat(filename, &fst) < 0)
        ereport(ERROR,
                (errcode_for_file_access(),
                 errmsg("could not stat file \"%s\": %m", filename)));
 
    fsync_fname_ext(filename, S_ISDIR(fst.st_mode), false, ERROR);
 
    PG_RETURN_VOID();
}

References convert_and_check_filename(), ereport, errcode_for_file_access(), errmsg(), ERROR, filename, fsync_fname_ext(), PG_GETARG_TEXT_PP, PG_RETURN_VOID, S_ISDIR, stat::st_mode, and stat.

pg_file_unlink()

Datum pg_file_unlink

(

PG_FUNCTION_ARGS

)

Definition at line 396 of file adminpack.c.

{
    char       *filename;
 
    requireSuperuser();
 
    filename = convert_and_check_filename(PG_GETARG_TEXT_PP(0));
 
    if (access(filename, W_OK) < 0)
    {
        if (errno == ENOENT)
            PG_RETURN_BOOL(false);
        else
            ereport(ERROR,
                    (errcode_for_file_access(),
                     errmsg("file \"%s\" is not accessible: %m", filename)));
    }
 
    if (unlink(filename) < 0)
    {
        ereport(WARNING,
                (errcode_for_file_access(),
                 errmsg("could not unlink file \"%s\": %m", filename)));
 
        PG_RETURN_BOOL(false);
    }
    PG_RETURN_BOOL(true);
}

References convert_and_check_filename(), ereport, errcode_for_file_access(), errmsg(), ERROR, filename, PG_GETARG_TEXT_PP, PG_RETURN_BOOL, requireSuperuser(), and WARNING.

pg_file_unlink_v1_1()

Datum pg_file_unlink_v1_1

(

PG_FUNCTION_ARGS

)

Definition at line 436 of file adminpack.c.

{
    char       *filename;
 
    filename = convert_and_check_filename(PG_GETARG_TEXT_PP(0));
 
    if (access(filename, W_OK) < 0)
    {
        if (errno == ENOENT)
            PG_RETURN_BOOL(false);
        else
            ereport(ERROR,
                    (errcode_for_file_access(),
                     errmsg("file \"%s\" is not accessible: %m", filename)));
    }
 
    if (unlink(filename) < 0)
    {
        ereport(WARNING,
                (errcode_for_file_access(),
                 errmsg("could not unlink file \"%s\": %m", filename)));
 
        PG_RETURN_BOOL(false);
    }
    PG_RETURN_BOOL(true);
}

References convert_and_check_filename(), ereport, errcode_for_file_access(), errmsg(), ERROR, filename, PG_GETARG_TEXT_PP, PG_RETURN_BOOL, and WARNING.

pg_file_write()

Datum pg_file_write

(

PG_FUNCTION_ARGS

)

Definition at line 128 of file adminpack.c.

{
    text       *file = PG_GETARG_TEXT_PP(0);
    text       *data = PG_GETARG_TEXT_PP(1);
    bool        replace = PG_GETARG_BOOL(2);
    int64       count = 0;
 
    requireSuperuser();
 
    count = pg_file_write_internal(file, data, replace);
 
    PG_RETURN_INT64(count);
}

References data, pg_file_write_internal(), PG_GETARG_BOOL, PG_GETARG_TEXT_PP, PG_RETURN_INT64, and requireSuperuser().

pg_file_write_internal()

static int64 pg_file_write_internal ( text *  file, text *  data, bool  replace  )

static

Definition at line 170 of file adminpack.c.

{
    FILE       *f;
    char       *filename;
    int64       count = 0;
 
    filename = convert_and_check_filename(file);
 
    if (!replace)
    {
        struct stat fst;
 
        if (stat(filename, &fst) >= 0)
            ereport(ERROR,
                    (errcode(ERRCODE_DUPLICATE_FILE),
                     errmsg("file \"%s\" exists", filename)));
 
        f = AllocateFile(filename, "wb");
    }
    else
        f = AllocateFile(filename, "ab");
 
    if (!f)
        ereport(ERROR,
                (errcode_for_file_access(),
                 errmsg("could not open file \"%s\" for writing: %m",
                        filename)));
 
    count = fwrite(VARDATA_ANY(data), 1, VARSIZE_ANY_EXHDR(data), f);
    if (count != VARSIZE_ANY_EXHDR(data) || FreeFile(f))
        ereport(ERROR,
                (errcode_for_file_access(),
                 errmsg("could not write file \"%s\": %m", filename)));
 
    return (count);
}

References AllocateFile(), convert_and_check_filename(), data, ereport, errcode(), errcode_for_file_access(), errmsg(), ERROR, filename, FreeFile(), stat, VARDATA_ANY, and VARSIZE_ANY_EXHDR.

Referenced by pg_file_write(), and pg_file_write_v1_1().

pg_file_write_v1_1()

Datum pg_file_write_v1_1

(

PG_FUNCTION_ARGS

)

Definition at line 152 of file adminpack.c.

{
    text       *file = PG_GETARG_TEXT_PP(0);
    text       *data = PG_GETARG_TEXT_PP(1);
    bool        replace = PG_GETARG_BOOL(2);
    int64       count = 0;
 
    count = pg_file_write_internal(file, data, replace);
 
    PG_RETURN_INT64(count);
}

References data, pg_file_write_internal(), PG_GETARG_BOOL, PG_GETARG_TEXT_PP, and PG_RETURN_INT64.

PG_FUNCTION_INFO_V1() [1/9]

PG_FUNCTION_INFO_V1

(

pg_file_rename

)

PG_FUNCTION_INFO_V1() [2/9]

PG_FUNCTION_INFO_V1

(

pg_file_rename_v1_1

)

PG_FUNCTION_INFO_V1() [3/9]

PG_FUNCTION_INFO_V1

(

pg_file_sync

)

PG_FUNCTION_INFO_V1() [4/9]

PG_FUNCTION_INFO_V1

(

pg_file_unlink

)

PG_FUNCTION_INFO_V1() [5/9]

PG_FUNCTION_INFO_V1

(

pg_file_unlink_v1_1

)

PG_FUNCTION_INFO_V1() [6/9]

PG_FUNCTION_INFO_V1

(

pg_file_write

)

PG_FUNCTION_INFO_V1() [7/9]

PG_FUNCTION_INFO_V1

(

pg_file_write_v1_1

)

PG_FUNCTION_INFO_V1() [8/9]

PG_FUNCTION_INFO_V1

(

pg_logdir_ls

)

PG_FUNCTION_INFO_V1() [9/9]

PG_FUNCTION_INFO_V1

(

pg_logdir_ls_v1_1

)

pg_logdir_ls()

Datum pg_logdir_ls

(

PG_FUNCTION_ARGS

)

Definition at line 471 of file adminpack.c.

{
    if (!superuser())
        ereport(ERROR,
                (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                 errmsg("only superuser can list the log directory")));
 
    return (pg_logdir_ls_internal(fcinfo));
}

References ereport, errcode(), errmsg(), ERROR, pg_logdir_ls_internal(), and superuser().

pg_logdir_ls_internal()

static Datum pg_logdir_ls_internal ( FunctionCallInfo  fcinfo )

static

Definition at line 497 of file adminpack.c.

{
    ReturnSetInfo *rsinfo = (ReturnSetInfo *) fcinfo->resultinfo;
    bool        randomAccess;
    TupleDesc   tupdesc;
    Tuplestorestate *tupstore;
    AttInMetadata *attinmeta;
    DIR        *dirdesc;
    struct dirent *de;
    MemoryContext oldcontext;
 
    if (strcmp(Log_filename, "postgresql-%Y-%m-%d_%H%M%S.log") != 0)
        ereport(ERROR,
                (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
                 errmsg("the log_filename parameter must equal 'postgresql-%%Y-%%m-%%d_%%H%%M%%S.log'")));
 
    /* check to see if caller supports us returning a tuplestore */
    if (rsinfo == NULL || !IsA(rsinfo, ReturnSetInfo))
        ereport(ERROR,
                (errcode(ERRCODE_FEATURE_NOT_SUPPORTED),
                 errmsg("set-valued function called in context that cannot accept a set")));
    if (!(rsinfo->allowedModes & SFRM_Materialize))
        ereport(ERROR,
                (errcode(ERRCODE_SYNTAX_ERROR),
                 errmsg("materialize mode required, but it is not allowed in this context")));
 
    /* The tupdesc and tuplestore must be created in ecxt_per_query_memory */
    oldcontext = MemoryContextSwitchTo(rsinfo->econtext->ecxt_per_query_memory);
 
    tupdesc = CreateTemplateTupleDesc(2);
    TupleDescInitEntry(tupdesc, (AttrNumber) 1, "starttime",
                       TIMESTAMPOID, -1, 0);
    TupleDescInitEntry(tupdesc, (AttrNumber) 2, "filename",
                       TEXTOID, -1, 0);
 
    randomAccess = (rsinfo->allowedModes & SFRM_Materialize_Random) != 0;
    tupstore = tuplestore_begin_heap(randomAccess, false, work_mem);
    rsinfo->returnMode = SFRM_Materialize;
    rsinfo->setResult = tupstore;
    rsinfo->setDesc = tupdesc;
 
    MemoryContextSwitchTo(oldcontext);
 
    attinmeta = TupleDescGetAttInMetadata(tupdesc);
 
    dirdesc = AllocateDir(Log_directory);
    while ((de = ReadDir(dirdesc, Log_directory)) != NULL)
    {
        char       *values[2];
        HeapTuple   tuple;
        char        timestampbuf[32];
        char       *field[MAXDATEFIELDS];
        char        lowstr[MAXDATELEN + 1];
        int         dtype;
        int         nf,
                    ftype[MAXDATEFIELDS];
        fsec_t      fsec;
        int         tz = 0;
        struct pg_tm date;
        DateTimeErrorExtra extra;
 
        /*
         * Default format: postgresql-YYYY-MM-DD_HHMMSS.log
         */
        if (strlen(de->d_name) != 32
            || strncmp(de->d_name, "postgresql-", 11) != 0
            || de->d_name[21] != '_'
            || strcmp(de->d_name + 28, ".log") != 0)
            continue;
 
        /* extract timestamp portion of filename */
        strcpy(timestampbuf, de->d_name + 11);
        timestampbuf[17] = '\0';
 
        /* parse and decode expected timestamp to verify it's OK format */
        if (ParseDateTime(timestampbuf, lowstr, MAXDATELEN, field, ftype, MAXDATEFIELDS, &nf))
            continue;
 
        if (DecodeDateTime(field, ftype, nf,
                           &dtype, &date, &fsec, &tz, &extra))
            continue;
 
        /* Seems the timestamp is OK; prepare and return tuple */
 
        values[0] = timestampbuf;
        values[1] = psprintf("%s/%s", Log_directory, de->d_name);
 
        tuple = BuildTupleFromCStrings(attinmeta, values);
 
        tuplestore_puttuple(tupstore, tuple);
    }
 
    FreeDir(dirdesc);
    return (Datum) 0;
}

References AllocateDir(), ReturnSetInfo::allowedModes, BuildTupleFromCStrings(), CreateTemplateTupleDesc(), DecodeDateTime(), ReturnSetInfo::econtext, ExprContext::ecxt_per_query_memory, ereport, errcode(), errmsg(), ERROR, FreeDir(), if(), IsA, Log_directory, Log_filename, MAXDATEFIELDS, MAXDATELEN, MemoryContextSwitchTo(), ParseDateTime(), psprintf(), ReadDir(), FunctionCallInfoBaseData::resultinfo, ReturnSetInfo::returnMode, ReturnSetInfo::setDesc, ReturnSetInfo::setResult, SFRM_Materialize, SFRM_Materialize_Random, TupleDescGetAttInMetadata(), TupleDescInitEntry(), tuplestore_begin_heap(), tuplestore_puttuple(), values, and work_mem.

Referenced by pg_logdir_ls(), and pg_logdir_ls_v1_1().

pg_logdir_ls_v1_1()

Datum pg_logdir_ls_v1_1

(

PG_FUNCTION_ARGS

)

Definition at line 491 of file adminpack.c.

{
    return (pg_logdir_ls_internal(fcinfo));
}

References pg_logdir_ls_internal().

requireSuperuser()

static void requireSuperuser ( void  )

static

Definition at line 110 of file adminpack.c.

{
    if (!superuser())
        ereport(ERROR,
                (errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
                 errmsg("only superuser may access generic file functions")));
}

References ereport, errcode(), errmsg(), ERROR, and superuser().

Referenced by pg_file_rename(), pg_file_unlink(), and pg_file_write().

Variable Documentation

PG_MODULE_MAGIC

PG_MODULE_MAGIC

Definition at line 43 of file adminpack.c.