compress_none.c File Reference

#include "postgres_fe.h"
#include <unistd.h>
#include "compress_none.h"
#include "pg_backup_utils.h"

Include dependency graph for compress_none.c:

Go to the source code of this file.

Functions
static void	ReadDataFromArchiveNone (ArchiveHandle *AH, CompressorState *cs)
static void	WriteDataToArchiveNone (ArchiveHandle *AH, CompressorState *cs, const void *data, size_t dLen)
static void	EndCompressorNone (ArchiveHandle *AH, CompressorState *cs)
void	InitCompressorNone (CompressorState *cs, const pg_compress_specification compression_spec)
static bool	read_none (void *ptr, size_t size, size_t *rsize, CompressFileHandle *CFH)
static bool	write_none (const void *ptr, size_t size, CompressFileHandle *CFH)
static const char *	get_error_none (CompressFileHandle *CFH)
static char *	gets_none (char *ptr, int size, CompressFileHandle *CFH)
static int	getc_none (CompressFileHandle *CFH)
static bool	close_none (CompressFileHandle *CFH)
static bool	eof_none (CompressFileHandle *CFH)
static bool	open_none (const char *path, int fd, const char *mode, CompressFileHandle *CFH)
static bool	open_write_none (const char *path, const char *mode, CompressFileHandle *CFH)
void	InitCompressFileHandleNone (CompressFileHandle *CFH, const pg_compress_specification compression_spec)

Function Documentation

close_none()

static bool close_none ( CompressFileHandle *  CFH )

static

Definition at line 148 of file compress_none.c.

{
    FILE       *fp = (FILE *) CFH->private_data;
    int         ret = 0;
 
    CFH->private_data = NULL;
 
    if (fp)
        ret = fclose(fp);
 
    return ret == 0;
}

References if(), and CompressFileHandle::private_data.

Referenced by InitCompressFileHandleNone().

EndCompressorNone()

static void EndCompressorNone ( ArchiveHandle *  AH, CompressorState *  cs  )

static

Definition at line 56 of file compress_none.c.

{
    /* no op */
}

Referenced by InitCompressorNone().

eof_none()

static bool eof_none ( CompressFileHandle *  CFH )

static

Definition at line 162 of file compress_none.c.

{
    return feof((FILE *) CFH->private_data) != 0;
}

References CompressFileHandle::private_data.

Referenced by InitCompressFileHandleNone().

get_error_none()

static const char* get_error_none ( CompressFileHandle *  CFH )

static

Definition at line 118 of file compress_none.c.

{
    return strerror(errno);
}

References strerror.

Referenced by InitCompressFileHandleNone().

getc_none()

static int getc_none ( CompressFileHandle *  CFH )

static

Definition at line 130 of file compress_none.c.

{
    FILE       *fp = (FILE *) CFH->private_data;
    int         ret;
 
    ret = fgetc(fp);
    if (ret == EOF)
    {
        if (!feof(fp))
            pg_fatal("could not read from input file: %m");
        else
            pg_fatal("could not read from input file: end of file");
    }
 
    return ret;
}

References pg_fatal, and CompressFileHandle::private_data.

Referenced by InitCompressFileHandleNone().

gets_none()

static char* gets_none ( char *  ptr, int  size, CompressFileHandle *  CFH  )

static

Definition at line 124 of file compress_none.c.

{
    return fgets(ptr, size, (FILE *) CFH->private_data);
}

References CompressFileHandle::private_data, and size.

Referenced by InitCompressFileHandleNone().

InitCompressFileHandleNone()

void InitCompressFileHandleNone	(	CompressFileHandle *	CFH,
		const pg_compress_specification	compression_spec
	)

Definition at line 200 of file compress_none.c.

{
    CFH->open_func = open_none;
    CFH->open_write_func = open_write_none;
    CFH->read_func = read_none;
    CFH->write_func = write_none;
    CFH->gets_func = gets_none;
    CFH->getc_func = getc_none;
    CFH->close_func = close_none;
    CFH->eof_func = eof_none;
    CFH->get_error_func = get_error_none;
 
    CFH->private_data = NULL;
}

