summaryrefslogtreecommitdiffabout
path: root/shared.c
authorLars Hjemli <hjemli@gmail.com>2010-07-18 13:03:08 (UTC)
committer Lars Hjemli <hjemli@gmail.com>2010-07-18 13:03:08 (UTC)
commit5c5d189635287a3bfaa1a4aef133dc0c582a27c2 (patch) (unidiff)
treecf14b0a5578c9d23a560690e7e256260633ce043 /shared.c
parent60fcf600f5010701c20b63867999a802ca0e05c0 (diff)
parentba56a37e863d0f90e3e953047486905cfb959925 (diff)
downloadcgit-5c5d189635287a3bfaa1a4aef133dc0c582a27c2.zip
cgit-5c5d189635287a3bfaa1a4aef133dc0c582a27c2.tar.gz
cgit-5c5d189635287a3bfaa1a4aef133dc0c582a27c2.tar.bz2
Merge branch 'lh/macros'
Diffstat (limited to 'shared.c') (more/less context) (ignore whitespace changes)
-rw-r--r--shared.c71
1 files changed, 71 insertions, 0 deletions
diff --git a/shared.c b/shared.c
index 06f70bb..9f7d6a5 100644
--- a/shared.c
+++ b/shared.c
@@ -371,64 +371,135 @@ int cgit_parse_snapshots_mask(const char *str)
371} 371}
372 372
373int cgit_open_filter(struct cgit_filter *filter) 373int cgit_open_filter(struct cgit_filter *filter)
374{ 374{
375 375
376 filter->old_stdout = chk_positive(dup(STDOUT_FILENO), 376 filter->old_stdout = chk_positive(dup(STDOUT_FILENO),
377 "Unable to duplicate STDOUT"); 377 "Unable to duplicate STDOUT");
378 chk_zero(pipe(filter->pipe_fh), "Unable to create pipe to subprocess"); 378 chk_zero(pipe(filter->pipe_fh), "Unable to create pipe to subprocess");
379 filter->pid = chk_non_negative(fork(), "Unable to create subprocess"); 379 filter->pid = chk_non_negative(fork(), "Unable to create subprocess");
380 if (filter->pid == 0) { 380 if (filter->pid == 0) {
381 close(filter->pipe_fh[1]); 381 close(filter->pipe_fh[1]);
382 chk_non_negative(dup2(filter->pipe_fh[0], STDIN_FILENO), 382 chk_non_negative(dup2(filter->pipe_fh[0], STDIN_FILENO),
383 "Unable to use pipe as STDIN"); 383 "Unable to use pipe as STDIN");
384 execvp(filter->cmd, filter->argv); 384 execvp(filter->cmd, filter->argv);
385 die("Unable to exec subprocess %s: %s (%d)", filter->cmd, 385 die("Unable to exec subprocess %s: %s (%d)", filter->cmd,
386 strerror(errno), errno); 386 strerror(errno), errno);
387 } 387 }
388 close(filter->pipe_fh[0]); 388 close(filter->pipe_fh[0]);
389 chk_non_negative(dup2(filter->pipe_fh[1], STDOUT_FILENO), 389 chk_non_negative(dup2(filter->pipe_fh[1], STDOUT_FILENO),
390 "Unable to use pipe as STDOUT"); 390 "Unable to use pipe as STDOUT");
391 close(filter->pipe_fh[1]); 391 close(filter->pipe_fh[1]);
392 return 0; 392 return 0;
393} 393}
394 394
395int cgit_close_filter(struct cgit_filter *filter) 395int cgit_close_filter(struct cgit_filter *filter)
396{ 396{
397 chk_non_negative(dup2(filter->old_stdout, STDOUT_FILENO), 397 chk_non_negative(dup2(filter->old_stdout, STDOUT_FILENO),
398 "Unable to restore STDOUT"); 398 "Unable to restore STDOUT");
399 close(filter->old_stdout); 399 close(filter->old_stdout);
400 if (filter->pid < 0) 400 if (filter->pid < 0)
401 return 0; 401 return 0;
402 waitpid(filter->pid, &filter->exitstatus, 0); 402 waitpid(filter->pid, &filter->exitstatus, 0);
403 if (WIFEXITED(filter->exitstatus) && !WEXITSTATUS(filter->exitstatus)) 403 if (WIFEXITED(filter->exitstatus) && !WEXITSTATUS(filter->exitstatus))
404 return 0; 404 return 0;
405 die("Subprocess %s exited abnormally", filter->cmd); 405 die("Subprocess %s exited abnormally", filter->cmd);
406} 406}
407 407
408/* Read the content of the specified file into a newly allocated buffer, 408/* Read the content of the specified file into a newly allocated buffer,
409 * zeroterminate the buffer and return 0 on success, errno otherwise. 409 * zeroterminate the buffer and return 0 on success, errno otherwise.
410 */ 410 */
411int readfile(const char *path, char **buf, size_t *size) 411int readfile(const char *path, char **buf, size_t *size)
412{ 412{
413 int fd, e; 413 int fd, e;
414 struct stat st; 414 struct stat st;
415 415
416 fd = open(path, O_RDONLY); 416 fd = open(path, O_RDONLY);
417 if (fd == -1) 417 if (fd == -1)
418 return errno; 418 return errno;
419 if (fstat(fd, &st)) { 419 if (fstat(fd, &st)) {
420 e = errno; 420 e = errno;
421 close(fd); 421 close(fd);
422 return e; 422 return e;
423 } 423 }
424 if (!S_ISREG(st.st_mode)) { 424 if (!S_ISREG(st.st_mode)) {
425 close(fd); 425 close(fd);
426 return EISDIR; 426 return EISDIR;
427 } 427 }
428 *buf = xmalloc(st.st_size + 1); 428 *buf = xmalloc(st.st_size + 1);
429 *size = read_in_full(fd, *buf, st.st_size); 429 *size = read_in_full(fd, *buf, st.st_size);
430 e = errno; 430 e = errno;
431 (*buf)[*size] = '\0'; 431 (*buf)[*size] = '\0';
432 close(fd); 432 close(fd);
433 return (*size == st.st_size ? 0 : e); 433 return (*size == st.st_size ? 0 : e);
434} 434}
435
436int is_token_char(char c)
437{
438 return isalnum(c) || c == '_';
439}
440
441/* Replace name with getenv(name), return pointer to zero-terminating char
442 */
443char *expand_macro(char *name, int maxlength)
444{
445 char *value;
446 int len;
447
448 len = 0;
449 value = getenv(name);
450 if (value) {
451 len = strlen(value);
452 if (len > maxlength)
453 len = maxlength;
454 strncpy(name, value, len);
455 }
456 return name + len;
457}
458
459#define EXPBUFSIZE (1024 * 8)
460
461/* Replace all tokens prefixed by '$' in the specified text with the
462 * value of the named environment variable.
463 * NB: the return value is a static buffer, i.e. it must be strdup'd
464 * by the caller.
465 */
466char *expand_macros(const char *txt)
467{
468 static char result[EXPBUFSIZE];
469 char *p, *start;
470 int len;
471
472 p = result;
473 start = NULL;
474 while (p < result + EXPBUFSIZE - 1 && txt && *txt) {
475 *p = *txt;
476 if (start) {
477 if (!is_token_char(*txt)) {
478 if (p - start > 0) {
479 *p = '\0';
480 len = result + EXPBUFSIZE - start - 1;
481 p = expand_macro(start, len) - 1;
482 }
483 start = NULL;
484 txt--;
485 }
486 p++;
487 txt++;
488 continue;
489 }
490 if (*txt == '$') {
491 start = p;
492 txt++;
493 continue;
494 }
495 p++;
496 txt++;
497 }
498 *p = '\0';
499 if (start && p - start > 0) {
500 len = result + EXPBUFSIZE - start - 1;
501 p = expand_macro(start, len);
502 *p = '\0';
503 }
504 return result;
505}