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
@@ -307,128 +307,199 @@ void cgit_diff_tree(const unsigned char *old_sha1,
307 const unsigned char *new_sha1, 307 const unsigned char *new_sha1,
308 filepair_fn fn, const char *prefix) 308 filepair_fn fn, const char *prefix)
309{ 309{
310 struct diff_options opt; 310 struct diff_options opt;
311 int ret; 311 int ret;
312 int prefixlen; 312 int prefixlen;
313 313
314 diff_setup(&opt); 314 diff_setup(&opt);
315 opt.output_format = DIFF_FORMAT_CALLBACK; 315 opt.output_format = DIFF_FORMAT_CALLBACK;
316 opt.detect_rename = 1; 316 opt.detect_rename = 1;
317 opt.rename_limit = ctx.cfg.renamelimit; 317 opt.rename_limit = ctx.cfg.renamelimit;
318 DIFF_OPT_SET(&opt, RECURSIVE); 318 DIFF_OPT_SET(&opt, RECURSIVE);
319 opt.format_callback = cgit_diff_tree_cb; 319 opt.format_callback = cgit_diff_tree_cb;
320 opt.format_callback_data = fn; 320 opt.format_callback_data = fn;
321 if (prefix) { 321 if (prefix) {
322 opt.nr_paths = 1; 322 opt.nr_paths = 1;
323 opt.paths = &prefix; 323 opt.paths = &prefix;
324 prefixlen = strlen(prefix); 324 prefixlen = strlen(prefix);
325 opt.pathlens = &prefixlen; 325 opt.pathlens = &prefixlen;
326 } 326 }
327 diff_setup_done(&opt); 327 diff_setup_done(&opt);
328 328
329 if (old_sha1 && !is_null_sha1(old_sha1)) 329 if (old_sha1 && !is_null_sha1(old_sha1))
330 ret = diff_tree_sha1(old_sha1, new_sha1, "", &opt); 330 ret = diff_tree_sha1(old_sha1, new_sha1, "", &opt);
331 else 331 else
332 ret = diff_root_tree_sha1(new_sha1, "", &opt); 332 ret = diff_root_tree_sha1(new_sha1, "", &opt);
333 diffcore_std(&opt); 333 diffcore_std(&opt);
334 diff_flush(&opt); 334 diff_flush(&opt);
335} 335}
336 336
337void cgit_diff_commit(struct commit *commit, filepair_fn fn) 337void cgit_diff_commit(struct commit *commit, filepair_fn fn)
338{ 338{
339 unsigned char *old_sha1 = NULL; 339 unsigned char *old_sha1 = NULL;
340 340
341 if (commit->parents) 341 if (commit->parents)
342 old_sha1 = commit->parents->item->object.sha1; 342 old_sha1 = commit->parents->item->object.sha1;
343 cgit_diff_tree(old_sha1, commit->object.sha1, fn, NULL); 343 cgit_diff_tree(old_sha1, commit->object.sha1, fn, NULL);
344} 344}
345 345
346int cgit_parse_snapshots_mask(const char *str) 346int cgit_parse_snapshots_mask(const char *str)
347{ 347{
348 const struct cgit_snapshot_format *f; 348 const struct cgit_snapshot_format *f;
349 static const char *delim = " \t,:/|;"; 349 static const char *delim = " \t,:/|;";
350 int tl, sl, rv = 0; 350 int tl, sl, rv = 0;
351 351
352 /* favor legacy setting */ 352 /* favor legacy setting */
353 if(atoi(str)) 353 if(atoi(str))
354 return 1; 354 return 1;
355 for(;;) { 355 for(;;) {
356 str += strspn(str,delim); 356 str += strspn(str,delim);
357 tl = strcspn(str,delim); 357 tl = strcspn(str,delim);
358 if (!tl) 358 if (!tl)
359 break; 359 break;
360 for (f = cgit_snapshot_formats; f->suffix; f++) { 360 for (f = cgit_snapshot_formats; f->suffix; f++) {
361 sl = strlen(f->suffix); 361 sl = strlen(f->suffix);
362 if((tl == sl && !strncmp(f->suffix, str, tl)) || 362 if((tl == sl && !strncmp(f->suffix, str, tl)) ||
363 (tl == sl-1 && !strncmp(f->suffix+1, str, tl-1))) { 363 (tl == sl-1 && !strncmp(f->suffix+1, str, tl-1))) {
364 rv |= f->bit; 364 rv |= f->bit;
365 break; 365 break;
366 } 366 }
367 } 367 }
368 str += tl; 368 str += tl;
369 } 369 }
370 return rv; 370 return rv;
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}