author | Lars Hjemli <hjemli@gmail.com> | 2010-07-18 13:03:08 (UTC) |
---|---|---|
committer | Lars Hjemli <hjemli@gmail.com> | 2010-07-18 13:03:08 (UTC) |
commit | 5c5d189635287a3bfaa1a4aef133dc0c582a27c2 (patch) (unidiff) | |
tree | cf14b0a5578c9d23a560690e7e256260633ce043 /shared.c | |
parent | 60fcf600f5010701c20b63867999a802ca0e05c0 (diff) | |
parent | ba56a37e863d0f90e3e953047486905cfb959925 (diff) | |
download | cgit-5c5d189635287a3bfaa1a4aef133dc0c582a27c2.zip cgit-5c5d189635287a3bfaa1a4aef133dc0c582a27c2.tar.gz cgit-5c5d189635287a3bfaa1a4aef133dc0c582a27c2.tar.bz2 |
Merge branch 'lh/macros'
-rw-r--r-- | shared.c | 71 |
1 files changed, 71 insertions, 0 deletions
@@ -371,64 +371,135 @@ int cgit_parse_snapshots_mask(const char *str) | |||
371 | } | 371 | } |
372 | 372 | ||
373 | int cgit_open_filter(struct cgit_filter *filter) | 373 | int 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 | ||
395 | int cgit_close_filter(struct cgit_filter *filter) | 395 | int 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 | */ |
411 | int readfile(const char *path, char **buf, size_t *size) | 411 | int 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 | |||
436 | int 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 | */ | ||
443 | char *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 | */ | ||
466 | char *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 | } | ||