PostgreSQL Source Code  git master
basebackup_sink.c File Reference
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)
Assert(fmt[strlen(fmt) - 1] !='\n')
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);
124  bbsink_cleanup(sink->bbs_next);
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 
)

Definition at line 89 of file basebackup_sink.c.

90 {
91  Assert(sink->bbs_next != NULL);
92  Assert(sink->bbs_buffer == sink->bbs_next->bbs_buffer);
95 }
static void bbsink_manifest_contents(bbsink *sink, size_t 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().