Commitd68714b

committed

Allow pg_basebackup compressed tar output to stdout

1 parent1b6dabc commitd68714bCopy full SHA for d68714b

File tree

+25

-12

lines changed

+25

-12

lines changed

Lines changed: 1 addition & 2 deletions

Original file line number	Diff line number	Diff line change
`@@ -174,8 +174,7 @@ PostgreSQL documentation`
`174`	`174`	`<listitem>`
`175`	`175`	`<para>`
`176`	`176`	`Enables gzip compression of tar file output. Compression is only`
`177`		`- available when generating tar files, and is not available when sending`
`178`		`- output to standard output.`
	`177`	`+ available when using the tar format.`
`179`	`178`	`</para>`
`180`	`179`	`</listitem>`
`181`	`180`	`</varlistentry>`

Lines changed: 24 additions & 10 deletions

Original file line number	Diff line number	Diff line change
`@@ -261,7 +261,22 @@ ReceiveTarFile(PGconn conn, PGresult res, int rownum)`
`261`	`261`	`* Base tablespaces`
`262`	`262`	`*/`
`263`	`263`	`if (strcmp(basedir,"-")==0)`
`264`		`-tarfile=stdout;`
	`264`	`+{`
	`265`	`+#ifdefHAVE_LIBZ`
	`266`	`+if (compresslevel>0)`
	`267`	`+{`
	`268`	`+ztarfile=gzdopen(dup(fileno(stdout)),"wb");`
	`269`	`+if (gzsetparams(ztarfile,compresslevel,Z_DEFAULT_STRATEGY)!=Z_OK)`
	`270`	`+{`
	`271`	`+fprintf(stderr,_("%s: could not set compression level %i: %s\n"),`
	`272`	`+progname,compresslevel,get_gz_error(ztarfile));`
	`273`	`+disconnect_and_exit(1);`
	`274`	`+}`
	`275`	`+}`
	`276`	`+else`
	`277`	`+#endif`
	`278`	`+tarfile=stdout;`
	`279`	`+}`
`265`	`280`	`else`
`266`	`281`	`{`
`267`	`282`	`#ifdefHAVE_LIBZ`
`@@ -384,7 +399,14 @@ ReceiveTarFile(PGconn conn, PGresult res, int rownum)`
`384`	`399`	`}`
`385`	`400`	`}`
`386`	`401`
`387`		`-if (strcmp(basedir,"-")!=0)`
	`402`	`+if (strcmp(basedir,"-")==0)`
	`403`	`+{`
	`404`	`+#ifdefHAVE_LIBZ`
	`405`	`+if (ztarfile)`
	`406`	`+gzclose(ztarfile);`
	`407`	`+#endif`
	`408`	`+}`
	`409`	`+else`
`388`	`410`	`{`
`389`	`411`	`#ifdefHAVE_LIBZ`
`390`	`412`	`if (ztarfile!=NULL)`
`@@ -1076,14 +1098,6 @@ main(int argc, char **argv)`
`1076`	`1098`	`progname);`
`1077`	`1099`	`exit(1);`
`1078`	`1100`	`}`
`1079`		`-#else`
`1080`		`-if (compresslevel>0&&strcmp(basedir,"-")==0)`
`1081`		`-{`
`1082`		`-fprintf(stderr,`
`1083`		`-_("%s: compression is not supported on standard output\n"),`
`1084`		`-progname);`
`1085`		`-exit(1);`
`1086`		`-}`
`1087`	`1101`	`#endif`
`1088`	`1102`
`1089`	`1103`	`/*`

Comments

(0)