|
diff --git a/cgit.c b/cgit.c index b0e202e..93a7a69 100644 --- a/ cgit.c+++ b/ cgit.c |
|
@@ -430,128 +430,131 @@ static void process_request(void *cbdata) |
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; |
|
|
|
|
@@ -93,128 +93,136 @@ static void dec_quarter(struct tm *tm) |
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); |
|
|
|
|
@@ -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 */ |
|