#include "postgres.h"
#include "backup/basebackup_sink.h"

Include dependency graph for basebackup_sink.c:

Functions
void	bbsink_forward_begin_backup (bbsink *sink)

void	bbsink_forward_begin_archive (bbsink sink, const char archive_name)

void	bbsink_forward_archive_contents (bbsink *sink, size_t len)

void	bbsink_forward_end_archive (bbsink *sink)

void	bbsink_forward_begin_manifest (bbsink *sink)

void	bbsink_forward_manifest_contents (bbsink *sink, size_t len)

void	bbsink_forward_end_manifest (bbsink *sink)

void	bbsink_forward_end_backup (bbsink *sink, XLogRecPtr endptr, TimeLineID endtli)

void	bbsink_forward_cleanup (bbsink *sink)

Function Documentation

◆ bbsink_forward_archive_contents()

void bbsink_forward_archive_contents	(	bbsink *	sink,
		size_t	len
	)

Definition at line 54 of file basebackup_sink.c.

{
    Assert(sink->bbs_next != NULL);
    Assert(sink->bbs_buffer == sink->bbs_next->bbs_buffer);
    Assert(sink->bbs_buffer_length == sink->bbs_next->bbs_buffer_length);
    bbsink_archive_contents(sink->bbs_next, len);
}

References Assert(), bbsink::bbs_buffer, bbsink::bbs_buffer_length, bbsink::bbs_next, bbsink_archive_contents(), and len.

Referenced by bbsink_progress_archive_contents(), bbsink_server_archive_contents(), bbsink_shell_archive_contents(), and bbsink_throttle_archive_contents().

◆ bbsink_forward_begin_archive()

void bbsink_forward_begin_archive	(	bbsink *	sink,
		const char *	archive_name
	)

Definition at line 37 of file basebackup_sink.c.

{
    Assert(sink->bbs_next != NULL);
    bbsink_begin_archive(sink->bbs_next, archive_name);
}

References Assert(), bbsink::bbs_next, and bbsink_begin_archive().

Referenced by bbsink_server_begin_archive(), and bbsink_shell_begin_archive().

◆ bbsink_forward_begin_backup()

void bbsink_forward_begin_backup ( bbsink * sink )

Definition at line 24 of file basebackup_sink.c.

{
    Assert(sink->bbs_next != NULL);
    Assert(sink->bbs_state != NULL);
    bbsink_begin_backup(sink->bbs_next, sink->bbs_state,
                        sink->bbs_buffer_length);
    sink->bbs_buffer = sink->bbs_next->bbs_buffer;
}

References Assert(), bbsink::bbs_buffer, bbsink::bbs_buffer_length, bbsink::bbs_next, bbsink::bbs_state, and bbsink_begin_backup().

Referenced by bbsink_progress_begin_backup(), and bbsink_throttle_begin_backup().

◆ bbsink_forward_begin_manifest()

void bbsink_forward_begin_manifest ( bbsink * sink )

Definition at line 76 of file basebackup_sink.c.

{
    Assert(sink->bbs_next != NULL);
    bbsink_begin_manifest(sink->bbs_next);
}

References Assert(), bbsink::bbs_next, and bbsink_begin_manifest().

Referenced by bbsink_server_begin_manifest(), and bbsink_shell_begin_manifest().

◆ bbsink_forward_cleanup()

void bbsink_forward_cleanup ( bbsink * sink )

Definition at line 121 of file basebackup_sink.c.

{
    Assert(sink->bbs_next != NULL);
    bbsink_cleanup(sink->bbs_next);
}

References Assert(), bbsink::bbs_next, and bbsink_cleanup().

◆ bbsink_forward_end_archive()

void bbsink_forward_end_archive ( bbsink * sink )

Definition at line 66 of file basebackup_sink.c.

{
    Assert(sink->bbs_next != NULL);
    bbsink_end_archive(sink->bbs_next);
}

References Assert(), bbsink::bbs_next, and bbsink_end_archive().

Referenced by bbsink_progress_end_archive(), bbsink_server_end_archive(), and bbsink_shell_end_archive().

◆ bbsink_forward_end_backup()

void bbsink_forward_end_backup	(	bbsink *	sink,
		XLogRecPtr	endptr,
		TimeLineID	endtli
	)

Definition at line 111 of file basebackup_sink.c.

{
    Assert(sink->bbs_next != NULL);
    bbsink_end_backup(sink->bbs_next, endptr, endtli);
}

References Assert(), bbsink::bbs_next, and bbsink_end_backup().

◆ bbsink_forward_end_manifest()

void bbsink_forward_end_manifest ( bbsink * sink )

Definition at line 101 of file basebackup_sink.c.

{
    Assert(sink->bbs_next != NULL);
    bbsink_end_manifest(sink->bbs_next);
}

References Assert(), bbsink::bbs_next, and bbsink_end_manifest().

Referenced by bbsink_server_end_manifest(), and bbsink_shell_end_manifest().

◆ bbsink_forward_manifest_contents()

void bbsink_forward_manifest_contents	(	bbsink *	sink,
		size_t	len
	)

Definition at line 89 of file basebackup_sink.c.

{
    Assert(sink->bbs_next != NULL);
    Assert(sink->bbs_buffer == sink->bbs_next->bbs_buffer);
    Assert(sink->bbs_buffer_length == sink->bbs_next->bbs_buffer_length);
    bbsink_manifest_contents(sink->bbs_next, len);
}

References Assert(), bbsink::bbs_buffer, bbsink::bbs_buffer_length, bbsink::bbs_next, bbsink_manifest_contents(), and len.

Referenced by bbsink_server_manifest_contents(), bbsink_shell_manifest_contents(), and bbsink_throttle_manifest_contents().

Functions