walmethods.h File Reference

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 }
enum	WalCompressionMethod { COMPRESSION_GZIP , COMPRESSION_LZ4 , COMPRESSION_NONE }

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

Typedef Documentation

Walfile

typedef void* Walfile

Definition at line 13 of file walmethods.h.

WalWriteMethod

typedef struct WalWriteMethod WalWriteMethod

Definition at line 13 of file walmethods.h.

Enumeration Type Documentation

WalCloseMethod

enum WalCloseMethod

Enumerator
CLOSE_NORMAL
CLOSE_UNLINK
CLOSE_NO_RENAME

Definition at line 15 of file walmethods.h.

{
    CLOSE_NORMAL,
    CLOSE_UNLINK,
    CLOSE_NO_RENAME
} WalCloseMethod;

WalCompressionMethod

enum WalCompressionMethod

Enumerator
COMPRESSION_GZIP
COMPRESSION_LZ4
COMPRESSION_NONE

Definition at line 23 of file walmethods.h.

{
    COMPRESSION_GZIP,
    COMPRESSION_LZ4,
    COMPRESSION_NONE
} WalCompressionMethod;

Function Documentation

CreateWalDirectoryMethod()

WalWriteMethod* CreateWalDirectoryMethod	(	const char *	basedir,
		WalCompressionMethod	compression_method,
		int	compression,
		bool	sync
	)

Definition at line 610 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_method = dir_compression_method;
    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_method = compression_method;
    dir_data->compression_level = compression_level;
    dir_data->basedir = pg_strdup(basedir);
    dir_data->sync = sync;
 
    return method;
}

References basedir, DirectoryMethodData::basedir, WalWriteMethod::close, DirectoryMethodData::compression_level, compression_method, DirectoryMethodData::compression_method, WalWriteMethod::compression_method, dir_close(), dir_compression_method(), 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,
		WalCompressionMethod	compression_method,
		int	compression,
		bool	sync
	)

Definition at line 1310 of file walmethods.c.

{
    WalWriteMethod *method;
    const char *suffix = (compression_level != 0) ? ".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_method = tar_compression_method;
    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_method = compression_method;
    tar_data->compression_level = compression_level;
    tar_data->sync = sync;
#ifdef HAVE_LIBZ
    if (compression_level)
        tar_data->zlibOut = (char *) pg_malloc(ZLIB_OUT_SIZE + 1);
#endif
 
    return method;
}

References WalWriteMethod::close, TarMethodData::compression_level, compression_method, TarMethodData::compression_method, WalWriteMethod::compression_method, 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_malloc(), pg_malloc0(), sprintf, TarMethodData::sync, WalWriteMethod::sync, tar_close(), tar_compression_method(), 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 639 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 1346 of file walmethods.c.

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

References TarMethodData::compression_level, pg_free(), tar_data, and TarMethodData::tarfilename.

Referenced by LogStreamerMain().