|
diff --git a/cgit.c b/cgit.c index b0e202e..93a7a69 100644 --- a/ cgit.c+++ b/ cgit.c |
|
@@ -398,192 +398,195 @@ static void process_request(void *cbdata) |
398 | |
398 | |
399 | cmd = cgit_get_cmd(ctx); |
399 | cmd = cgit_get_cmd(ctx); |
400 | if (!cmd) { |
400 | if (!cmd) { |
401 | ctx->page.title = "cgit error"; |
401 | ctx->page.title = "cgit error"; |
402 | cgit_print_http_headers(ctx); |
402 | cgit_print_http_headers(ctx); |
403 | cgit_print_docstart(ctx); |
403 | cgit_print_docstart(ctx); |
404 | cgit_print_pageheader(ctx); |
404 | cgit_print_pageheader(ctx); |
405 | cgit_print_error("Invalid request"); |
405 | cgit_print_error("Invalid request"); |
406 | cgit_print_docend(); |
406 | cgit_print_docend(); |
407 | return; |
407 | return; |
408 | } |
408 | } |
409 | |
409 | |
410 | if (cmd->want_repo && !ctx->repo) { |
410 | if (cmd->want_repo && !ctx->repo) { |
411 | cgit_print_http_headers(ctx); |
411 | cgit_print_http_headers(ctx); |
412 | cgit_print_docstart(ctx); |
412 | cgit_print_docstart(ctx); |
413 | cgit_print_pageheader(ctx); |
413 | cgit_print_pageheader(ctx); |
414 | cgit_print_error(fmt("No repository selected")); |
414 | cgit_print_error(fmt("No repository selected")); |
415 | cgit_print_docend(); |
415 | cgit_print_docend(); |
416 | return; |
416 | return; |
417 | } |
417 | } |
418 | |
418 | |
419 | if (ctx->repo && prepare_repo_cmd(ctx)) |
419 | if (ctx->repo && prepare_repo_cmd(ctx)) |
420 | return; |
420 | return; |
421 | |
421 | |
422 | if (cmd->want_layout) { |
422 | if (cmd->want_layout) { |
423 | cgit_print_http_headers(ctx); |
423 | cgit_print_http_headers(ctx); |
424 | cgit_print_docstart(ctx); |
424 | cgit_print_docstart(ctx); |
425 | cgit_print_pageheader(ctx); |
425 | cgit_print_pageheader(ctx); |
426 | } |
426 | } |
427 | |
427 | |
428 | cmd->fn(ctx); |
428 | cmd->fn(ctx); |
429 | |
429 | |
430 | if (cmd->want_layout) |
430 | if (cmd->want_layout) |
431 | cgit_print_docend(); |
431 | cgit_print_docend(); |
432 | } |
432 | } |
433 | |
433 | |
434 | int cmp_repos(const void *a, const void *b) |
434 | int cmp_repos(const void *a, const void *b) |
435 | { |
435 | { |
436 | const struct cgit_repo *ra = a, *rb = b; |
436 | const struct cgit_repo *ra = a, *rb = b; |
437 | return strcmp(ra->url, rb->url); |
437 | return strcmp(ra->url, rb->url); |
438 | } |
438 | } |
439 | |
439 | |
440 | char *build_snapshot_setting(int bitmap) |
440 | char *build_snapshot_setting(int bitmap) |
441 | { |
441 | { |
442 | const struct cgit_snapshot_format *f; |
442 | const struct cgit_snapshot_format *f; |
443 | char *result = xstrdup(""); |
443 | char *result = xstrdup(""); |
444 | char *tmp; |
444 | char *tmp; |
445 | int len; |
445 | int len; |
446 | |
446 | |
447 | for (f = cgit_snapshot_formats; f->suffix; f++) { |
447 | for (f = cgit_snapshot_formats; f->suffix; f++) { |
448 | if (f->bit & bitmap) { |
448 | if (f->bit & bitmap) { |
449 | tmp = result; |
449 | tmp = result; |
450 | result = xstrdup(fmt("%s%s ", tmp, f->suffix)); |
450 | result = xstrdup(fmt("%s%s ", tmp, f->suffix)); |
451 | free(tmp); |
451 | free(tmp); |
452 | } |
452 | } |
453 | } |
453 | } |
454 | len = strlen(result); |
454 | len = strlen(result); |
455 | if (len) |
455 | if (len) |
456 | result[len - 1] = '\0'; |
456 | result[len - 1] = '\0'; |
457 | return result; |
457 | return result; |
458 | } |
458 | } |
459 | |
459 | |
460 | void print_repo(FILE *f, struct cgit_repo *repo) |
460 | void print_repo(FILE *f, struct cgit_repo *repo) |
461 | { |
461 | { |
462 | fprintf(f, "repo.url=%s\n", repo->url); |
462 | fprintf(f, "repo.url=%s\n", repo->url); |
463 | fprintf(f, "repo.name=%s\n", repo->name); |
463 | fprintf(f, "repo.name=%s\n", repo->name); |
464 | fprintf(f, "repo.path=%s\n", repo->path); |
464 | fprintf(f, "repo.path=%s\n", repo->path); |
465 | if (repo->owner) |
465 | if (repo->owner) |
466 | fprintf(f, "repo.owner=%s\n", repo->owner); |
466 | fprintf(f, "repo.owner=%s\n", repo->owner); |
467 | if (repo->desc) |
467 | if (repo->desc) |
468 | fprintf(f, "repo.desc=%s\n", repo->desc); |
468 | fprintf(f, "repo.desc=%s\n", repo->desc); |
469 | if (repo->readme) |
469 | if (repo->readme) |
470 | fprintf(f, "repo.readme=%s\n", repo->readme); |
470 | fprintf(f, "repo.readme=%s\n", repo->readme); |
471 | if (repo->defbranch) |
471 | if (repo->defbranch) |
472 | fprintf(f, "repo.defbranch=%s\n", repo->defbranch); |
472 | fprintf(f, "repo.defbranch=%s\n", repo->defbranch); |
473 | if (repo->module_link) |
473 | if (repo->module_link) |
474 | fprintf(f, "repo.module-link=%s\n", repo->module_link); |
474 | fprintf(f, "repo.module-link=%s\n", repo->module_link); |
475 | if (repo->section) |
475 | if (repo->section) |
476 | fprintf(f, "repo.section=%s\n", repo->section); |
476 | fprintf(f, "repo.section=%s\n", repo->section); |
477 | if (repo->clone_url) |
477 | if (repo->clone_url) |
478 | fprintf(f, "repo.clone-url=%s\n", repo->clone_url); |
478 | fprintf(f, "repo.clone-url=%s\n", repo->clone_url); |
479 | fprintf(f, "repo.enable-log-filecount=%d\n", |
479 | fprintf(f, "repo.enable-log-filecount=%d\n", |
480 | repo->enable_log_filecount); |
480 | repo->enable_log_filecount); |
481 | fprintf(f, "repo.enable-log-linecount=%d\n", |
481 | fprintf(f, "repo.enable-log-linecount=%d\n", |
482 | repo->enable_log_linecount); |
482 | repo->enable_log_linecount); |
483 | if (repo->about_filter && repo->about_filter != ctx.cfg.about_filter) |
483 | if (repo->about_filter && repo->about_filter != ctx.cfg.about_filter) |
484 | fprintf(f, "repo.about-filter=%s\n", repo->about_filter->cmd); |
484 | fprintf(f, "repo.about-filter=%s\n", repo->about_filter->cmd); |
485 | if (repo->commit_filter && repo->commit_filter != ctx.cfg.commit_filter) |
485 | if (repo->commit_filter && repo->commit_filter != ctx.cfg.commit_filter) |
486 | fprintf(f, "repo.commit-filter=%s\n", repo->commit_filter->cmd); |
486 | fprintf(f, "repo.commit-filter=%s\n", repo->commit_filter->cmd); |
487 | if (repo->source_filter && repo->source_filter != ctx.cfg.source_filter) |
487 | if (repo->source_filter && repo->source_filter != ctx.cfg.source_filter) |
488 | fprintf(f, "repo.source-filter=%s\n", repo->source_filter->cmd); |
488 | fprintf(f, "repo.source-filter=%s\n", repo->source_filter->cmd); |
489 | if (repo->snapshots != ctx.cfg.snapshots) { |
489 | if (repo->snapshots != ctx.cfg.snapshots) { |
490 | char *tmp = build_snapshot_setting(repo->snapshots); |
490 | char *tmp = build_snapshot_setting(repo->snapshots); |
491 | fprintf(f, "repo.snapshots=%s\n", tmp); |
491 | fprintf(f, "repo.snapshots=%s\n", tmp); |
492 | free(tmp); |
492 | free(tmp); |
493 | } |
493 | } |
| |
494 | if (repo->max_stats != ctx.cfg.max_stats) |
| |
495 | fprintf(f, "repo.max-stats=%s\n", |
| |
496 | cgit_find_stats_periodname(repo->max_stats)); |
494 | fprintf(f, "\n"); |
497 | fprintf(f, "\n"); |
495 | } |
498 | } |
496 | |
499 | |
497 | void print_repolist(FILE *f, struct cgit_repolist *list, int start) |
500 | void print_repolist(FILE *f, struct cgit_repolist *list, int start) |
498 | { |
501 | { |
499 | int i; |
502 | int i; |
500 | |
503 | |
501 | for(i = start; i < list->count; i++) |
504 | for(i = start; i < list->count; i++) |
502 | print_repo(f, &list->repos[i]); |
505 | print_repo(f, &list->repos[i]); |
503 | } |
506 | } |
504 | |
507 | |
505 | /* Scan 'path' for git repositories, save the resulting repolist in 'cached_rc' |
508 | /* Scan 'path' for git repositories, save the resulting repolist in 'cached_rc' |
506 | * and return 0 on success. |
509 | * and return 0 on success. |
507 | */ |
510 | */ |
508 | static int generate_cached_repolist(const char *path, const char *cached_rc) |
511 | static int generate_cached_repolist(const char *path, const char *cached_rc) |
509 | { |
512 | { |
510 | char *locked_rc; |
513 | char *locked_rc; |
511 | int idx; |
514 | int idx; |
512 | FILE *f; |
515 | FILE *f; |
513 | |
516 | |
514 | locked_rc = xstrdup(fmt("%s.lock", cached_rc)); |
517 | locked_rc = xstrdup(fmt("%s.lock", cached_rc)); |
515 | f = fopen(locked_rc, "wx"); |
518 | f = fopen(locked_rc, "wx"); |
516 | if (!f) { |
519 | if (!f) { |
517 | /* Inform about the error unless the lockfile already existed, |
520 | /* Inform about the error unless the lockfile already existed, |
518 | * since that only means we've got concurrent requests. |
521 | * since that only means we've got concurrent requests. |
519 | */ |
522 | */ |
520 | if (errno != EEXIST) |
523 | if (errno != EEXIST) |
521 | fprintf(stderr, "[cgit] Error opening %s: %s (%d)\n", |
524 | fprintf(stderr, "[cgit] Error opening %s: %s (%d)\n", |
522 | locked_rc, strerror(errno), errno); |
525 | locked_rc, strerror(errno), errno); |
523 | return errno; |
526 | return errno; |
524 | } |
527 | } |
525 | idx = cgit_repolist.count; |
528 | idx = cgit_repolist.count; |
526 | scan_tree(path, repo_config); |
529 | scan_tree(path, repo_config); |
527 | print_repolist(f, &cgit_repolist, idx); |
530 | print_repolist(f, &cgit_repolist, idx); |
528 | if (rename(locked_rc, cached_rc)) |
531 | if (rename(locked_rc, cached_rc)) |
529 | fprintf(stderr, "[cgit] Error renaming %s to %s: %s (%d)\n", |
532 | fprintf(stderr, "[cgit] Error renaming %s to %s: %s (%d)\n", |
530 | locked_rc, cached_rc, strerror(errno), errno); |
533 | locked_rc, cached_rc, strerror(errno), errno); |
531 | fclose(f); |
534 | fclose(f); |
532 | return 0; |
535 | return 0; |
533 | } |
536 | } |
534 | |
537 | |
535 | static void process_cached_repolist(const char *path) |
538 | static void process_cached_repolist(const char *path) |
536 | { |
539 | { |
537 | struct stat st; |
540 | struct stat st; |
538 | char *cached_rc; |
541 | char *cached_rc; |
539 | time_t age; |
542 | time_t age; |
540 | |
543 | |
541 | cached_rc = xstrdup(fmt("%s/rc-%8x", ctx.cfg.cache_root, |
544 | cached_rc = xstrdup(fmt("%s/rc-%8x", ctx.cfg.cache_root, |
542 | hash_str(path))); |
545 | hash_str(path))); |
543 | |
546 | |
544 | if (stat(cached_rc, &st)) { |
547 | if (stat(cached_rc, &st)) { |
545 | /* Nothing is cached, we need to scan without forking. And |
548 | /* Nothing is cached, we need to scan without forking. And |
546 | * if we fail to generate a cached repolist, we need to |
549 | * if we fail to generate a cached repolist, we need to |
547 | * invoke scan_tree manually. |
550 | * invoke scan_tree manually. |
548 | */ |
551 | */ |
549 | if (generate_cached_repolist(path, cached_rc)) |
552 | if (generate_cached_repolist(path, cached_rc)) |
550 | scan_tree(path, repo_config); |
553 | scan_tree(path, repo_config); |
551 | return; |
554 | return; |
552 | } |
555 | } |
553 | |
556 | |
554 | parse_configfile(cached_rc, config_cb); |
557 | parse_configfile(cached_rc, config_cb); |
555 | |
558 | |
556 | /* If the cached configfile hasn't expired, lets exit now */ |
559 | /* If the cached configfile hasn't expired, lets exit now */ |
557 | age = time(NULL) - st.st_mtime; |
560 | age = time(NULL) - st.st_mtime; |
558 | if (age <= (ctx.cfg.cache_scanrc_ttl * 60)) |
561 | if (age <= (ctx.cfg.cache_scanrc_ttl * 60)) |
559 | return; |
562 | return; |
560 | |
563 | |
561 | /* The cached repolist has been parsed, but it was old. So lets |
564 | /* The cached repolist has been parsed, but it was old. So lets |
562 | * rescan the specified path and generate a new cached repolist |
565 | * rescan the specified path and generate a new cached repolist |
563 | * in a child-process to avoid latency for the current request. |
566 | * in a child-process to avoid latency for the current request. |
564 | */ |
567 | */ |
565 | if (fork()) |
568 | if (fork()) |
566 | return; |
569 | return; |
567 | |
570 | |
568 | exit(generate_cached_repolist(path, cached_rc)); |
571 | exit(generate_cached_repolist(path, cached_rc)); |
569 | } |
572 | } |
570 | |
573 | |
571 | static void cgit_parse_args(int argc, const char **argv) |
574 | static void cgit_parse_args(int argc, const char **argv) |
572 | { |
575 | { |
573 | int i; |
576 | int i; |
574 | int scan = 0; |
577 | int scan = 0; |
575 | |
578 | |
576 | for (i = 1; i < argc; i++) { |
579 | for (i = 1; i < argc; i++) { |
577 | if (!strncmp(argv[i], "--cache=", 8)) { |
580 | if (!strncmp(argv[i], "--cache=", 8)) { |
578 | ctx.cfg.cache_root = xstrdup(argv[i]+8); |
581 | ctx.cfg.cache_root = xstrdup(argv[i]+8); |
579 | } |
582 | } |
580 | if (!strcmp(argv[i], "--nocache")) { |
583 | if (!strcmp(argv[i], "--nocache")) { |
581 | ctx.cfg.nocache = 1; |
584 | ctx.cfg.nocache = 1; |
582 | } |
585 | } |
583 | if (!strcmp(argv[i], "--nohttp")) { |
586 | if (!strcmp(argv[i], "--nohttp")) { |
584 | ctx.env.no_http = "1"; |
587 | ctx.env.no_http = "1"; |
585 | } |
588 | } |
586 | if (!strncmp(argv[i], "--query=", 8)) { |
589 | if (!strncmp(argv[i], "--query=", 8)) { |
587 | ctx.qry.raw = xstrdup(argv[i]+8); |
590 | ctx.qry.raw = xstrdup(argv[i]+8); |
588 | } |
591 | } |
589 | if (!strncmp(argv[i], "--repo=", 7)) { |
592 | if (!strncmp(argv[i], "--repo=", 7)) { |
|
|
|
|
@@ -61,192 +61,200 @@ static void dec_month(struct tm *tm) |
61 | static void inc_month(struct tm *tm) |
61 | static void inc_month(struct tm *tm) |
62 | { |
62 | { |
63 | tm->tm_mon++; |
63 | tm->tm_mon++; |
64 | if (tm->tm_mon > 11) { |
64 | if (tm->tm_mon > 11) { |
65 | tm->tm_year++; |
65 | tm->tm_year++; |
66 | tm->tm_mon = 0; |
66 | tm->tm_mon = 0; |
67 | } |
67 | } |
68 | } |
68 | } |
69 | |
69 | |
70 | static char *pretty_month(struct tm *tm) |
70 | static char *pretty_month(struct tm *tm) |
71 | { |
71 | { |
72 | static const char *months[] = { |
72 | static const char *months[] = { |
73 | "Jan", "Feb", "Mar", "Apr", "May", "Jun", |
73 | "Jan", "Feb", "Mar", "Apr", "May", "Jun", |
74 | "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" |
74 | "Jul", "Aug", "Sep", "Oct", "Nov", "Dec" |
75 | }; |
75 | }; |
76 | return fmt("%s %d", months[tm->tm_mon], tm->tm_year + 1900); |
76 | return fmt("%s %d", months[tm->tm_mon], tm->tm_year + 1900); |
77 | } |
77 | } |
78 | |
78 | |
79 | static void trunc_quarter(struct tm *tm) |
79 | static void trunc_quarter(struct tm *tm) |
80 | { |
80 | { |
81 | trunc_month(tm); |
81 | trunc_month(tm); |
82 | while(tm->tm_mon % 3 != 0) |
82 | while(tm->tm_mon % 3 != 0) |
83 | dec_month(tm); |
83 | dec_month(tm); |
84 | } |
84 | } |
85 | |
85 | |
86 | static void dec_quarter(struct tm *tm) |
86 | static void dec_quarter(struct tm *tm) |
87 | { |
87 | { |
88 | dec_month(tm); |
88 | dec_month(tm); |
89 | dec_month(tm); |
89 | dec_month(tm); |
90 | dec_month(tm); |
90 | dec_month(tm); |
91 | } |
91 | } |
92 | |
92 | |
93 | static void inc_quarter(struct tm *tm) |
93 | static void inc_quarter(struct tm *tm) |
94 | { |
94 | { |
95 | inc_month(tm); |
95 | inc_month(tm); |
96 | inc_month(tm); |
96 | inc_month(tm); |
97 | inc_month(tm); |
97 | inc_month(tm); |
98 | } |
98 | } |
99 | |
99 | |
100 | static char *pretty_quarter(struct tm *tm) |
100 | static char *pretty_quarter(struct tm *tm) |
101 | { |
101 | { |
102 | return fmt("Q%d %d", tm->tm_mon / 3 + 1, tm->tm_year + 1900); |
102 | return fmt("Q%d %d", tm->tm_mon / 3 + 1, tm->tm_year + 1900); |
103 | } |
103 | } |
104 | |
104 | |
105 | static void trunc_year(struct tm *tm) |
105 | static void trunc_year(struct tm *tm) |
106 | { |
106 | { |
107 | trunc_month(tm); |
107 | trunc_month(tm); |
108 | tm->tm_mon = 0; |
108 | tm->tm_mon = 0; |
109 | } |
109 | } |
110 | |
110 | |
111 | static void dec_year(struct tm *tm) |
111 | static void dec_year(struct tm *tm) |
112 | { |
112 | { |
113 | tm->tm_year--; |
113 | tm->tm_year--; |
114 | } |
114 | } |
115 | |
115 | |
116 | static void inc_year(struct tm *tm) |
116 | static void inc_year(struct tm *tm) |
117 | { |
117 | { |
118 | tm->tm_year++; |
118 | tm->tm_year++; |
119 | } |
119 | } |
120 | |
120 | |
121 | static char *pretty_year(struct tm *tm) |
121 | static char *pretty_year(struct tm *tm) |
122 | { |
122 | { |
123 | return fmt("%d", tm->tm_year + 1900); |
123 | return fmt("%d", tm->tm_year + 1900); |
124 | } |
124 | } |
125 | |
125 | |
126 | struct cgit_period periods[] = { |
126 | struct cgit_period periods[] = { |
127 | {'w', "week", 12, 4, trunc_week, dec_week, inc_week, pretty_week}, |
127 | {'w', "week", 12, 4, trunc_week, dec_week, inc_week, pretty_week}, |
128 | {'m', "month", 12, 4, trunc_month, dec_month, inc_month, pretty_month}, |
128 | {'m', "month", 12, 4, trunc_month, dec_month, inc_month, pretty_month}, |
129 | {'q', "quarter", 12, 4, trunc_quarter, dec_quarter, inc_quarter, pretty_quarter}, |
129 | {'q', "quarter", 12, 4, trunc_quarter, dec_quarter, inc_quarter, pretty_quarter}, |
130 | {'y', "year", 12, 4, trunc_year, dec_year, inc_year, pretty_year}, |
130 | {'y', "year", 12, 4, trunc_year, dec_year, inc_year, pretty_year}, |
131 | }; |
131 | }; |
132 | |
132 | |
133 | /* Given a period code or name, return a period index (1, 2, 3 or 4) |
133 | /* Given a period code or name, return a period index (1, 2, 3 or 4) |
134 | * and update the period pointer to the correcsponding struct. |
134 | * and update the period pointer to the correcsponding struct. |
135 | * If no matching code is found, return 0. |
135 | * If no matching code is found, return 0. |
136 | */ |
136 | */ |
137 | int cgit_find_stats_period(const char *expr, struct cgit_period **period) |
137 | int cgit_find_stats_period(const char *expr, struct cgit_period **period) |
138 | { |
138 | { |
139 | int i; |
139 | int i; |
140 | char code = '\0'; |
140 | char code = '\0'; |
141 | |
141 | |
142 | if (!expr) |
142 | if (!expr) |
143 | return 0; |
143 | return 0; |
144 | |
144 | |
145 | if (strlen(expr) == 1) |
145 | if (strlen(expr) == 1) |
146 | code = expr[0]; |
146 | code = expr[0]; |
147 | |
147 | |
148 | for (i = 0; i < sizeof(periods) / sizeof(periods[0]); i++) |
148 | for (i = 0; i < sizeof(periods) / sizeof(periods[0]); i++) |
149 | if (periods[i].code == code || !strcmp(periods[i].name, expr)) { |
149 | if (periods[i].code == code || !strcmp(periods[i].name, expr)) { |
150 | if (period) |
150 | if (period) |
151 | *period = &periods[i]; |
151 | *period = &periods[i]; |
152 | return i+1; |
152 | return i+1; |
153 | } |
153 | } |
154 | return 0; |
154 | return 0; |
155 | } |
155 | } |
156 | |
156 | |
| |
157 | const char *cgit_find_stats_periodname(int idx) |
| |
158 | { |
| |
159 | if (idx > 0 && idx < 4) |
| |
160 | return periods[idx - 1].name; |
| |
161 | else |
| |
162 | return ""; |
| |
163 | } |
| |
164 | |
157 | static void add_commit(struct string_list *authors, struct commit *commit, |
165 | static void add_commit(struct string_list *authors, struct commit *commit, |
158 | struct cgit_period *period) |
166 | struct cgit_period *period) |
159 | { |
167 | { |
160 | struct commitinfo *info; |
168 | struct commitinfo *info; |
161 | struct string_list_item *author, *item; |
169 | struct string_list_item *author, *item; |
162 | struct authorstat *authorstat; |
170 | struct authorstat *authorstat; |
163 | struct string_list *items; |
171 | struct string_list *items; |
164 | char *tmp; |
172 | char *tmp; |
165 | struct tm *date; |
173 | struct tm *date; |
166 | time_t t; |
174 | time_t t; |
167 | |
175 | |
168 | info = cgit_parse_commit(commit); |
176 | info = cgit_parse_commit(commit); |
169 | tmp = xstrdup(info->author); |
177 | tmp = xstrdup(info->author); |
170 | author = string_list_insert(tmp, authors); |
178 | author = string_list_insert(tmp, authors); |
171 | if (!author->util) |
179 | if (!author->util) |
172 | author->util = xcalloc(1, sizeof(struct authorstat)); |
180 | author->util = xcalloc(1, sizeof(struct authorstat)); |
173 | else |
181 | else |
174 | free(tmp); |
182 | free(tmp); |
175 | authorstat = author->util; |
183 | authorstat = author->util; |
176 | items = &authorstat->list; |
184 | items = &authorstat->list; |
177 | t = info->committer_date; |
185 | t = info->committer_date; |
178 | date = gmtime(&t); |
186 | date = gmtime(&t); |
179 | period->trunc(date); |
187 | period->trunc(date); |
180 | tmp = xstrdup(period->pretty(date)); |
188 | tmp = xstrdup(period->pretty(date)); |
181 | item = string_list_insert(tmp, items); |
189 | item = string_list_insert(tmp, items); |
182 | if (item->util) |
190 | if (item->util) |
183 | free(tmp); |
191 | free(tmp); |
184 | item->util++; |
192 | item->util++; |
185 | authorstat->total++; |
193 | authorstat->total++; |
186 | cgit_free_commitinfo(info); |
194 | cgit_free_commitinfo(info); |
187 | } |
195 | } |
188 | |
196 | |
189 | static int cmp_total_commits(const void *a1, const void *a2) |
197 | static int cmp_total_commits(const void *a1, const void *a2) |
190 | { |
198 | { |
191 | const struct string_list_item *i1 = a1; |
199 | const struct string_list_item *i1 = a1; |
192 | const struct string_list_item *i2 = a2; |
200 | const struct string_list_item *i2 = a2; |
193 | const struct authorstat *auth1 = i1->util; |
201 | const struct authorstat *auth1 = i1->util; |
194 | const struct authorstat *auth2 = i2->util; |
202 | const struct authorstat *auth2 = i2->util; |
195 | |
203 | |
196 | return auth2->total - auth1->total; |
204 | return auth2->total - auth1->total; |
197 | } |
205 | } |
198 | |
206 | |
199 | /* Walk the commit DAG and collect number of commits per author per |
207 | /* Walk the commit DAG and collect number of commits per author per |
200 | * timeperiod into a nested string_list collection. |
208 | * timeperiod into a nested string_list collection. |
201 | */ |
209 | */ |
202 | struct string_list collect_stats(struct cgit_context *ctx, |
210 | struct string_list collect_stats(struct cgit_context *ctx, |
203 | struct cgit_period *period) |
211 | struct cgit_period *period) |
204 | { |
212 | { |
205 | struct string_list authors; |
213 | struct string_list authors; |
206 | struct rev_info rev; |
214 | struct rev_info rev; |
207 | struct commit *commit; |
215 | struct commit *commit; |
208 | const char *argv[] = {NULL, ctx->qry.head, NULL, NULL, NULL, NULL}; |
216 | const char *argv[] = {NULL, ctx->qry.head, NULL, NULL, NULL, NULL}; |
209 | int argc = 3; |
217 | int argc = 3; |
210 | time_t now; |
218 | time_t now; |
211 | long i; |
219 | long i; |
212 | struct tm *tm; |
220 | struct tm *tm; |
213 | char tmp[11]; |
221 | char tmp[11]; |
214 | |
222 | |
215 | time(&now); |
223 | time(&now); |
216 | tm = gmtime(&now); |
224 | tm = gmtime(&now); |
217 | period->trunc(tm); |
225 | period->trunc(tm); |
218 | for (i = 1; i < period->count; i++) |
226 | for (i = 1; i < period->count; i++) |
219 | period->dec(tm); |
227 | period->dec(tm); |
220 | strftime(tmp, sizeof(tmp), "%Y-%m-%d", tm); |
228 | strftime(tmp, sizeof(tmp), "%Y-%m-%d", tm); |
221 | argv[2] = xstrdup(fmt("--since=%s", tmp)); |
229 | argv[2] = xstrdup(fmt("--since=%s", tmp)); |
222 | if (ctx->qry.path) { |
230 | if (ctx->qry.path) { |
223 | argv[3] = "--"; |
231 | argv[3] = "--"; |
224 | argv[4] = ctx->qry.path; |
232 | argv[4] = ctx->qry.path; |
225 | argc += 2; |
233 | argc += 2; |
226 | } |
234 | } |
227 | init_revisions(&rev, NULL); |
235 | init_revisions(&rev, NULL); |
228 | rev.abbrev = DEFAULT_ABBREV; |
236 | rev.abbrev = DEFAULT_ABBREV; |
229 | rev.commit_format = CMIT_FMT_DEFAULT; |
237 | rev.commit_format = CMIT_FMT_DEFAULT; |
230 | rev.no_merges = 1; |
238 | rev.no_merges = 1; |
231 | rev.verbose_header = 1; |
239 | rev.verbose_header = 1; |
232 | rev.show_root_diff = 0; |
240 | rev.show_root_diff = 0; |
233 | setup_revisions(argc, argv, &rev, NULL); |
241 | setup_revisions(argc, argv, &rev, NULL); |
234 | prepare_revision_walk(&rev); |
242 | prepare_revision_walk(&rev); |
235 | memset(&authors, 0, sizeof(authors)); |
243 | memset(&authors, 0, sizeof(authors)); |
236 | while ((commit = get_revision(&rev)) != NULL) { |
244 | while ((commit = get_revision(&rev)) != NULL) { |
237 | add_commit(&authors, commit, period); |
245 | add_commit(&authors, commit, period); |
238 | free(commit->buffer); |
246 | free(commit->buffer); |
239 | free_commit_list(commit->parents); |
247 | free_commit_list(commit->parents); |
240 | } |
248 | } |
241 | return authors; |
249 | return authors; |
242 | } |
250 | } |
243 | |
251 | |
244 | void print_combined_authorrow(struct string_list *authors, int from, int to, |
252 | void print_combined_authorrow(struct string_list *authors, int from, int to, |
245 | const char *name, const char *leftclass, const char *centerclass, |
253 | const char *name, const char *leftclass, const char *centerclass, |
246 | const char *rightclass, struct cgit_period *period) |
254 | const char *rightclass, struct cgit_period *period) |
247 | { |
255 | { |
248 | struct string_list_item *author; |
256 | struct string_list_item *author; |
249 | struct authorstat *authorstat; |
257 | struct authorstat *authorstat; |
250 | struct string_list *items; |
258 | struct string_list *items; |
251 | struct string_list_item *date; |
259 | struct string_list_item *date; |
252 | time_t now; |
260 | time_t now; |
|
|
|
|
@@ -1,27 +1,28 @@ |
1 | #ifndef UI_STATS_H |
1 | #ifndef UI_STATS_H |
2 | #define UI_STATS_H |
2 | #define UI_STATS_H |
3 | |
3 | |
4 | #include "cgit.h" |
4 | #include "cgit.h" |
5 | |
5 | |
6 | struct cgit_period { |
6 | struct cgit_period { |
7 | const char code; |
7 | const char code; |
8 | const char *name; |
8 | const char *name; |
9 | int max_periods; |
9 | int max_periods; |
10 | int count; |
10 | int count; |
11 | |
11 | |
12 | /* Convert a tm value to the first day in the period */ |
12 | /* Convert a tm value to the first day in the period */ |
13 | void (*trunc)(struct tm *tm); |
13 | void (*trunc)(struct tm *tm); |
14 | |
14 | |
15 | /* Update tm value to start of next/previous period */ |
15 | /* Update tm value to start of next/previous period */ |
16 | void (*dec)(struct tm *tm); |
16 | void (*dec)(struct tm *tm); |
17 | void (*inc)(struct tm *tm); |
17 | void (*inc)(struct tm *tm); |
18 | |
18 | |
19 | /* Pretty-print a tm value */ |
19 | /* Pretty-print a tm value */ |
20 | char *(*pretty)(struct tm *tm); |
20 | char *(*pretty)(struct tm *tm); |
21 | }; |
21 | }; |
22 | |
22 | |
23 | extern int cgit_find_stats_period(const char *expr, struct cgit_period **period); |
23 | extern int cgit_find_stats_period(const char *expr, struct cgit_period **period); |
| |
24 | extern const char *cgit_find_stats_periodname(int idx); |
24 | |
25 | |
25 | extern void cgit_show_stats(struct cgit_context *ctx); |
26 | extern void cgit_show_stats(struct cgit_context *ctx); |
26 | |
27 | |
27 | #endif /* UI_STATS_H */ |
28 | #endif /* UI_STATS_H */ |
|