astreamer_inject.h File Reference

#include "fe_utils/astreamer.h"
#include "pqexpbuffer.h"

Include dependency graph for astreamer_inject.h:

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

Go to the source code of this file.

Functions
astreamer *	astreamer_recovery_injector_new (astreamer *next, bool is_recovery_guc_supported, PQExpBuffer recoveryconfcontents)
void	astreamer_inject_file (astreamer *streamer, char *pathname, char *data, int len)

Function Documentation

astreamer_inject_file()

void astreamer_inject_file	(	astreamer *	streamer,
		char *	pathname,
		char *	data,
		int	len
	)

Definition at line 219 of file astreamer_inject.c.

{
    astreamer_member member;
 
    strlcpy(member.pathname, pathname, MAXPGPATH);
    member.size = len;
    member.mode = pg_file_create_mode;
    member.is_directory = false;
    member.is_link = false;
    member.linktarget[0] = '\0';
 
    /*
     * There seems to be no principled argument for these values, but they are
     * what PostgreSQL has historically used.
     */
    member.uid = 04000;
    member.gid = 02000;
 
    /*
     * We don't know here how to generate valid member headers and trailers
     * for the archiving format in use, so if those are needed, some successor
     * astreamer will have to generate them using the data from 'member'.
     */
    astreamer_content(streamer, &member, NULL, 0,
                      ASTREAMER_MEMBER_HEADER);
    astreamer_content(streamer, &member, data, len,
                      ASTREAMER_MEMBER_CONTENTS);
    astreamer_content(streamer, &member, NULL, 0,
                      ASTREAMER_MEMBER_TRAILER);
}

References astreamer_content(), ASTREAMER_MEMBER_CONTENTS, ASTREAMER_MEMBER_HEADER, ASTREAMER_MEMBER_TRAILER, data, astreamer_member::gid, astreamer_member::is_directory, astreamer_member::is_link, len, astreamer_member::linktarget, MAXPGPATH, astreamer_member::mode, astreamer_member::pathname, pg_file_create_mode, astreamer_member::size, strlcpy(), and astreamer_member::uid.

Referenced by astreamer_recovery_injector_content(), ReceiveArchiveStream(), and ReceiveTarFile().

astreamer_recovery_injector_new()

astreamer * astreamer_recovery_injector_new	(	astreamer *	next,
		bool	is_recovery_guc_supported,
		PQExpBuffer	recoveryconfcontents
	)

Definition at line 65 of file astreamer_inject.c.

{
    astreamer_recovery_injector *streamer;
 
    streamer = palloc0(sizeof(astreamer_recovery_injector));
    *((const astreamer_ops **) &streamer->base.bbs_ops) =
        &astreamer_recovery_injector_ops;
    streamer->base.bbs_next = next;
    streamer->is_recovery_guc_supported = is_recovery_guc_supported;
    streamer->recoveryconfcontents = recoveryconfcontents;
 
    return &streamer->base;
}

References astreamer_recovery_injector_ops, astreamer_recovery_injector::base, astreamer::bbs_next, astreamer::bbs_ops, astreamer_recovery_injector::is_recovery_guc_supported, next, palloc0(), astreamer_recovery_injector::recoveryconfcontents, and recoveryconfcontents.

Referenced by CreateBackupStreamer().