aboutsummaryrefslogtreecommitdiffstats
path: root/file.c
diff options
context:
space:
mode:
authorFumitoshi UKAI <ukai@debian.or.jp>2003-01-22 16:10:27 +0000
committerFumitoshi UKAI <ukai@debian.or.jp>2003-01-22 16:10:27 +0000
commitb8b4edb15b7c1eca41c6272a197b37574d5c8238 (patch)
tree6b5680ba64aacb350b972e377e883c37e32909cf /file.c
parent[w3m-dev 03675] x-face (diff)
downloadw3m-b8b4edb15b7c1eca41c6272a197b37574d5c8238.tar.gz
w3m-b8b4edb15b7c1eca41c6272a197b37574d5c8238.zip
[w3m-dev 03676] cleanup for pipe
* etc.c (open_pipe_rw): added * file.c (uncompress_stream): rewrite using open_pipe_rw * image.c (openImgdisplay): rewrite using open_pipe_rw * local.c (localcgi_popen_rw): deleted (localcgi_post): rewrite using open_pipe_rw * proto.h (open_pipe_rw): added * search.c (migemor): initialized to NULL (migemow): initialized to NULL (migemo_pid): initialized to 0 (open_migemo): rewrite using open_pipe_rw From: Hironori SAKAMOTO <hsaka@mth.biglobe.ne.jp>
Diffstat (limited to '')
-rw-r--r--file.c108
1 files changed, 42 insertions, 66 deletions
diff --git a/file.c b/file.c
index e4242f1..68862f2 100644
--- a/file.c
+++ b/file.c
@@ -1,4 +1,4 @@
-/* $Id: file.c,v 1.197 2003/01/22 16:01:17 ukai Exp $ */
+/* $Id: file.c,v 1.198 2003/01/22 16:10:28 ukai Exp $ */
#include "fm.h"
#include <sys/types.h>
#include "myctype.h"
@@ -7723,8 +7723,8 @@ inputAnswer(char *prompt)
static void
uncompress_stream(URLFile *uf, char **src)
{
- int pid1;
- int fd1[2];
+ pid_t pid1;
+ FILE *f1;
char *expand_cmd = GUNZIP_CMDNAME;
char *expand_name = GUNZIP_NAME;
char *tmpf = NULL;
@@ -7748,82 +7748,58 @@ uncompress_stream(URLFile *uf, char **src)
}
uf->compression = CMP_NOCOMPRESS;
- if (pipe(fd1) < 0) {
- UFclose(uf);
- return;
- }
-
if (uf->scheme != SCM_LOCAL
#ifdef USE_IMAGE
&& !image_source
#endif
) {
tmpf = tmpfname(TMPF_DFL, ext)->ptr;
- if (save2tmp(*uf, tmpf) < 0) {
- UFclose(uf);
- return;
- }
-#if 0
- if (uf->scheme != SCM_FTP)
-#endif
- UFclose(uf);
- if (src)
- *src = tmpf;
- else
- uf->scheme = SCM_LOCAL;
}
- flush_tty();
- /* fd1[0]: read, fd1[1]: write */
- if ((pid1 = fork()) == 0) {
- close(fd1[0]);
- dup2(fd1[1], 1);
- dup2(fd1[1], 2);
+ pid1 = open_pipe_rw(&f1, NULL);
+ if (pid1 < 0) {
+ UFclose(uf);
+ return;
+ }
+ if (pid1 == 0) {
+ /* child */
+ pid_t pid2;
+ FILE *f2;
+ dup2(1, 2); /* stderr>&stdout */
setup_child(TRUE, -1, UFfileno(uf));
- if (tmpf) {
-#ifdef USE_BINMODE_STREAM
- int tmpfd = open(tmpf, O_RDONLY | O_BINARY);
-#else
- int tmpfd = open(tmpf, O_RDONLY);
-#endif
- if (tmpfd < 0) {
- close(fd1[1]);
- exit(1);
- }
- dup2(tmpfd, 0);
- }
- else {
- /* child */
- int pid2;
- int fd2[2];
- if (pipe(fd2) < 0) {
- close(fd1[1]);
- UFclose(uf);
- exit(1);
- }
- if ((pid2 = fork()) == 0) {
- /* child */
- Str buf = Strnew_size(SAVE_BUF_SIZE);
- close(fd2[0]);
- while (UFread(uf, buf, SAVE_BUF_SIZE)) {
- if (write(fd2[1], buf->ptr, buf->length) < 0) {
- close(fd2[1]);
- exit(0);
- }
- }
- close(fd2[1]);
- exit(0);
+ pid2 = open_pipe_rw(NULL, &f2);
+ if (pid2 < 0) {
+ UFclose(uf);
+ exit(1);
+ }
+ if (pid2 > 0) {
+ Str buf = Strnew_size(SAVE_BUF_SIZE);
+ FILE *f = NULL;
+ if (tmpf)
+ f = fopen(tmpf, "wb");
+ while (UFread(uf, buf, SAVE_BUF_SIZE)) {
+ if (Strfputs(buf, f2) < 0)
+ break;
+ if (f)
+ Strfputs(buf, f);
}
- close(fd2[1]);
- dup2(fd2[0], 0);
+ fclose(f2);
+ if (f)
+ fclose(f);
+ exit(0);
}
+ /* child */
execlp(expand_cmd, expand_name, NULL);
- exit(0);
+ exit(1);
}
- close(fd1[1]);
- if (tmpf == NULL)
- UFclose(uf);
- uf->stream = newFileStream(fdopen(fd1[0], "rb"), (void (*)())pclose);
+ if (tmpf) {
+ if (src)
+ *src = tmpf;
+ else
+ uf->scheme = SCM_LOCAL;
+ }
+ UFhalfclose(uf);
+ uf->stream = newFileStream(f1, (void (*)())fclose);
}
static FILE *