References CompressFileHandle::close_func, close_none(), CompressFileHandle::eof_func, eof_none(), CompressFileHandle::get_error_func, get_error_none(), CompressFileHandle::getc_func, getc_none(), CompressFileHandle::gets_func, gets_none(), CompressFileHandle::open_func, open_none(), CompressFileHandle::open_write_func, open_write_none(), CompressFileHandle::private_data, CompressFileHandle::read_func, read_none(), CompressFileHandle::write_func, and write_none().

Referenced by InitCompressFileHandle().

InitCompressorNone()

void InitCompressorNone	(	CompressorState *	cs,
		const pg_compress_specification	compression_spec
	)

Definition at line 66 of file compress_none.c.

{
    cs->readData = ReadDataFromArchiveNone;
    cs->writeData = WriteDataToArchiveNone;
    cs->end = EndCompressorNone;
 
    cs->compression_spec = compression_spec;
}

References CompressorState::compression_spec, CompressorState::end, EndCompressorNone(), CompressorState::readData, ReadDataFromArchiveNone(), CompressorState::writeData, and WriteDataToArchiveNone().

Referenced by AllocateCompressor().

open_none()

static bool open_none ( const char *  path, int  fd, const char *  mode, CompressFileHandle *  CFH  )

static

Definition at line 168 of file compress_none.c.

{
    Assert(CFH->private_data == NULL);
 
    if (fd >= 0)
        CFH->private_data = fdopen(dup(fd), mode);
    else
        CFH->private_data = fopen(path, mode);
 
    if (CFH->private_data == NULL)
        return false;
 
    return true;
}

References Assert, fd(), mode, and CompressFileHandle::private_data.

Referenced by InitCompressFileHandleNone().

open_write_none()

static bool open_write_none ( const char *  path, const char *  mode, CompressFileHandle *  CFH  )

static

Definition at line 184 of file compress_none.c.

{
    Assert(CFH->private_data == NULL);
 
    CFH->private_data = fopen(path, mode);
    if (CFH->private_data == NULL)
        return false;
 
    return true;
}

References Assert, mode, and CompressFileHandle::private_data.

Referenced by InitCompressFileHandleNone().

read_none()

static bool read_none ( void *  ptr, size_t  size, size_t *  rsize, CompressFileHandle *  CFH  )

static

Definition at line 87 of file compress_none.c.

{
    FILE       *fp = (FILE *) CFH->private_data;
    size_t      ret;
 
    if (size == 0)
        return true;
 
    ret = fread(ptr, 1, size, fp);
    if (ret != size && !feof(fp))
        pg_fatal("could not read from input file: %m");
 
    if (rsize)
        *rsize = ret;
 
    return true;
}

References if(), pg_fatal, CompressFileHandle::private_data, and size.

Referenced by InitCompressFileHandleNone().

ReadDataFromArchiveNone()

static void ReadDataFromArchiveNone ( ArchiveHandle *  AH, CompressorState *  cs  )

static

Definition at line 30 of file compress_none.c.

{
    size_t      cnt;
    char       *buf;
    size_t      buflen;
 
    buflen = DEFAULT_IO_BUFFER_SIZE;
    buf = pg_malloc(buflen);
 
    while ((cnt = cs->readF(AH, &buf, &buflen)))
    {
        ahwrite(buf, 1, cnt, AH);
    }
 
    free(buf);
}

References ahwrite(), buf, DEFAULT_IO_BUFFER_SIZE, free, pg_malloc(), and CompressorState::readF.

Referenced by InitCompressorNone().

write_none()

static bool write_none ( const void *  ptr, size_t  size, CompressFileHandle *  CFH  )

static

Definition at line 106 of file compress_none.c.

{
    size_t      ret;
 
    ret = fwrite(ptr, 1, size, (FILE *) CFH->private_data);
    if (ret != size)
        return false;
 
    return true;
}

References CompressFileHandle::private_data, and size.

Referenced by InitCompressFileHandleNone().

WriteDataToArchiveNone()

static void WriteDataToArchiveNone ( ArchiveHandle *  AH, CompressorState *  cs, const void *  data, size_t  dLen  )

static

Definition at line 49 of file compress_none.c.

{
    cs->writeF(AH, data, dLen);
}

References data, and CompressorState::writeF.

Referenced by InitCompressorNone().