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 }

Functions
WalWriteMethod *	CreateWalDirectoryMethod (const char *basedir, int compression, bool sync)
WalWriteMethod *	CreateWalTarMethod (const char *tarbase, 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 32 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;

Function Documentation

CreateWalDirectoryMethod()

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

Definition at line 376 of file walmethods.c.

References DirectoryMethodData::basedir, WalWriteMethod::close, DirectoryMethodData::compression, WalWriteMethod::compression, dir_close(), dir_compression(), 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().

{
    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 = dir_compression;
    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 = compression;
    dir_data->basedir = pg_strdup(basedir);
    dir_data->sync = sync;

    return method;
}

CreateWalTarMethod()

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

Definition at line 1035 of file walmethods.c.

References WalWriteMethod::close, DirectoryMethodData::compression, WalWriteMethod::compression, TarMethodData::compression, 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, DirectoryMethodData::sync, WalWriteMethod::sync, TarMethodData::sync, tar_close(), tar_compression(), 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().

{
    WalWriteMethod *method;
    const char *suffix = (compression != 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 = tar_compression;
    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 = compression;
    tar_data->sync = sync;
#ifdef HAVE_LIBZ
    if (compression)
        tar_data->zlibOut = (char *) pg_malloc(ZLIB_OUT_SIZE + 1);
#endif

    return method;
}

FreeWalDirectoryMethod()

void FreeWalDirectoryMethod

(

void

)

Definition at line 402 of file walmethods.c.

References DirectoryMethodData::basedir, and pg_free().

Referenced by LogStreamerMain(), and StreamLog().

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

FreeWalTarMethod()

void FreeWalTarMethod

(

void

)

Definition at line 1068 of file walmethods.c.

References TarMethodData::compression, pg_free(), and TarMethodData::tarfilename.

Referenced by LogStreamerMain().

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