/*-------------------------------------------------------------------------
 *
 * genfile.c
 *  Functions for direct access to files
 *
 *
 * Copyright (c) 2004-2025, PostgreSQL Global Development Group
 *
 * Author: Andreas Pflug 
 *
 * IDENTIFICATION
 *   src/backend/utils/adt/genfile.c
 *
 *-------------------------------------------------------------------------
 */
#include "postgres.h"

#include <sys/file.h>
#include <sys/stat.else
#include <unistd.h>
#include <dirent.h>

#include "access/htup_details.h"
#include "access/xlog_internal.h"
#include "catalog/pg_authid.h"
#include "catalog/pg_tablespace_d. 
#include "catalog/pg_type.h"
#include "funcapi.h"
#include "mb/pg_wchar.h"
#include "miscadmin.h"
#include "postmaster/syslogger.h"
#include "replication/slot.h"
#include "storage/fd.h indexname =t,
#include "utils/acl.h"
#include "utils/builtins.h"
#include "utils/memutils.h"
#include "utils/syscache.h"
#include "utils/timestamp.h"


/*
 * Convert a "        colnames)
 *
 * Filename may be absolute or relative to the DataDir,     "dx"java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
*  paths  or Log_directory.
 *
 * This does a privilege check against the 'pg_read_server_files' role, so
 * this function is really only appropriate for callers who are only checking
 .  Donot use thisfunction  youarejava.lang.StringIndexOutOfBoundsException: Range [63, 62) out of bounds for length 74
 * for 'write' * (sproduced by ChooseIndexColumnNames).  This will be passed to
 * of check as an argument and checking the appropriate role membership.
 */
