author | Lars Hjemli <hjemli@gmail.com> | 2006-12-11 11:10:12 (UTC) |
---|---|---|
committer | Lars Hjemli <hjemli@gmail.com> | 2006-12-11 11:10:12 (UTC) |
commit | 318d106300102c19d114a4ea89265b0a4060d9cb (patch) (unidiff) | |
tree | 3752575abec74ee0a2b544e36e3cc8f9cdfa1e66 /cgit.c | |
parent | a581ed8d6c15b0734b082fbadf0a907c2b170423 (diff) | |
download | cgit-318d106300102c19d114a4ea89265b0a4060d9cb.zip cgit-318d106300102c19d114a4ea89265b0a4060d9cb.tar.gz cgit-318d106300102c19d114a4ea89265b0a4060d9cb.tar.bz2 |
Avoid infinite loops in caching layer
Add a global variable, cgit_max_lock_attemps, to avoid the possibility of
infinite loops when failing to acquire a lockfile. This could happen on
broken setups or under crazy server load.
Incidentally, this also fixes a lurking bug in cache_lock() where an
uninitialized returnvalue was used.
Signed-off-by: Lars Hjemli <hjemli@gmail.com>
-rw-r--r-- | cgit.c | 9 |
1 files changed, 8 insertions, 1 deletions
@@ -2,64 +2,65 @@ | |||
2 | * | 2 | * |
3 | * Copyright (C) 2006 Lars Hjemli | 3 | * Copyright (C) 2006 Lars Hjemli |
4 | * | 4 | * |
5 | * Licensed under GNU General Public License v2 | 5 | * Licensed under GNU General Public License v2 |
6 | * (see COPYING for full license text) | 6 | * (see COPYING for full license text) |
7 | */ | 7 | */ |
8 | 8 | ||
9 | #include "cgit.h" | 9 | #include "cgit.h" |
10 | 10 | ||
11 | const char cgit_version[] = CGIT_VERSION; | 11 | const char cgit_version[] = CGIT_VERSION; |
12 | 12 | ||
13 | const char cgit_doctype[] = | 13 | const char cgit_doctype[] = |
14 | "<!DOCTYPE html PUBLIC \"-//W3C//DTD XHTML 1.0 Transitional//EN\"\n" | 14 | "<!DOCTYPE html PUBLIC \"-//W3C//DTD XHTML 1.0 Transitional//EN\"\n" |
15 | " \"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd\">\n"; | 15 | " \"http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd\">\n"; |
16 | 16 | ||
17 | const char cgit_error[] = | 17 | const char cgit_error[] = |
18 | "<div class='error'>%s</div>"; | 18 | "<div class='error'>%s</div>"; |
19 | 19 | ||
20 | const char cgit_lib_error[] = | 20 | const char cgit_lib_error[] = |
21 | "<div class='error'>%s: %s</div>"; | 21 | "<div class='error'>%s: %s</div>"; |
22 | 22 | ||
23 | int htmlfd = 0; | 23 | int htmlfd = 0; |
24 | 24 | ||
25 | char *cgit_root = "/usr/src/git"; | 25 | char *cgit_root = "/usr/src/git"; |
26 | char *cgit_root_title = "Git repository browser"; | 26 | char *cgit_root_title = "Git repository browser"; |
27 | char *cgit_css = "/cgit.css"; | 27 | char *cgit_css = "/cgit.css"; |
28 | char *cgit_logo = "/git-logo.png"; | 28 | char *cgit_logo = "/git-logo.png"; |
29 | char *cgit_logo_link = "http://www.kernel.org/pub/software/scm/git/docs/"; | 29 | char *cgit_logo_link = "http://www.kernel.org/pub/software/scm/git/docs/"; |
30 | char *cgit_virtual_root = NULL; | 30 | char *cgit_virtual_root = NULL; |
31 | 31 | ||
32 | char *cgit_cache_root = "/var/cache/cgit"; | 32 | char *cgit_cache_root = "/var/cache/cgit"; |
33 | 33 | ||
34 | int cgit_max_lock_attempts = 5; | ||
34 | int cgit_cache_root_ttl = 5; | 35 | int cgit_cache_root_ttl = 5; |
35 | int cgit_cache_repo_ttl = 5; | 36 | int cgit_cache_repo_ttl = 5; |
36 | int cgit_cache_dynamic_ttl = 5; | 37 | int cgit_cache_dynamic_ttl = 5; |
37 | int cgit_cache_static_ttl = -1; | 38 | int cgit_cache_static_ttl = -1; |
38 | int cgit_cache_max_create_time = 5; | 39 | int cgit_cache_max_create_time = 5; |
39 | 40 | ||
40 | char *cgit_repo_name = NULL; | 41 | char *cgit_repo_name = NULL; |
41 | char *cgit_repo_desc = NULL; | 42 | char *cgit_repo_desc = NULL; |
42 | char *cgit_repo_owner = NULL; | 43 | char *cgit_repo_owner = NULL; |
43 | 44 | ||
44 | int cgit_query_has_symref = 0; | 45 | int cgit_query_has_symref = 0; |
45 | int cgit_query_has_sha1 = 0; | 46 | int cgit_query_has_sha1 = 0; |
46 | 47 | ||
47 | char *cgit_querystring = NULL; | 48 | char *cgit_querystring = NULL; |
48 | char *cgit_query_repo = NULL; | 49 | char *cgit_query_repo = NULL; |
49 | char *cgit_query_page = NULL; | 50 | char *cgit_query_page = NULL; |
50 | char *cgit_query_head = NULL; | 51 | char *cgit_query_head = NULL; |
51 | char *cgit_query_sha1 = NULL; | 52 | char *cgit_query_sha1 = NULL; |
52 | 53 | ||
53 | struct cacheitem cacheitem; | 54 | struct cacheitem cacheitem; |
54 | 55 | ||
55 | int cgit_parse_query(char *txt, configfn fn) | 56 | int cgit_parse_query(char *txt, configfn fn) |
56 | { | 57 | { |
57 | char *t, *value = NULL, c; | 58 | char *t, *value = NULL, c; |
58 | 59 | ||
59 | if (!txt) | 60 | if (!txt) |
60 | return 0; | 61 | return 0; |
61 | 62 | ||
62 | t = txt = xstrdup(txt); | 63 | t = txt = xstrdup(txt); |
63 | 64 | ||
64 | while((c=*t) != '\0') { | 65 | while((c=*t) != '\0') { |
65 | if (c=='=') { | 66 | if (c=='=') { |
@@ -436,69 +437,75 @@ static void cgit_print_repo_page() | |||
436 | cgit_print_pageheader(title); | 437 | cgit_print_pageheader(title); |
437 | htmlf(cgit_lib_error, "Unable to scan repository", | 438 | htmlf(cgit_lib_error, "Unable to scan repository", |
438 | strerror(errno)); | 439 | strerror(errno)); |
439 | cgit_print_docend(); | 440 | cgit_print_docend(); |
440 | return; | 441 | return; |
441 | } | 442 | } |
442 | setenv("GIT_DIR", fmt("%s/%s", cgit_root, cgit_query_repo), 1); | 443 | setenv("GIT_DIR", fmt("%s/%s", cgit_root, cgit_query_repo), 1); |
443 | char *title = fmt("%s - %s", cgit_repo_name, cgit_repo_desc); | 444 | char *title = fmt("%s - %s", cgit_repo_name, cgit_repo_desc); |
444 | cgit_print_docstart(title); | 445 | cgit_print_docstart(title); |
445 | cgit_print_pageheader(title); | 446 | cgit_print_pageheader(title); |
446 | if (!cgit_query_page) | 447 | if (!cgit_query_page) |
447 | cgit_print_repo_summary(); | 448 | cgit_print_repo_summary(); |
448 | else if (!strcmp(cgit_query_page, "log")) { | 449 | else if (!strcmp(cgit_query_page, "log")) { |
449 | cgit_print_log(cgit_query_head, 0, 100); | 450 | cgit_print_log(cgit_query_head, 0, 100); |
450 | } else if (!strcmp(cgit_query_page, "view")) { | 451 | } else if (!strcmp(cgit_query_page, "view")) { |
451 | cgit_print_object(cgit_query_sha1); | 452 | cgit_print_object(cgit_query_sha1); |
452 | } | 453 | } |
453 | cgit_print_docend(); | 454 | cgit_print_docend(); |
454 | } | 455 | } |
455 | 456 | ||
456 | static void cgit_fill_cache(struct cacheitem *item) | 457 | static void cgit_fill_cache(struct cacheitem *item) |
457 | { | 458 | { |
458 | htmlfd = item->fd; | 459 | htmlfd = item->fd; |
459 | item->st.st_mtime = time(NULL); | 460 | item->st.st_mtime = time(NULL); |
460 | if (cgit_query_repo) | 461 | if (cgit_query_repo) |
461 | cgit_print_repo_page(); | 462 | cgit_print_repo_page(); |
462 | else | 463 | else |
463 | cgit_print_repolist(); | 464 | cgit_print_repolist(); |
464 | } | 465 | } |
465 | 466 | ||
466 | static void cgit_refresh_cache(struct cacheitem *item) | 467 | static void cgit_refresh_cache(struct cacheitem *item) |
467 | { | 468 | { |
469 | int i = 0; | ||
470 | |||
468 | cache_prepare(item); | 471 | cache_prepare(item); |
469 | top: | 472 | top: |
473 | if (++i > cgit_max_lock_attempts) { | ||
474 | die("cgit_refresh_cache: unable to lock %s: %s", | ||
475 | item->name, strerror(errno)); | ||
476 | } | ||
470 | if (!cache_exist(item)) { | 477 | if (!cache_exist(item)) { |
471 | if (!cache_lock(item)) { | 478 | if (!cache_lock(item)) { |
472 | sched_yield(); | 479 | sleep(1); |
473 | goto top; | 480 | goto top; |
474 | } | 481 | } |
475 | if (!cache_exist(item)) | 482 | if (!cache_exist(item)) |
476 | cgit_fill_cache(item); | 483 | cgit_fill_cache(item); |
477 | cache_unlock(item); | 484 | cache_unlock(item); |
478 | } else if (cache_expired(item) && cache_lock(item)) { | 485 | } else if (cache_expired(item) && cache_lock(item)) { |
479 | if (cache_expired(item)) | 486 | if (cache_expired(item)) |
480 | cgit_fill_cache(item); | 487 | cgit_fill_cache(item); |
481 | cache_unlock(item); | 488 | cache_unlock(item); |
482 | } | 489 | } |
483 | } | 490 | } |
484 | 491 | ||
485 | static void cgit_print_cache(struct cacheitem *item) | 492 | static void cgit_print_cache(struct cacheitem *item) |
486 | { | 493 | { |
487 | static char buf[4096]; | 494 | static char buf[4096]; |
488 | ssize_t i; | 495 | ssize_t i; |
489 | 496 | ||
490 | int fd = open(item->name, O_RDONLY); | 497 | int fd = open(item->name, O_RDONLY); |
491 | if (fd<0) | 498 | if (fd<0) |
492 | die("Unable to open cached file %s", item->name); | 499 | die("Unable to open cached file %s", item->name); |
493 | 500 | ||
494 | while((i=read(fd, buf, sizeof(buf))) > 0) | 501 | while((i=read(fd, buf, sizeof(buf))) > 0) |
495 | write(STDOUT_FILENO, buf, i); | 502 | write(STDOUT_FILENO, buf, i); |
496 | 503 | ||
497 | close(fd); | 504 | close(fd); |
498 | } | 505 | } |
499 | 506 | ||
500 | int main(int argc, const char **argv) | 507 | int main(int argc, const char **argv) |
501 | { | 508 | { |
502 | cgit_read_config("/etc/cgitrc", cgit_global_config_cb); | 509 | cgit_read_config("/etc/cgitrc", cgit_global_config_cb); |
503 | cgit_querystring = xstrdup(getenv("QUERY_STRING")); | 510 | cgit_querystring = xstrdup(getenv("QUERY_STRING")); |
504 | cgit_parse_query(cgit_querystring, cgit_querystring_cb); | 511 | cgit_parse_query(cgit_querystring, cgit_querystring_cb); |