rdelaage
/
postgresql
mirror of https://git.postgresql.org/git/postgresql.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Rename walmethod fsync method to sync 

Using the name fsync clashed with the #define we have on Windows that
redefines it to _commit. Naming it sync should remove that conflict.

Per all the Windows buildfarm members
This commit is contained in:
Magnus Hagander 2016-10-23 18:04:34 +02:00
parent a5c17c1dce
commit eade082b12
3 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/bin/pg_basebackup/receivelog.c
View File

@ -132,7 +132,7 @@ open_walfile(StreamCtl *stream, XLogRecPtr startpoint)
} }
/* fsync file in case of a previous crash */ /* fsync file in case of a previous crash */
if (!stream->walmethod->fsync(f)) if (!stream->walmethod->sync(f))
{ {
stream->walmethod->close(f, CLOSE_UNLINK); stream->walmethod->close(f, CLOSE_UNLINK);
return false; return false;
@ -768,7 +768,7 @@ HandleCopyStream(PGconn *conn, StreamCtl *stream,
*/ */
if (stream->synchronous && lastFlushPosition < blockpos && walfile != NULL) if (stream->synchronous && lastFlushPosition < blockpos && walfile != NULL)
{ {
if (stream->walmethod->fsync(walfile) != 0) if (stream->walmethod->sync(walfile) != 0)
{ {
fprintf(stderr, _("%s: could not fsync file \"%s\": %s\n"), fprintf(stderr, _("%s: could not fsync file \"%s\": %s\n"),
progname, current_walfile_name, stream->walmethod->getlasterror()); progname, current_walfile_name, stream->walmethod->getlasterror());
@ -1011,7 +1011,7 @@ ProcessKeepaliveMsg(PGconn *conn, StreamCtl *stream, char *copybuf, int len,
* data has been successfully replicated or not, at the normal * data has been successfully replicated or not, at the normal
* shutdown of the server. * shutdown of the server.
*/ */
if (stream->walmethod->fsync(walfile) != 0) if (stream->walmethod->sync(walfile) != 0)
{ {
fprintf(stderr, _("%s: could not fsync file \"%s\": %s\n"), fprintf(stderr, _("%s: could not fsync file \"%s\": %s\n"),
progname, current_walfile_name, stream->walmethod->getlasterror()); progname, current_walfile_name, stream->walmethod->getlasterror());

10
src/bin/pg_basebackup/walmethods.c
View File

@ -219,7 +219,7 @@ dir_close(Walfile f, WalCloseMethod method)
} }
static int static int
dir_fsync(Walfile f) dir_sync(Walfile f)
{ {
Assert(f != NULL); Assert(f != NULL);
@ -287,7 +287,7 @@ CreateWalDirectoryMethod(const char *basedir, bool sync)
method->get_current_pos = dir_get_current_pos; method->get_current_pos = dir_get_current_pos;
method->get_file_size = dir_get_file_size; method->get_file_size = dir_get_file_size;
method->close = dir_close; method->close = dir_close;
method->fsync = dir_fsync; method->sync = dir_sync;
method->existsfile = dir_existsfile; method->existsfile = dir_existsfile;
method->finish = dir_finish; method->finish = dir_finish;
method->getlasterror = dir_getlasterror; method->getlasterror = dir_getlasterror;
@ -606,7 +606,7 @@ tar_get_current_pos(Walfile f)
} }
static int static int
tar_fsync(Walfile f) tar_sync(Walfile f)
{ {
Assert(f != NULL); Assert(f != NULL);
tar_clear_error(); tar_clear_error();
@ -764,7 +764,7 @@ tar_close(Walfile f, WalCloseMethod method)
return -1; return -1;
/* Always fsync on close, so the padding gets fsynced */ /* Always fsync on close, so the padding gets fsynced */
tar_fsync(f); tar_sync(f);
/* Clean up and done */ /* Clean up and done */
pg_free(tf->pathname); pg_free(tf->pathname);
@ -872,7 +872,7 @@ CreateWalTarMethod(const char *tarbase, int compression, bool sync)
method->get_current_pos = tar_get_current_pos; method->get_current_pos = tar_get_current_pos;
method->get_file_size = tar_get_file_size; method->get_file_size = tar_get_file_size;
method->close = tar_close; method->close = tar_close;
method->fsync = tar_fsync; method->sync = tar_sync;
method->existsfile = tar_existsfile; method->existsfile = tar_existsfile;
method->finish = tar_finish; method->finish = tar_finish;
method->getlasterror = tar_getlasterror; method->getlasterror = tar_getlasterror;

2
src/bin/pg_basebackup/walmethods.h
View File

@ -29,7 +29,7 @@ struct WalWriteMethod
ssize_t (*write) (Walfile f, const void *buf, size_t count); ssize_t (*write) (Walfile f, const void *buf, size_t count);
off_t (*get_current_pos) (Walfile f); off_t (*get_current_pos) (Walfile f);
int (*fsync) (Walfile f); int (*sync) (Walfile f);
bool (*finish) (void); bool (*finish) (void);
char *(*getlasterror) (void); char *(*getlasterror) (void);
}; };