NotificationsYou must be signed in to change notification settings
Fork6
Star31

Commit62fb12d

committed

When performing a base backup, check for read errors.

The old code didn't differentiate between a read error and aconcurrent truncation. fread reports both of these by returning 0;you have to use feof() or ferror() to distinguish between them,which this code did not do.It might be a better idea to use read() rather than fread() here,so that we can display a less-generic error message, but I'm notsure that would qualify as a back-patchable bug fix, so just dothis much for now.Jeevan Chalke, reviewed by Jeevan Ladhe and by me.Discussion:http://postgr.es/m/CA+TgmobG4ywMzL5oQq2a8YKp8x2p3p1LOMMcGqpS7aekT9+ETA@mail.gmail.com

1 parent4950f09 commit62fb12dCopy full SHA for 62fb12d

File tree

1 file changed

+16

-0

lines changed

src/backend/replication
- basebackup.c

1 file changed

+16

-0

lines changed

`‎src/backend/replication/basebackup.c`

Lines changed: 16 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -85,6 +85,18 @@ static char *statrelpath = NULL;`
`85`	`85`	`*/`
`86`	`86`	`#defineTHROTTLING_FREQUENCY8`
`87`	`87`
	`88`	`+/*`
	`89`	`+ * Checks whether we encountered any error in fread(). fread() doesn't give`
	`90`	`+ * any clue what has happened, so we check with ferror(). Also, neither`
	`91`	`+ * fread() nor ferror() set errno, so we just throw a generic error.`
	`92`	`+ */`
	`93`	`+#defineCHECK_FREAD_ERROR(fp,filename) \`
	`94`	`+do { \`
	`95`	`+if (ferror(fp)) \`
	`96`	`+ereport(ERROR, \`
	`97`	`+(errmsg("could not read from file \"%s\"", filename))); \`
	`98`	`+} while (0)`
	`99`	`+`
`88`	`100`	`/* The actual number of bytes, transfer of which may cause sleep. */`
`89`	`101`	`staticuint64throttling_sample;`
`90`	`102`
`@@ -509,6 +521,8 @@ perform_base_backup(basebackup_options opt, DIR tblspcdir)`
`509`	`521`	`break;`
`510`	`522`	`}`
`511`	`523`
	`524`	`+CHECK_FREAD_ERROR(fp,pathbuf);`
	`525`	`+`
`512`	`526`	`if (len!=XLogSegSize)`
`513`	`527`	`{`
`514`	`528`	`CheckXLogRemoved(segno,tli);`
`@@ -1245,6 +1259,8 @@ sendFile(char readfilename, char tarfilename, struct stat *statbuf,`
`1245`	`1259`	`}`
`1246`	`1260`	`}`
`1247`	`1261`
	`1262`	`+CHECK_FREAD_ERROR(fp,readfilename);`
	`1263`	`+`
`1248`	`1264`	`/* If the file was truncated while we were sending it, pad it with zeros */`
`1249`	`1265`	`if (len<statbuf->st_size)`
`1250`	`1266`	`{`

0 commit comments

Comments

(0)

Movatterモバイル変換

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit62fb12d

File tree

1 file changed

1 file changed

`‎src/backend/replication/basebackup.c`

0 commit comments