1 /*-------------------------------------------------------------------------
4 * Win32 open() replacement
7 * Portions Copyright (c) 1996-2009, PostgreSQL Global Development Group
9 * $PostgreSQL: pgsql/src/port/open.c,v 1.29 2010/01/02 12:00:08 mha Exp $
11 *-------------------------------------------------------------------------
19 #include "postgres_fe.h"
28 openFlagsToCreateFileFlags(int openFlags)
30 switch (openFlags & (O_CREAT | O_TRUNC | O_EXCL))
32 /* O_EXCL is meaningless without O_CREAT */
40 /* O_EXCL is meaningless without O_CREAT */
42 case O_TRUNC | O_EXCL:
43 return TRUNCATE_EXISTING;
45 case O_CREAT | O_TRUNC:
48 /* O_TRUNC is meaningless with O_CREAT */
49 case O_CREAT | O_EXCL:
50 case O_CREAT | O_TRUNC | O_EXCL:
54 /* will never get here */
59 * - file attribute setting, based on fileMode?
62 pgwin32_open(const char *fileName, int fileFlags,...)
65 HANDLE h = INVALID_HANDLE_VALUE;
66 SECURITY_ATTRIBUTES sa;
69 /* Check that we can handle the request */
70 assert((fileFlags & ((O_RDONLY | O_WRONLY | O_RDWR) | O_APPEND |
71 (O_RANDOM | O_SEQUENTIAL | O_TEMPORARY) |
72 _O_SHORT_LIVED | O_DSYNC | O_DIRECT |
73 (O_CREAT | O_TRUNC | O_EXCL) | (O_TEXT | O_BINARY))) == fileFlags);
75 sa.nLength = sizeof(sa);
76 sa.bInheritHandle = TRUE;
77 sa.lpSecurityDescriptor = NULL;
79 while ((h = CreateFile(fileName,
80 /* cannot use O_RDONLY, as it == 0 */
81 (fileFlags & O_RDWR) ? (GENERIC_WRITE | GENERIC_READ) :
82 ((fileFlags & O_WRONLY) ? GENERIC_WRITE : GENERIC_READ),
83 /* These flags allow concurrent rename/unlink */
84 (FILE_SHARE_READ | FILE_SHARE_WRITE | FILE_SHARE_DELETE),
86 openFlagsToCreateFileFlags(fileFlags),
87 FILE_ATTRIBUTE_NORMAL |
88 ((fileFlags & O_RANDOM) ? FILE_FLAG_RANDOM_ACCESS : 0) |
89 ((fileFlags & O_SEQUENTIAL) ? FILE_FLAG_SEQUENTIAL_SCAN : 0) |
90 ((fileFlags & _O_SHORT_LIVED) ? FILE_ATTRIBUTE_TEMPORARY : 0) |
91 ((fileFlags & O_TEMPORARY) ? FILE_FLAG_DELETE_ON_CLOSE : 0) |
92 ((fileFlags & O_DIRECT) ? FILE_FLAG_NO_BUFFERING : 0) |
93 ((fileFlags & O_DSYNC) ? FILE_FLAG_WRITE_THROUGH : 0),
94 NULL)) == INVALID_HANDLE_VALUE)
97 * Sharing violation or locking error can indicate antivirus, backup
98 * or similar software that's locking the file. Try again for 30
99 * seconds before giving up.
101 DWORD err = GetLastError();
103 if (err == ERROR_SHARING_VIOLATION ||
104 err == ERROR_LOCK_VIOLATION)
112 (errmsg("could not open file \"%s\": %s", fileName,
113 (err == ERROR_SHARING_VIOLATION) ? _("sharing violation") : _("lock violation")),
114 errdetail("Continuing to retry for 30 seconds."),
115 errhint("You might have antivirus, backup, or similar software interfering with the database system.")));
126 /* _open_osfhandle will, on error, set errno accordingly */
127 if ((fd = _open_osfhandle((intptr_t) h, fileFlags & O_APPEND)) < 0)
128 CloseHandle(h); /* will not affect errno */
129 else if (fileFlags & (O_TEXT | O_BINARY) &&
130 _setmode(fd, fileFlags & (O_TEXT | O_BINARY)) < 0)
140 pgwin32_fopen(const char *fileName, const char *mode)
145 if (strstr(mode, "r+"))
147 else if (strchr(mode, 'r'))
148 openmode |= O_RDONLY;
149 if (strstr(mode, "w+"))
150 openmode |= O_RDWR | O_CREAT | O_TRUNC;
151 else if (strchr(mode, 'w'))
152 openmode |= O_WRONLY | O_CREAT | O_TRUNC;
153 if (strchr(mode, 'a'))
154 openmode |= O_WRONLY | O_CREAT | O_APPEND;
156 if (strchr(mode, 'b'))
157 openmode |= O_BINARY;
158 if (strchr(mode, 't'))
161 fd = pgwin32_open(fileName, openmode);
164 return _fdopen(fd, mode);