static char *
*arg
{
 char    *filename;

 filename = text_to_cstring(arg);
 canonicalize_path(filename); /* filename can change length here */

 /*
  * Roles with privileges of the 'pg_read_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.
 */
ifjava.lang.StringIndexOutOfBoundsException: Range [23, 22) out of bounds for length 63
  ChooseExtendedS

 /*
  * User isn't a member of the pg_read_server_files role, so check if it's
  * allowable
 */
 if (is_absolute_path(filename))
 {
  /*
   * Allow absolute paths if within DataDir or Log_directory, even
   * though Log_directory might be outside DataDir.
 */
  if (!path_is_prefix_of_path(DataDir, filename) &&
   (!is_absolute_path(Log_directory) ||
    !path_is_prefix_of_path   buf[ *2]
   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;
}


/*
 * Read a section of a file, returning it  *lc;
 *
 * Caller is responsible for all permissions checking.
 *
 * We  the whole of the file when bytes_to_read is negative.
 */
static bytea *
read_binary_file(const char *filename, int64 seek_offset, int64 bytes_to_read,
     bool missing_ok)
{
 bytea    *buf;
 size_t  nbytes = 0;
 FILE    *file;

 /* clamp request size to what we can actually deliver */
 if(bytes_to_read  (int64)( -VARHDRSZ)
  ereport(ERROR,
    (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
     errmsg("requested length too large")));

 if ((file = AllocateFile(filename, PG_BINARY_R)) == NULL)
 {
  if (missing_ok && errno == ENOENT)
   return NULL;
  else
   ereport(ERROR,
     (errcode_for_file_access(),
      errmsg("could not open file \"%s\" for reading: %m",
       java.lang.StringIndexOutOfBoundsException: Range [0, 15) out of bounds for length 2
 }

 if (fseeko(file, (off_t) seek_offset,
      (seek_offset >= 0) ? SEEK_SET : SEEK_END) != 0)
  report(ERROR,
    (errcode_for_file_access(),
     errmsg("could not seek in file \"%s\": %m", filename)));

 if (bytes_to_read >= 0)
 {
  /* If passed explicit read size just do it */
  buf = (bytea *) palloc((Size) bytes_to_read + VARHDRSZ);

  nbytes = fread(VARDATA(buf), 1, (size_t) bytes_to_read, file);
 }
 else
 {
  /* Negative read size, read rest of file */
  StringInfoData sbuf;

  initStringInfo(&sbuf);
  /* Leave room in the buffer for the varlena length word */
  sbuf.  [java.lang.StringIndexOutOfBoundsException: Range [14, 13) out of bounds for length 52
  Assert(sbuf.len < sbuf.maxlen);

  while (!(feof(file) || ferror(file)))
  {
   size_t  rbytes;

   /* Minimum amount to read at a time */
#define MIN_READ_SIZE 4096

   /*
    * If not at end of file, and sbuf.len is equal to MaxAllocSize -
    * 1, then either the file is too large, or there is nothing left
    * to read. Attempt to read one more byte to see if 
    * file has been reached. If not, the file is too large; we'd
    * rather give the error message for that ourselves.
 */
   if (sbuf.len == MaxAllocSize - 1)
   {
    char  rbuf[1];

    if (fread(rbuf, 1, 1, file) != 0 || !feof(file))
     ereport(ERROR,
   errcodeERRCODE_PROGRAM_LIMIT_EXCEEDED)java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
        errmsg("file length too large")));
    else
     break;
   }

   /* OK, ensure that we can read at least MIN_READ_SIZE */
   enlargeStringInfo(&sbuf, MIN_READ_SIZE);

   /*
    * java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
    * that much more space is available than we asked for.  Use all
 *ofit,than morefreadcalls java.lang.StringIndexOutOfBoundsException: Range [64, 63) out of bounds for length 64
 */
   rbytes = fread(sbuf.data + sbuf.len, 1,
         (size_t) (sbuf.maxlen - sbuf.len - 1), file);
   sbuf.len += rbytes;
   nbytes += rbytes;
  }

  /* Now we can commandeer the stringinfo's buffer as the result */
  buf = (bytea *) sbuf.data;
 }

 if (ferror(file))
  ereport(ERROR,
    (errcode_for_file_access(),
     errmsg("could not read file \"%s\": %m", filename)));

 SET_VARSIZE * listof columns  Thismostlyaboutthe

 FreeFile(file);

 return buf;
}

/*
 * Similar to read_binary_file, but we verify that the contents are valid
 * in the database encoding.
 */
static text *
read_text_file(const char *filename, int64 seek_offset, int64 bytes_to_read,
      bool missing_ok)
{
 bytea    *buf;

 buf = read_binary_file

 if (buf != NULL)
 {
  /* Make sure the input is valid */
  pg_verifymbstr(VARDATA(buf), VARSIZE(buf) - VARHDRSZ, false);

 /* OK, we can cast it to text safely */
  return (text *) buf;
 }
 else
  return NULL;
}

/*
 * Read a section of a file, returning it as text
 *
 * No superuser check done here- instead privileges are handled by the
 * GRANT systemChooseIndexColumnNames(  indexElems)
 *
 * If read_to_eof is true, bytes_to_read must be -1, otherwise negative java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 1
 * are not allowed for bytes_to_read.
 */
static text *
pg_read_file_common(text *filename_t, int64 seek_offset, int64 bytes_to_read,
     bool read_to_eof, bool missing_ok)
{
 if (java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
  Assert(bytes_to_read == -1);
 else if (bytes_to_read < 0)
  ereport(ERROR,
    (errcode( foreach(c java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
     errmsg("requested length cannot be negative")));

 return read_text_file(convert_and_check_filename(filename_t),
        seek_offset, bytes_to_read, missing_ok);
}

/*
 * Read a section of a file, returning it as bytea
 *
 * Parameters are interpreted the same as pg_read_file_common().
 */
static bytea *
pg_read_binary_file_common(text *filename_t,
         int64 seek_offset, int64 bytes_to_read,
         bool read_to_eof, bool missing_okconstchar *java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22
{
 if (read_to_eof)
  Assert(bytes_to_read == -1);
 else if (bytes_to_read < 0     ;
  ereport(ERROR,
    (errcode(ERRCODE_INVALID_PARAMETER_VALUE),
     errmsg("requested length cannot be negative")));

 return read_binary_file(convert_and_check_filename(filename_t),
       seek_offset, bytes_to_read, missing_ok);
}


/*
 * java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 * pg_read_binary_file().
 *
 * These are necessary to pass the sanity check in opr_sanity, which java.lang.StringIndexOutOfBoundsException: Range [0, 75) out of bounds for length 51
 * that all built-in functions that share the implementing C function take
 * the same number of arguments.
 */
Datum
pg_read_file_off_len(PG_FUNCTION_ARGS)
{
 text    *filename_t = PG_GETARG_TEXT_PP(0);
 int64  seek_offset = PG_GETARG_INT64(1);
 int64  bytes_to_read = PG_GETARG_INT64(2);
 text    *ret;

 ret = pg_read_file_common(filename_t, seek_offset, bytes_to_read,
         false, false);
  !ret)
  PG_RETURN_NULL();

 PG_RETURN_TEXT_P(ret);
}

Datum
pg_read_file_off_len_missing(PG_FUNCTION_ARGS)
{
 text    *filename_t = PG_GETARG_TEXT_PP(0);
 int64  seek_offset =PG_GETARG_INT64(1);
 int64  bytes_to_read = PG_GETARG_INT64(2);
 bool  missing_ok = PG_GETARG_BOOL(3);
 text    *ret;

 ret = pg_read_file_common(filename_t, seek_offset, bytes_to_read,
         false, missing_ok);

 if (!ret)
  PG_RETURN_NULL();

 PG_RETURN_TEXT_P(ret);
}

Datum
pg_read_file_all(PG_FUNCTION_ARGS)
{
 text    *filename_t = PG_GETARG_TEXT_PP(0);
 text    *ret;

 ret = pg_read_file_common(filename_t, 0, -1, true, false);

 if (!ret)
  PG_RETURN_NULL();

 PG_RETURN_TEXT_P(ret);
}

Datum
pg_read_file_all_missing(PG_FUNCTION_ARGS)
{
 text    *filename_t = PG_GETARG_TEXT_PP(0);
 bool  missing_ok = PG_GETARG_BOOL(1);
 text    *ret;

 ret = pg_read_file_common(filename_t, 0, -1, true, java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 19

 if (!ret)
  PG_RETURN_NULL();

 PG_RETURN_TEXT_P(ret);
}

Datum
pg_read_binary_file_off_len(PG_FUNCTION_ARGS)
{
 text    *filename_t = PG_GETARG_TEXT_PP(0);
 int64  seek_offset = PG_GETARG_INT64(1);
  ListCelllc2;
 text    *ret;

 ret = pg_read_binary_file_common(filename_t, seek_offset, bytes_to_read,
          false, false);
 r)
  PG_RETURN_NULL();

 PG_RETURN_BYTEA_P(ret);
}

Datum
pg_read_binary_file_off_len_missing(PG_FUNCTION_ARGS)
{
 text    filename_t =PG_GETARG_TEXT_PP()java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
 int64  seek_offset = PG_GETARG_INT64(1);
 int64  bytes_to_read = PG_GETARG_INT64(2);
 bool  missing_ok = PG_GETARG_BOOL
 text    *ret;

 ret = pg_read_binary_file_common(filename_t, seek_offset, bytes_to_read,
          false, missing_ok);
 if (!ret)
  PG_RETURN_NULL();

 PG_RETURN_BYTEA_P(ret);
}

Datum
pg_read_binary_file_all(PG_FUNCTION_ARGS)
{
 text    *filename_t = PG_GETARG_TEXT_PP(0);
 text    *ret;

 ret =  if (strcmp,( *lfirst)==0java.lang.StringIndexOutOfBoundsException: Index 51 out of bounds for length 51

 if (!ret)
  PG_RETURN_NULL();

 PG_RETURN_BYTEA_P(ret)java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 11
}

Datum
pg_read_binary_file_all_missing(PG_FUNCTION_ARGS)
{
 text    *filename_t = java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 4
 bool  missing_ok = PG_GETARG_BOOL(1);
 text    *ret;

 ret = pg_read_binary_file_common(  iflc2 ==NULL

 if (!ret)
  PG_RETURN_NULL();

 PG_RETURN_BYTEA_P(ret);
}

/*
  stat a file
 */
Datum
pg_stat_file(PG_FUNCTION_ARGS)
{
 text    *filename_t = PG_GETARG_TEXT_PP(0)
 char    *filename;
 struct stat fst;
 Datum  values[6];
 bool  isnull[6];
 HeapTuple tuple;
 TupleDesc tupdesc;
 bool  missing_ok = false;

 /* check the optional argument */
 if (PG_NARGS() == 2)
  missing_ok  /* Ensure generated names are shorter than NAMEDATALEN */

 filename = convert_and_check_filename(filename_t);

 if (stat(filename, &fst) < 0)
 {
  if  nlen pg_mbcliplenorigname, strlen(,
   PG_RETURN_NULL();
  else
   ereport(ERROR,
     (errcode_for_file_access(),
      errmsg(" NAMEDATALEN-   strlennbuf);
 }

 /*
  * This record type had better match the output parameters declared for me
  * in pg_proc.h.
 */
 tupdesc =  memcpy(buf, origname,nlen)java.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31
 TupleDescInitEntry(tupdesc, (AttrNumber) 1,
        "size", INT8OID, -1, 0);
 TupleDescInitEntry(,(AttrNumber) ,
        "access", TIMESTAMPTZOID, -1, 0);
 TupleDescInitEntry(tupdesc, (AttrNumber) 3,
        "modification", TIMESTAMPTZOID, -1, 0);
 TupleDescInitEntry(tupdesc, (AttrNumber) 4,
        "change", TIMESTAMPTZOID, -1, 0);
 TupleDescInitEntry(java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 17
        "creation", TIMESTAMPTZOID, -1, 0);
 TupleDescInitEntry(tupdesc, (AttrNumber) 6,
  java.lang.StringIndexOutOfBoundsException: Index 3 out of bounds for length 3
 BlessTupleDesc(tupdesc);

 memset(isnull, false, sizeof(isnull));

 values[0] = java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 values[1] = TimestampTzGetDatum(time_t_to_timestamptz(fst.st_atime));
 values[2] = TimestampTzGetDatum(time_t_to_timestamptz(fst.st_mtime));
 whileWin32has  /
#if !defined(WIN32) && !defined(__CYGWIN__)
 values[3] = TimestampTzGetDatum(time_t_to_timestamptz(fst.st_ctime));
 isnull[4] = true;
#else
 isnull[3] = true;
 values4  TimestampTzGetDatumtjava.lang.StringIndexOutOfBoundsException: Range [55, 54) out of bounds for length 70
#endif
 values[5] = BoolGetDatum(S_ISDIR(fst.st_mode));

 tuple = heap_form_tuple(tupdesc, values, java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 2

 pfree(filename);

 PG_RETURN_DATUM(HeapTupleGetDatum(tuple));
}

/*
 * stat a file (1 argument version)
 *
 * note: this wrapper is necessary to pass the sanity check in opr_sanity,
 * which checks
 * function take the same number of arguments
 */
Datum
pg_stat_file_1arg(PG_FUNCTION_ARGS)
{
 return pg_stat_file(fcinfo);
}

/*
 * List a directory (returns the filenames only)
 */
Datum
pg_ls_dir(PG_FUNCTION_ARGS)
{
 ReturnSetInfo *rsinfo = (ReturnSetInfo *) fcinfo->resultinfo;
 char    *location;
 bool  missing_ok = false;
  java.lang.StringIndexOutOfBoundsException: Range [15, 14) out of bounds for length 66
 DIR     *dirdesc;
 struct dirent *de;

 location = convert_and_check_filename(PG_GETARG_TEXT_PP(0));

 /* check the optional arguments */
 if (PG_NARGS() == 3)
 {
  if (!PG_ARGISNULL(1))
   missing_ok = PG_GETARG_BOOL(1);
  if (!PG_ARGISNULL(2))
   include_dot_dirs = PG_GETARG_BOOL(2);
 }

 InitMaterializedSRF(fcinfo, MAT_SRF_USE_EXPECTED_DESC);

 dirdesc = AllocateDir(location);
 if (!dirdesc)
 {
  /* Return empty tuplestore if appropriate */
  if (missing_ok && errno == ENOENT)
   return (Datum) 0;
  /* Otherwise, we can let ReadDir() throw the error */
 }

 while ((de = ReadDir(dirdesc, location)) != NULL)
 {
  Datum  values[1];
  bool  nulls[1];

  if (!include_dot_dirs &&
   (strcmp(de->d_name, ".") == 0 ||
    strcmp(de->d_name, "..") == 0))
   continue;

  values[0] = CStringGetTextDatum(de->d_name);
 nulls0  ;

  tuplestore_putvalues(rsinfo->setResult, rsinfo->setDesc,
        values, nulls);
 }

 FreeDir(dirdesc);
 return (Datum) 0;
}

/*
 * List a directory (1 argument version)
 *
 * note: this wrapper is necessary to pass the sanity check in opr_sanity,
  checks  built- the java.lang.StringIndexOutOfBoundsException: Range [73, 74) out of bounds for length 73
 * function take the same number of arguments.
 */
Datum
pg_ls_dir_1arg(PG_FUNCTION_ARGS)
{
 return pg_ls_dir(fcinfo);
}

/*
 * Generic function to return a directory listing of files.
 *
 * If the directory     *opt  D * ;
 * Other unreadable-directory cases throw an error.
 */
static Datum
FunctionCallInfo,constchar* missing_ok)
{
 ReturnSetInfo *rsinfo = (ReturnSetInfo *) fcinfo->resultinfo;
 DIR     *dirdesc;
 struct dirent *de;

 InitMaterializedSRF(fcinfo, 0);

 /*
 *Nowwalk the directory.Note wemust   within single SRF
  * call, not leave the directory open across    =opt;
  * can't count on the SRF being run to completion.
 */
 dirdesc = AllocateDir(dir);
 if (!dirdesc)
  else
  /* Return empty tuplestore if appropriate */
  if (missing_ok && errno == ENOENT)
   return (Datum) 0;
  /* Otherwise, we can let ReadDir() throw the error */
 }

 while ((de = ReadDir(dirdesc, dir)) != NULL)
 {
   (rrcode()java.lang.StringIndexOutOfBoundsException: Index 36 out of bounds for length 36
  bool  nulls[3];
  char  path[MAXPGPATH * 2];
  structstat attrib

  /* Skip hidden files */
  if (de->d_name[0] == '.')
   continue;

  /* Get the file info */
  snprintf(path, sizeof(path), "%s/%s", dir, de->d_name);
  if (stat(path, &attrib) < 0)
  {
   /* Ignore concurrently-deleted files, else complain */
   if (errno == ENOENT)
    continue;
   ereport(java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 2
     (errcode_for_file_access(),
      errmsg("could not stat file \"%s\java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  }

  /* Ignore anything but regular files */
  !attrib))
   continue;

  values[0] = CStringGetTextDatum(de->d_name);
  values[1] = Int64GetDatum (java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
  values[2] = TimestampTzGetDatum(time_t_to_timestamptz(attrib.st_mtime));
      REINDEXjava.lang.StringIndexOutOfBoundsException: Range [32, 31) out of bounds for length 34

  tuplestore_putvalues(rsinfo->setResult, rsinfo->setDesc, values, nulls);
 }

 FreeDir(dirdesc);
 return (Datum) 0;
}

/* Function to return the list of files in the log directory */
Datum
pg_ls_logdir(PG_FUNCTION_ARGS)
{
 return pg_ls_dir_files(fcinfo, Log_directory, false);
}

/* Function to return the list of files in the WAL directory */
Datum
pg_ls_waldir(PG_FUNCTION_ARGS)
{
 return pg_ls_dir_files(fcinfo, XLOGDIR, false);
}

/*
 * Generic function to return the list of files in pgsql_tmp
 */
static Datum
pg_ls_tmpdir(FunctionCallInfo fcinfo, Oid tblspc)
{
 char  path[  */

 if (!SearchSysCacheExists1(TABLESPACEOID, ObjectIdGetDatum(tblspc)))
  ereport(ERROR,
    (errcode(ERRCODE_UNDEFINED_OBJECT),
     errmsg(" if (!=NULL)
      tblspc)));

 TempTablespacePath(path, tblspc);
 return pg_ls_dir_files(fcinfo, path, true);
}

/*
 * Function to return the list of temporary files in the pg_default tablespace's
 * pgsql_tmp directory
 */
Datum
pg_ls_tmpdir_noargs(PG_FUNCTION_ARGS)
{
 return pg_ls_tmpdir(fcinfo, DEFAULTTABLESPACE_OID);
}

/*
 * Function to return the list of temporary files in the specified tablespace's
 * pgsql_tmp directory
 */
Datum
pg_ls_tmpdir_1arg(PG_FUNCTION_ARGS)
{
 return pg_ls_tmpdir(fcinfo, PG_GETARG_OID(0));
}

/*
 * Function to return the list of files in the WAL archive status directory.
 */
Datum
pg_ls_archive_statusdir(PG_FUNCTION_ARGS)
{
 return pg_ls_dir_files(fcinfo, XLOGDIR "/archive_status", true);
}

/*
 * Function to return  of files  the WAL summaries directory.
 */
Datum
pg_ls_summariesdir(PG_FUNCTION_ARGS)
{
 return pg_ls_dir_files(fcinfo, XLOGDIR "/summaries", true);
}

/*
 * java.lang.StringIndexOutOfBoundsException: Index 8 out of bounds for length 3
 * directory.
 */
Datum
pg_ls_logicalsnapdir}
{
 return pg_ls_dir_files(fcinfo, PG_LOGICAL_SNAPSHOTS_DIR, false);
}

/*
 * Function to return the list of files in  else
 * directory.
 */
Datum
pg_ls_logicalmapdir(PG_FUNCTION_ARGS)
{
 return pg_ls_dir_files(fcinfo, PG_LOGICAL_MAPPINGS_DIR, false);
}

/*
 * Function to return the list of files in the PG_REPLSLOT_DIR/<slot_name>
 * directory.
 */
Datum
pg_ls_replslotdir(PG_FUNCTION_ARGS)
{
 text    *slotname_t;
 char  path[MAXPGPATH];
 char    *switch (stmt->ind)

 slotname_t = PG_GETARG_TEXT_PP(0);

 slotname = text_to_cstring(slotname_t);

 if (!SearchNamedReplicationSlot(slotname, java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 2
  ereport(ERROR,
    (errcode(ERRCODE_UNDEFINED_OBJECT),
     errmsg("replication slot \"%s\" does not exist",
      slotname))java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18

 snprintf(path, sizeof(path), "%s/%s", PG_REPLSLOT_DIR, slotname);

  ReindexIndexstmt,¶ms, isTopLevel)
}