This graph shows which files directly or indirectly include 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 347 of file walmethods.c.

References DirectoryMethodData::basedir, WalWriteMethod::close, DirectoryMethodData::compression, dir_close(), dir_existsfile(), dir_finish(), dir_get_current_pos(), 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_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->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 949 of file walmethods.c.

References WalWriteMethod::close, DirectoryMethodData::compression, TarMethodData::compression, WalWriteMethod::existsfile, TarMethodData::fd, WalWriteMethod::finish, WalWriteMethod::get_current_pos, WalWriteMethod::get_file_size, WalWriteMethod::getlasterror, WalWriteMethod::open_for_write, pg_malloc(), pg_malloc0(), DirectoryMethodData::sync, WalWriteMethod::sync, TarMethodData::sync, tar_close(), tar_existsfile(), tar_finish(), tar_get_current_pos(), 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->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 371 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 980 of file walmethods.c.

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