Commitdac1d43

committed

Fx handling files with zero length

1 parent16f5c9a commitdac1d43Copy full SHA for dac1d43

File tree

+18

-1

lines changed

+18

-1

lines changed

Lines changed: 18 additions & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -873,6 +873,7 @@ int fio_send_pages(FILE* in, FILE* out, pgFile *file,`
`873`	`873`	`req.arg.clevel=clevel;`
`874`	`874`
`875`	`875`	`IO_CHECK(fio_write_all(fio_stdout,&req,sizeof(req)),sizeof(req));`
	`876`	`+file->compress_alg=calg;`
`876`	`877`
`877`	`878`	`while (true)`
`878`	`879`	`{`
`@@ -886,7 +887,24 @@ int fio_send_pages(FILE* in, FILE* out, pgFile *file,`
`886`	`887`
`887`	`888`	`blknum=hdr.arg;`
`888`	`889`	`if (hdr.size==0)/* end of segment */`
	`890`	`+{`
	`891`	`+if (n_blocks_read==0)`
	`892`	`+{`
	`893`	`+BackupPageHeaderph;`
	`894`	`+ph.block=blknum;`
	`895`	`+ph.compressed_size=0;`
	`896`	`+if (fio_fwrite(out,&ph,sizeofph)!=sizeof(ph))`
	`897`	`+{`
	`898`	`+interrno_tmp=errno;`
	`899`	`+fio_fclose(out);`
	`900`	`+elog(ERROR,"File: %s, cannot write backup at block %u: %s",`
	`901`	`+file->path,blknum,strerror(errno_tmp));`
	`902`	`+}`
	`903`	`+n_blocks_read++;`
	`904`	`+file->write_size=sizeof(ph);`
	`905`	`+}`
`889`	`906`	`break;`
	`907`	`+}`
`890`	`908`
`891`	`909`	`Assert(hdr.size <=sizeof(buf));`
`892`	`910`	`IO_CHECK(fio_read_all(fio_stdin,buf,hdr.size),hdr.size);`
`@@ -900,7 +918,6 @@ int fio_send_pages(FILE* in, FILE* out, pgFile *file,`
`900`	`918`	`elog(ERROR,"File: %s, cannot write backup at block %u: %s",`
`901`	`919`	`file->path,blknum,strerror(errno_tmp));`
`902`	`920`	`}`
`903`		`-file->compress_alg=calg;`
`904`	`921`	`file->read_size+=BLCKSZ;`
`905`	`922`	`file->write_size+=hdr.size;`
`906`	`923`	`n_blocks_read++;`

Comments

(0)