PostgreSQL Source Code git master
All Data Structures Namespaces Files Functions Variables Typedefs Enumerations Enumerator Macros Pages
basebackup_sink.c File Reference
#include "postgres.h"
#include "backup/basebackup_sink.h"
Include dependency graph for basebackup_sink.c:

Go to the source code of this file.

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.

55{
56 Assert(sink->bbs_next != NULL);
57 Assert(sink->bbs_buffer == sink->bbs_next->bbs_buffer);
60}
static void bbsink_archive_contents(bbsink *sink, size_t len)
#define Assert(condition)
Definition: c.h:812
const void size_t len
bbsink * bbs_next
char * bbs_buffer
size_t bbs_buffer_length

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.

38{
39 Assert(sink->bbs_next != NULL);
40 bbsink_begin_archive(sink->bbs_next, archive_name);
41}
static void bbsink_begin_archive(bbsink *sink, const char *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.

25{
26 Assert(sink->bbs_next != NULL);
27 Assert(sink->bbs_state != NULL);
29 sink->bbs_buffer_length);
30 sink->bbs_buffer = sink->bbs_next->bbs_buffer;
31}
static void bbsink_begin_backup(bbsink *sink, bbsink_state *state, int buffer_length)
bbsink_state * bbs_state

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.

77{
78 Assert(sink->bbs_next != NULL);
80}
static void bbsink_begin_manifest(bbsink *sink)

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.

122{
123 Assert(sink->bbs_next != NULL);
125}
static void bbsink_cleanup(bbsink *sink)

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.

67{
68 Assert(sink->bbs_next != NULL);
70}
static void bbsink_end_archive(bbsink *sink)

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.

112{
113 Assert(sink->bbs_next != NULL);
114 bbsink_end_backup(sink->bbs_next, endptr, endtli);
115}
static void bbsink_end_backup(bbsink *sink, XLogRecPtr endptr, TimeLineID 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.

102{
103 Assert(sink->bbs_next != NULL);
105}
static void bbsink_end_manifest(bbsink *sink)

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 
)