forked from vmware-archive/pg_rewind
-
Notifications
You must be signed in to change notification settings - Fork 0
/
fetch.h
56 lines (45 loc) · 1.87 KB
/
fetch.h
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
/*-------------------------------------------------------------------------
*
* fetch.h
* Fetching data from a local or remote data directory.
*
* This file includes the prototypes for functions used to copy files from
* one data directory to another. The source to copy from can be a local
* directory (copy method), or a remote PostgreSQL server (libpq fetch
* method).
*
* Portions Copyright (c) 2013-2015 VMware, Inc. All Rights Reserved.
*
*-------------------------------------------------------------------------
*/
#ifndef FETCH_H
#define FETCH_H
#include "c.h"
#include "filemap.h"
/*
* Common interface. Calls the copy or libpq method depending on global
* config options.
*/
extern void fetchRemoteFileList(void);
extern char *fetchFile(char *filename, size_t *filesize);
extern void executeFileMap(void);
/* in libpq_fetch.c */
extern void libpqConnect(const char *connstr);
extern void libpqProcessFileList(void);
extern void libpq_executeFileMap(filemap_t *map);
extern void libpqGetChangedDataPages(datapagemap_t *pagemap);
extern void libpqGetOtherFiles(void);
extern char *libpqGetFile(const char *filename, size_t *filesize);
/* in copy_fetch.c */
extern void copy_executeFileMap(filemap_t *map);
extern void open_target_file(const char *path, bool trunc);
extern void write_file_range(char *buf, off_t begin, size_t size);
extern void close_target_file(void);
extern char *slurpFile(const char *datadir, const char *path, size_t *filesize);
typedef void (*process_file_callback_t) (const char *path, file_type_t type, size_t size, const char *link_target);
extern void traverse_datadir(const char *datadir, process_file_callback_t callback);
extern void truncate_target_file(const char *path, off_t newsize);
extern void create_target(file_entry_t *t);
extern void remove_target(file_entry_t *t);
extern void check_samefile(int fd1, int fd2);
#endif /* FETCH_H */