Commit92875e6

committed

pg_fsync is fsync in WAL version.

1 parentddeab22 commit92875e6Copy full SHA for 92875e6

File tree

+25

-4

lines changed

+25

-4

lines changed

Lines changed: 4 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@`
`8`	`8`	`*`
`9`	`9`	`*`
`10`	`10`	`* IDENTIFICATION`
`11`		`- * $Header: /cvsroot/pgsql/src/backend/storage/buffer/Attic/xlog_bufmgr.c,v 1.2 2000/11/08 22:09:59 tgl Exp $`
	`11`	`+ * $Header: /cvsroot/pgsql/src/backend/storage/buffer/Attic/xlog_bufmgr.c,v 1.3 2000/11/10 03:53:44 vadim Exp $`
`12`	`12`	`*`
`13`	`13`	`*-------------------------------------------------------------------------`
`14`	`14`	`*/`
`@@ -1065,6 +1065,9 @@ void`
`1065`	`1065`	`BufmgrCommit(void)`
`1066`	`1066`	`{`
`1067`	`1067`	`LocalBufferSync();`
	`1068`	`+/*`
	`1069`	`+ * All files created in current transaction will be fsync-ed`
	`1070`	`+ */`
`1068`	`1071`	`smgrcommit();`
`1069`	`1072`	`}`
`1070`	`1073`

Lines changed: 12 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,7 @@`
`7`	`7`	`* Portions Copyright (c) 1994, Regents of the University of California`
`8`	`8`	`*`
`9`	`9`	`* IDENTIFICATION`
`10`		`- * $Header: /cvsroot/pgsql/src/backend/storage/file/fd.c,v 1.65 2000/10/28 16:20:56 vadim Exp $`
	`10`	`+ * $Header: /cvsroot/pgsql/src/backend/storage/file/fd.c,v 1.66 2000/11/10 03:53:44 vadim Exp $`
`11`	`11`	`*`
`12`	`12`	`* NOTES:`
`13`	`13`	`*`
`@@ -192,6 +192,7 @@ static File fileNameOpenFile(FileName fileName, int fileFlags, int fileMode);`
`192`	`192`	`staticcharfilepath(charfilename);`
`193`	`193`	`staticlongpg_nofile(void);`
`194`	`194`
	`195`	`+#ifndefXLOG`
`195`	`196`	`/*`
`196`	`197`	`* pg_fsync --- same as fsync except does nothing if -F switch was given`
`197`	`198`	`*/`
`@@ -203,6 +204,7 @@ pg_fsync(int fd)`
`203`	`204`	`else`
`204`	`205`	`return0;`
`205`	`206`	`}`
	`207`	`+#endif`
`206`	`208`
`207`	`209`	`/*`
`208`	`210`	`* BasicOpenFile --- same as open(2) except can free other FDs if needed`
`@@ -663,7 +665,16 @@ fileNameOpenFile(FileName fileName,`
`663`	`665`	`vfdP->fileFlags=fileFlags& ~(O_TRUNC \|O_EXCL);`
`664`	`666`	`vfdP->fileMode=fileMode;`
`665`	`667`	`vfdP->seekPos=0;`
	`668`	`+#ifdefXLOG`
	`669`	`+/*`
	`670`	`+ * Have to fsync file on commit. Alternative way - log`
	`671`	`+ * file creation and fsync log before actual file creation.`
	`672`	`+ */`
	`673`	`+if (fileFlags&O_CREAT)`
	`674`	`+vfdP->fdstate=FD_DIRTY;`
	`675`	`+#else`
`666`	`676`	`vfdP->fdstate=0x0;`
	`677`	`+#endif`
`667`	`678`
`668`	`679`	`returnfile;`
`669`	`680`	`}`

Lines changed: 3 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -8,7 +8,7 @@`
`8`	`8`	`*`
`9`	`9`	`*`
`10`	`10`	`* IDENTIFICATION`
`11`		`- * $Header: /cvsroot/pgsql/src/backend/storage/smgr/md.c,v 1.78 2000/11/08 22:10:00 tgl Exp $`
	`11`	`+ * $Header: /cvsroot/pgsql/src/backend/storage/smgr/md.c,v 1.79 2000/11/10 03:53:45 vadim Exp $`
`12`	`12`	`*`
`13`	`13`	`*-------------------------------------------------------------------------`
`14`	`14`	`*/`
`@@ -569,12 +569,14 @@ mdblindwrt(RelFileNode rnode,`
`569`	`569`	`elog(DEBUG,"mdblindwrt: write() failed: %m");`
`570`	`570`	`status=SM_FAIL;`
`571`	`571`	`}`
	`572`	`+#ifndefXLOG`
`572`	`573`	`elseif (dofsync&&`
`573`	`574`	`pg_fsync(fd)<0)`
`574`	`575`	`{`
`575`	`576`	`elog(DEBUG,"mdblindwrt: fsync() failed: %m");`
`576`	`577`	`status=SM_FAIL;`
`577`	`578`	`}`
	`579`	`+#endif`
`578`	`580`
`579`	`581`	`if (close(fd)<0)`
`580`	`582`	`{`

Lines changed: 6 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -7,7 +7,7 @@`
`7`	`7`	`* Portions Copyright (c) 1996-2000, PostgreSQL, Inc`
`8`	`8`	`* Portions Copyright (c) 1994, Regents of the University of California`
`9`	`9`	`*`
`10`		`- * $Id: fd.h,v 1.22 2000/06/02 03:58:31 tgl Exp $`
	`10`	`+ * $Id: fd.h,v 1.23 2000/11/10 03:53:45 vadim Exp $`
`11`	`11`	`*`
`12`	`12`	`*-------------------------------------------------------------------------`
`13`	`13`	`*/`
`@@ -70,6 +70,11 @@ extern intBasicOpenFile(FileName fileName, int fileFlags, int fileMode);`
`70`	`70`	`/* Miscellaneous support routines */`
`71`	`71`	`externvoidcloseAllVfds(void);`
`72`	`72`	`externvoidAtEOXact_Files(void);`
	`73`	`+`
	`74`	`+#ifdefXLOG`
	`75`	`+#definepg_fsync(fd)fsync(fd)`
	`76`	`+#else`
`73`	`77`	`externintpg_fsync(intfd);`
	`78`	`+#endif`
`74`	`79`
`75`	`80`	`#endif/* FD_H */`

Comments

(0)