aboutsummaryrefslogtreecommitdiffstats
path: root/shared.c
diff options
context:
space:
mode:
authorGravatar Lars Hjemli <hjemli@gmail.com>2009-08-01 00:38:38 (JST)
committerGravatar Lars Hjemli <hjemli@gmail.com>2009-08-01 00:39:51 (JST)
commitd6f6072560c963065b13c704fa1fa6f8950e4bac (patch)
tree096a542cd404d4a174f2f4a1da44ab0df99aa7c3 /shared.c
parent286a905842dc0bec6d21a614ec4a97c5f19d5bc4 (diff)
downloadcgit-d6f6072560c963065b13c704fa1fa6f8950e4bac.zip
cgit-d6f6072560c963065b13c704fa1fa6f8950e4bac.tar.gz
Add generic filter/plugin infrastructure
The functions cgit_open_filter() and cgit_close_filter() can be used to execute filters on the output stream from cgit. Signed-off-by: Lars Hjemli <hjemli@gmail.com>
Diffstat (limited to 'shared.c')
-rw-r--r--shared.c35
1 files changed, 35 insertions, 0 deletions
diff --git a/shared.c b/shared.c
index cce0af4..288cfa2 100644
--- a/shared.c
+++ b/shared.c
@@ -355,3 +355,38 @@ int cgit_parse_snapshots_mask(const char *str)
355 } 355 }
356 return rv; 356 return rv;
357} 357}
358
359int cgit_open_filter(struct cgit_filter *filter)
360{
361
362 filter->old_stdout = chk_positive(dup(STDOUT_FILENO),
363 "Unable to duplicate STDOUT");
364 chk_zero(pipe(filter->pipe_fh), "Unable to create pipe to subprocess");
365 filter->pid = chk_non_negative(fork(), "Unable to create subprocess");
366 if (filter->pid == 0) {
367 close(filter->pipe_fh[1]);
368 chk_non_negative(dup2(filter->pipe_fh[0], STDIN_FILENO),
369 "Unable to use pipe as STDIN");
370 execvp(filter->cmd, filter->argv);
371 die("Unable to exec subprocess %s: %s (%d)", filter->cmd,
372 strerror(errno), errno);
373 }
374 close(filter->pipe_fh[0]);
375 chk_non_negative(dup2(filter->pipe_fh[1], STDOUT_FILENO),
376 "Unable to use pipe as STDOUT");
377 close(filter->pipe_fh[1]);
378 return 0;
379}
380
381int cgit_close_filter(struct cgit_filter *filter)
382{
383 chk_non_negative(dup2(filter->old_stdout, STDOUT_FILENO),
384 "Unable to restore STDOUT");
385 close(filter->old_stdout);
386 if (filter->pid < 0)
387 return 0;
388 waitpid(filter->pid, &filter->exitstatus, 0);
389 if (WIFEXITED(filter->exitstatus) && !WEXITSTATUS(filter->exitstatus))
390 return 0;
391 die("Subprocess %s exited abnormally", filter->cmd);
392}