PostgreSQL Source Code: src/include/storage/fd.h Source File (original) (raw)

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#ifndef FD_H

44#define FD_H

45

47

49#include <fcntl.h>

50

52

53

54#define IO_DIRECT_DATA 0x01

55#define IO_DIRECT_WAL 0x02

56#define IO_DIRECT_WAL_INIT 0x04

57

58

59

64

65

66

67

69

70

71

72

73

74

75

76

77#ifndef WIN32

78#define FILE_POSSIBLY_DELETED(err) ((err) == ENOENT)

79#else

80#define FILE_POSSIBLY_DELETED(err) ((err) == ENOENT || (err) == EACCES)

81#endif

82

83

84

85

86

87

88

89

90

91#if defined(O_DIRECT) && defined(pg_attribute_aligned)

92#define PG_O_DIRECT O_DIRECT

93#elif defined(F_NOCACHE)

94#define PG_O_DIRECT 0x80000000

95#define PG_O_DIRECT_USE_F_NOCACHE

96#else

97#define PG_O_DIRECT 0

98#endif

99

100

101

102

103

105

106

111extern int FilePrefetch(File file, off_t offset, off_t amount, uint32 wait_event_info);

112extern ssize_t FileReadV(File file, const struct iovec *iov, int iovcnt, off_t offset, uint32 wait_event_info);

113extern ssize_t FileWriteV(File file, const struct iovec *iov, int iovcnt, off_t offset, uint32 wait_event_info);

116extern int FileZero(File file, off_t offset, off_t amount, uint32 wait_event_info);

118

126

127

134

135

137extern int FreeFile(FILE *file);

138

139

142

143

147 int elevel);

149

150

151extern int OpenTransientFile(const char *fileName, int fileFlags);

152extern int OpenTransientFilePerm(const char *fileName, int fileFlags, mode_t fileMode);

154

155

156extern int BasicOpenFile(const char *fileName, int fileFlags);

157extern int BasicOpenFilePerm(const char *fileName, int fileFlags, mode_t fileMode);

158

159

163

164

166

167

181 bool unlink_all);

183

189extern void pg_flush_data(int fd, off_t offset, off_t nbytes);

190extern int pg_truncate(const char *path, off_t length);

191extern void fsync_fname(const char *fname, bool isdir);

192extern int fsync_fname_ext(const char *fname, bool isdir, bool ignore_perm, int elevel);

193extern int durable_rename(const char *oldfile, const char *newfile, int elevel);

194extern int durable_unlink(const char *fname, int elevel);

197

198static inline ssize_t

199FileRead(File file, void *buffer, size_t amount, off_t offset,

200 uint32 wait_event_info)

201{

202 struct iovec iov = {

203 .iov_base = buffer,

204 .iov_len = amount

205 };

206

207 return FileReadV(file, &iov, 1, offset, wait_event_info);

208}

209

210static inline ssize_t

211FileWrite(File file, const void *buffer, size_t amount, off_t offset,

212 uint32 wait_event_info)

213{

214 struct iovec iov = {

215 .iov_base = unconstify(void *, buffer),

216 .iov_len = amount

217 };

218

219 return FileWriteV(file, &iov, 1, offset, wait_event_info);

220}

221

222#endif

#define unconstify(underlying_type, expr)

PGDLLIMPORT int max_safe_fds

void pg_flush_data(int fd, off_t offset, off_t nbytes)

int FileGetRawDesc(File file)

int MakePGDirectory(const char *directoryName)

void FileWriteback(File file, off_t offset, off_t nbytes, uint32 wait_event_info)

int pg_fsync_no_writethrough(int fd)

FILE * OpenPipeStream(const char *command, const char *mode)

int BasicOpenFilePerm(const char *fileName, int fileFlags, mode_t fileMode)

PGDLLIMPORT int io_direct_flags

int durable_rename(const char *oldfile, const char *newfile, int elevel)

char * FilePathName(File file)

int GetTempTablespaces(Oid *tableSpaces, int numSpaces)

File PathNameOpenTemporaryFile(const char *path, int mode)

int FileSync(File file, uint32 wait_event_info)

int CloseTransientFile(int fd)

int BasicOpenFile(const char *fileName, int fileFlags)

File PathNameCreateTemporaryFile(const char *path, bool error_on_failure)

void PathNameDeleteTemporaryDir(const char *dirname)

int ClosePipeStream(FILE *file)

PGDLLIMPORT bool data_sync_retry

void AtEOXact_Files(bool isCommit)

int FileGetRawFlags(File file)

int fsync_fname_ext(const char *fname, bool isdir, bool ignore_perm, int elevel)

PGDLLIMPORT int recovery_init_sync_method

mode_t FileGetRawMode(File file)

struct dirent * ReadDirExtended(DIR *dir, const char *dirname, int elevel)

int pg_fsync_writethrough(int fd)

void FileClose(File file)

void ReleaseExternalFD(void)

void RemovePgTempFilesInDir(const char *tmpdirname, bool missing_ok, bool unlink_all)

bool pg_file_exists(const char *name)

void RemovePgTempFiles(void)

bool TempTablespacesAreSet(void)

void fsync_fname(const char *fname, bool isdir)

int FileFallocate(File file, off_t offset, off_t amount, uint32 wait_event_info)

int FilePrefetch(File file, off_t offset, off_t amount, uint32 wait_event_info)

int data_sync_elevel(int elevel)

File PathNameOpenFile(const char *fileName, int fileFlags)

Oid GetNextTempTableSpace(void)

File PathNameOpenFilePerm(const char *fileName, int fileFlags, mode_t fileMode)

int FileStartReadV(struct PgAioHandle *ioh, File file, int iovcnt, off_t offset, uint32 wait_event_info)

bool AcquireExternalFD(void)

DIR * AllocateDir(const char *dirname)

void InitFileAccess(void)

File OpenTemporaryFile(bool interXact)

int durable_unlink(const char *fname, int elevel)

PGDLLIMPORT int max_files_per_process

void ReserveExternalFD(void)

struct dirent * ReadDir(DIR *dir, const char *dirname)

bool looks_like_temp_rel_name(const char *name)

bool PathNameDeleteTemporaryFile(const char *path, bool error_on_failure)

void set_max_safe_fds(void)

static ssize_t FileRead(File file, void *buffer, size_t amount, off_t offset, uint32 wait_event_info)

void PathNameCreateTemporaryDir(const char *basedir, const char *directory)

FILE * AllocateFile(const char *name, const char *mode)

static ssize_t FileWrite(File file, const void *buffer, size_t amount, off_t offset, uint32 wait_event_info)

void AtEOSubXact_Files(bool isCommit, SubTransactionId mySubid, SubTransactionId parentSubid)

int OpenTransientFile(const char *fileName, int fileFlags)

void InitTemporaryFileAccess(void)

int OpenTransientFilePerm(const char *fileName, int fileFlags, mode_t fileMode)

ssize_t FileWriteV(File file, const struct iovec *iov, int iovcnt, off_t offset, uint32 wait_event_info)

void SyncDataDirectory(void)

int FileZero(File file, off_t offset, off_t amount, uint32 wait_event_info)

off_t FileSize(File file)

ssize_t FileReadV(File file, const struct iovec *iov, int iovcnt, off_t offset, uint32 wait_event_info)

int FileTruncate(File file, off_t offset, uint32 wait_event_info)

int pg_truncate(const char *path, off_t length)

void SetTempTablespaces(Oid *tableSpaces, int numSpaces)

void TempTablespacePath(char *path, Oid tablespace)

static PgChecksumMode mode

static int fd(const char *x, int i)

static const char * directory