walmethods.h File Reference

#include "common/compression.h"

Include dependency graph for walmethods.h:

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

Go to the source code of this file.

Data Structures
struct	WalWriteMethod

Typedefs
typedef void *	Walfile
typedef struct WalWriteMethod	WalWriteMethod

Enumerations
enum	WalCloseMethod { CLOSE_NORMAL , CLOSE_UNLINK , CLOSE_NO_RENAME }

Functions
WalWriteMethod *	CreateWalDirectoryMethod (const char *basedir, pg_compress_algorithm compression_algo, int compression, bool sync)
WalWriteMethod *	CreateWalTarMethod (const char *tarbase, pg_compress_algorithm compression_algo, int compression, bool sync)
void	FreeWalDirectoryMethod (void)
void	FreeWalTarMethod (void)

Typedef Documentation

Walfile

typedef void* Walfile

Definition at line 14 of file walmethods.h.

WalWriteMethod

typedef struct WalWriteMethod WalWriteMethod

Definition at line 14 of file walmethods.h.

Enumeration Type Documentation

WalCloseMethod

enum WalCloseMethod

Enumerator
CLOSE_NORMAL
CLOSE_UNLINK
CLOSE_NO_RENAME

Definition at line 16 of file walmethods.h.

{
    CLOSE_NORMAL,
    CLOSE_UNLINK,
    CLOSE_NO_RENAME
} WalCloseMethod;

Function Documentation

CreateWalDirectoryMethod()

WalWriteMethod* CreateWalDirectoryMethod	(	const char *	basedir,
		pg_compress_algorithm	compression_algo,
		int	compression,
		bool	sync
	)

Definition at line 625 of file walmethods.c.

{
    WalWriteMethod *method;
 
    method = pg_malloc0(sizeof(WalWriteMethod));
    method->open_for_write = dir_open_for_write;
    method->write = dir_write;
    method->get_current_pos = dir_get_current_pos;
    method->get_file_size = dir_get_file_size;
    method->get_file_name = dir_get_file_name;
    method->compression_algorithm = dir_compression_algorithm;
    method->close = dir_close;
    method->sync = dir_sync;
    method->existsfile = dir_existsfile;
    method->finish = dir_finish;
    method->getlasterror = dir_getlasterror;
 
    dir_data = pg_malloc0(sizeof(DirectoryMethodData));
    dir_data->compression_algorithm = compression_algorithm;
    dir_data->compression_level = compression_level;
    dir_data->basedir = pg_strdup(basedir);
    dir_data->sync = sync;
 
    return method;
}

References basedir, DirectoryMethodData::basedir, WalWriteMethod::close, compression_algorithm, DirectoryMethodData::compression_algorithm, WalWriteMethod::compression_algorithm, DirectoryMethodData::compression_level, dir_close(), dir_compression_algorithm(), dir_data, dir_existsfile(), dir_finish(), dir_get_current_pos(), dir_get_file_name(), dir_get_file_size(), dir_getlasterror(), dir_open_for_write(), dir_sync(), dir_write(), WalWriteMethod::existsfile, WalWriteMethod::finish, WalWriteMethod::get_current_pos, WalWriteMethod::get_file_name, WalWriteMethod::get_file_size, WalWriteMethod::getlasterror, WalWriteMethod::open_for_write, pg_malloc0(), pg_strdup(), DirectoryMethodData::sync, WalWriteMethod::sync, and WalWriteMethod::write.

Referenced by LogStreamerMain(), and StreamLog().

CreateWalTarMethod()

WalWriteMethod* CreateWalTarMethod	(	const char *	tarbase,
		pg_compress_algorithm	compression_algo,
		int	compression,
		bool	sync
	)

Definition at line 1338 of file walmethods.c.

{
    WalWriteMethod *method;
    const char *suffix = (compression_algorithm == PG_COMPRESSION_GZIP) ?
    ".tar.gz" : ".tar";
 
    method = pg_malloc0(sizeof(WalWriteMethod));
    method->open_for_write = tar_open_for_write;
    method->write = tar_write;
    method->get_current_pos = tar_get_current_pos;
    method->get_file_size = tar_get_file_size;
    method->get_file_name = tar_get_file_name;
    method->compression_algorithm = tar_compression_algorithm;
    method->close = tar_close;
    method->sync = tar_sync;
    method->existsfile = tar_existsfile;
    method->finish = tar_finish;
    method->getlasterror = tar_getlasterror;
 
    tar_data = pg_malloc0(sizeof(TarMethodData));
    tar_data->tarfilename = pg_malloc0(strlen(tarbase) + strlen(suffix) + 1);
    sprintf(tar_data->tarfilename, "%s%s", tarbase, suffix);
    tar_data->fd = -1;
    tar_data->compression_algorithm = compression_algorithm;
    tar_data->compression_level = compression_level;
    tar_data->sync = sync;
#ifdef HAVE_LIBZ
    if (compression_algorithm == PG_COMPRESSION_GZIP)
        tar_data->zlibOut = (char *) pg_malloc(ZLIB_OUT_SIZE + 1);
#endif
 
    return method;
}

References WalWriteMethod::close, compression_algorithm, TarMethodData::compression_algorithm, WalWriteMethod::compression_algorithm, TarMethodData::compression_level, WalWriteMethod::existsfile, TarMethodData::fd, WalWriteMethod::finish, WalWriteMethod::get_current_pos, WalWriteMethod::get_file_name, WalWriteMethod::get_file_size, WalWriteMethod::getlasterror, WalWriteMethod::open_for_write, PG_COMPRESSION_GZIP, pg_malloc(), pg_malloc0(), sprintf, TarMethodData::sync, WalWriteMethod::sync, tar_close(), tar_compression_algorithm(), tar_data, tar_existsfile(), tar_finish(), tar_get_current_pos(), tar_get_file_name(), tar_get_file_size(), tar_getlasterror(), tar_open_for_write(), tar_sync(), tar_write(), TarMethodData::tarfilename, WalWriteMethod::write, and ZLIB_OUT_SIZE.

Referenced by LogStreamerMain().

FreeWalDirectoryMethod()

void FreeWalDirectoryMethod

(

void

)

Definition at line 654 of file walmethods.c.

{
    pg_free(dir_data->basedir);
    pg_free(dir_data);
    dir_data = NULL;
}

References DirectoryMethodData::basedir, dir_data, and pg_free().

Referenced by LogStreamerMain(), and StreamLog().

FreeWalTarMethod()

void FreeWalTarMethod

(

void

)

Definition at line 1375 of file walmethods.c.

{
    pg_free(tar_data->tarfilename);
#ifdef HAVE_LIBZ
    if (tar_data->compression_algorithm == PG_COMPRESSION_GZIP)
        pg_free(tar_data->zlibOut);
#endif
    pg_free(tar_data);
    tar_data = NULL;
}

References TarMethodData::compression_algorithm, PG_COMPRESSION_GZIP, pg_free(), tar_data, and TarMethodData::tarfilename.

Referenced by LogStreamerMain().