1#include "refs.h"
2#include "cache.h"
3#include <errno.h>
5struct ref_list {
7 struct ref_list *next;
8 unsigned char flag; /* ISSYMREF? ISPACKED? */
9 unsigned char sha1[20];
10 char name[FLEX_ARRAY];
11};
12static const char *parse_ref_line(char *line, unsigned char *sha1)
14{
15 /*
16 * 42: the answer to everything.
17 *
18 * In this case, it happens to be the answer to
19 * 40 (length of sha1 hex representation)
20 * +1 (space in between hex and name)
21 * +1 (newline at the end of the line)
22 */
23 int len = strlen(line) - 42;
24 if (len <= 0)
26 return NULL;
27 if (get_sha1_hex(line, sha1) < 0)
28 return NULL;
29 if (!isspace(line[40]))
30 return NULL;
31 line += 41;
32 if (isspace(*line))
33 return NULL;
34 if (line[len] != '\n')
35 return NULL;
36 line[len] = 0;
37 return line;
38}
39static struct ref_list *add_ref(const char *name, const unsigned char *sha1,
41 int flag, struct ref_list *list)
42{
43 int len;
44 struct ref_list **p = &list, *entry;
45 /* Find the place to insert the ref into.. */
47 while ((entry = *p) != NULL) {
48 int cmp = strcmp(entry->name, name);
49 if (cmp > 0)
50 break;
51 /* Same as existing entry? */
53 if (!cmp)
54 return list;
55 p = &entry->next;
56 }
57 /* Allocate it and add it in.. */
59 len = strlen(name) + 1;
60 entry = xmalloc(sizeof(struct ref_list) + len);
61 hashcpy(entry->sha1, sha1);
62 memcpy(entry->name, name, len);
63 entry->flag = flag;
64 entry->next = *p;
65 *p = entry;
66 return list;
67}
68/*
70 * Future: need to be in "struct repository"
71 * when doing a full libification.
72 */
73struct cached_refs {
74 char did_loose;
75 char did_packed;
76 struct ref_list *loose;
77 struct ref_list *packed;
78} cached_refs;
79static void free_ref_list(struct ref_list *list)
81{
82 struct ref_list *next;
83 for ( ; list; list = next) {
84 next = list->next;
85 free(list);
86 }
87}
88static void invalidate_cached_refs(void)
90{
91 struct cached_refs *ca = &cached_refs;
92 if (ca->did_loose && ca->loose)
94 free_ref_list(ca->loose);
95 if (ca->did_packed && ca->packed)
96 free_ref_list(ca->packed);
97 ca->loose = ca->packed = NULL;
98 ca->did_loose = ca->did_packed = 0;
99}
100static struct ref_list *get_packed_refs(void)
102{
103 if (!cached_refs.did_packed) {
104 struct ref_list *refs = NULL;
105 FILE *f = fopen(git_path("packed-refs"), "r");
106 if (f) {
107 struct ref_list *list = NULL;
108 char refline[PATH_MAX];
109 while (fgets(refline, sizeof(refline), f)) {
110 unsigned char sha1[20];
111 const char *name = parse_ref_line(refline, sha1);
112 if (!name)
113 continue;
114 list = add_ref(name, sha1, REF_ISPACKED, list);
115 }
116 fclose(f);
117 refs = list;
118 }
119 cached_refs.packed = refs;
120 cached_refs.did_packed = 1;
121 }
122 return cached_refs.packed;
123}
124static struct ref_list *get_ref_dir(const char *base, struct ref_list *list)
126{
127 DIR *dir = opendir(git_path("%s", base));
128 if (dir) {
130 struct dirent *de;
131 int baselen = strlen(base);
132 char *ref = xmalloc(baselen + 257);
133 memcpy(ref, base, baselen);
135 if (baselen && base[baselen-1] != '/')
136 ref[baselen++] = '/';
137 while ((de = readdir(dir)) != NULL) {
139 unsigned char sha1[20];
140 struct stat st;
141 int flag;
142 int namelen;
143 if (de->d_name[0] == '.')
145 continue;
146 namelen = strlen(de->d_name);
147 if (namelen > 255)
148 continue;
149 if (has_extension(de->d_name, ".lock"))
150 continue;
151 memcpy(ref + baselen, de->d_name, namelen+1);
152 if (stat(git_path("%s", ref), &st) < 0)
153 continue;
154 if (S_ISDIR(st.st_mode)) {
155 list = get_ref_dir(ref, list);
156 continue;
157 }
158 if (!resolve_ref(ref, sha1, 1, &flag)) {
159 error("%s points nowhere!", ref);
160 continue;
161 }
162 list = add_ref(ref, sha1, flag, list);
163 }
164 free(ref);
165 closedir(dir);
166 }
167 return list;
168}
169static struct ref_list *get_loose_refs(void)
171{
172 if (!cached_refs.did_loose) {
173 cached_refs.loose = get_ref_dir("refs", NULL);
174 cached_refs.did_loose = 1;
175 }
176 return cached_refs.loose;
177}
178/* We allow "recursive" symbolic refs. Only within reason, though */
180#define MAXDEPTH 5
181const char *resolve_ref(const char *ref, unsigned char *sha1, int reading, int *flag)
183{
184 int depth = MAXDEPTH, len;
185 char buffer[256];
186 static char ref_buffer[256];
187 if (flag)
189 *flag = 0;
190 for (;;) {
192 const char *path = git_path("%s", ref);
193 struct stat st;
194 char *buf;
195 int fd;
196 if (--depth < 0)
198 return NULL;
199 /* Special case: non-existing file.
201 * Not having the refs/heads/new-branch is OK
202 * if we are writing into it, so is .git/HEAD
203 * that points at refs/heads/master still to be
204 * born. It is NOT OK if we are resolving for
205 * reading.
206 */
207 if (lstat(path, &st) < 0) {
208 struct ref_list *list = get_packed_refs();
209 while (list) {
210 if (!strcmp(ref, list->name)) {
211 hashcpy(sha1, list->sha1);
212 if (flag)
213 *flag |= REF_ISPACKED;
214 return ref;
215 }
216 list = list->next;
217 }
218 if (reading || errno != ENOENT)
219 return NULL;
220 hashclr(sha1);
221 return ref;
222 }
223 /* Follow "normalized" - ie "refs/.." symlinks by hand */
225 if (S_ISLNK(st.st_mode)) {
226 len = readlink(path, buffer, sizeof(buffer)-1);
227 if (len >= 5 && !memcmp("refs/", buffer, 5)) {
228 buffer[len] = 0;
229 strcpy(ref_buffer, buffer);
230 ref = ref_buffer;
231 if (flag)
232 *flag |= REF_ISSYMREF;
233 continue;
234 }
235 }
236 /*
238 * Anything else, just open it and try to use it as
239 * a ref
240 */
241 fd = open(path, O_RDONLY);
242 if (fd < 0)
243 return NULL;
244 len = read(fd, buffer, sizeof(buffer)-1);
245 close(fd);
246 /*
248 * Is it a symbolic ref?
249 */
250 if (len < 4 || memcmp("ref:", buffer, 4))
251 break;
252 buf = buffer + 4;
253 len -= 4;
254 while (len && isspace(*buf))
255 buf++, len--;
256 while (len && isspace(buf[len-1]))
257 len--;
258 buf[len] = 0;
259 memcpy(ref_buffer, buf, len + 1);
260 ref = ref_buffer;
261 if (flag)
262 *flag |= REF_ISSYMREF;
263 }
264 if (len < 40 || get_sha1_hex(buffer, sha1))
265 return NULL;
266 return ref;
267}
268int create_symref(const char *ref_target, const char *refs_heads_master)
270{
271 const char *lockpath;
272 char ref[1000];
273 int fd, len, written;
274 const char *git_HEAD = git_path("%s", ref_target);
275#ifndef NO_SYMLINK_HEAD
277 if (prefer_symlink_refs) {
278 unlink(git_HEAD);
279 if (!symlink(refs_heads_master, git_HEAD))
280 return 0;
281 fprintf(stderr, "no symlink - falling back to symbolic ref\n");
282 }
283#endif
284 len = snprintf(ref, sizeof(ref), "ref: %s\n", refs_heads_master);
286 if (sizeof(ref) <= len) {
287 error("refname too long: %s", refs_heads_master);
288 return -1;
289 }
290 lockpath = mkpath("%s.lock", git_HEAD);
291 fd = open(lockpath, O_CREAT | O_EXCL | O_WRONLY, 0666);
292 written = write(fd, ref, len);
293 close(fd);
294 if (written != len) {
295 unlink(lockpath);
296 error("Unable to write to %s", lockpath);
297 return -2;
298 }
299 if (rename(lockpath, git_HEAD) < 0) {
300 unlink(lockpath);
301 error("Unable to create %s", git_HEAD);
302 return -3;
303 }
304 if (adjust_shared_perm(git_HEAD)) {
305 unlink(lockpath);
306 error("Unable to fix permissions on %s", lockpath);
307 return -4;
308 }
309 return 0;
310}
311int read_ref(const char *ref, unsigned char *sha1)
313{
314 if (resolve_ref(ref, sha1, 1, NULL))
315 return 0;
316 return -1;
317}
318static int do_for_each_ref(const char *base, each_ref_fn fn, int trim,
320 void *cb_data)
321{
322 int retval;
323 struct ref_list *packed = get_packed_refs();
324 struct ref_list *loose = get_loose_refs();
325 while (packed && loose) {
327 struct ref_list *entry;
328 int cmp = strcmp(packed->name, loose->name);
329 if (!cmp) {
330 packed = packed->next;
331 continue;
332 }
333 if (cmp > 0) {
334 entry = loose;
335 loose = loose->next;
336 } else {
337 entry = packed;
338 packed = packed->next;
339 }
340 if (strncmp(base, entry->name, trim))
341 continue;
342 if (is_null_sha1(entry->sha1))
343 continue;
344 if (!has_sha1_file(entry->sha1)) {
345 error("%s does not point to a valid object!", entry->name);
346 continue;
347 }
348 retval = fn(entry->name + trim, entry->sha1,
349 entry->flag, cb_data);
350 if (retval)
351 return retval;
352 }
353 packed = packed ? packed : loose;
355 while (packed) {
356 if (!strncmp(base, packed->name, trim)) {
357 retval = fn(packed->name + trim, packed->sha1,
358 packed->flag, cb_data);
359 if (retval)
360 return retval;
361 }
362 packed = packed->next;
363 }
364 return 0;
365}
366int head_ref(each_ref_fn fn, void *cb_data)
368{
369 unsigned char sha1[20];
370 int flag;
371 if (resolve_ref("HEAD", sha1, 1, &flag))
373 return fn("HEAD", sha1, flag, cb_data);
374 return 0;
375}
376int for_each_ref(each_ref_fn fn, void *cb_data)
378{
379 return do_for_each_ref("refs/", fn, 0, cb_data);
380}
381int for_each_tag_ref(each_ref_fn fn, void *cb_data)
383{
384 return do_for_each_ref("refs/tags/", fn, 10, cb_data);
385}
386int for_each_branch_ref(each_ref_fn fn, void *cb_data)
388{
389 return do_for_each_ref("refs/heads/", fn, 11, cb_data);
390}
391int for_each_remote_ref(each_ref_fn fn, void *cb_data)
393{
394 return do_for_each_ref("refs/remotes/", fn, 13, cb_data);
395}
396/* NEEDSWORK: This is only used by ssh-upload and it should go; the
398 * caller should do resolve_ref or read_ref like everybody else. Or
399 * maybe everybody else should use get_ref_sha1() instead of doing
400 * read_ref().
401 */
402int get_ref_sha1(const char *ref, unsigned char *sha1)
403{
404 if (check_ref_format(ref))
405 return -1;
406 return read_ref(mkpath("refs/%s", ref), sha1);
407}
408/*
410 * Make sure "ref" is something reasonable to have under ".git/refs/";
411 * We do not like it if:
412 *
413 * - any path component of it begins with ".", or
414 * - it has double dots "..", or
415 * - it has ASCII control character, "~", "^", ":" or SP, anywhere, or
416 * - it ends with a "/".
417 */
418static inline int bad_ref_char(int ch)
420{
421 return (((unsigned) ch) <= ' ' ||
422 ch == '~' || ch == '^' || ch == ':' ||
423 /* 2.13 Pattern Matching Notation */
424 ch == '?' || ch == '*' || ch == '[');
425}
426int check_ref_format(const char *ref)
428{
429 int ch, level;
430 const char *cp = ref;
431 level = 0;
433 while (1) {
434 while ((ch = *cp++) == '/')
435 ; /* tolerate duplicated slashes */
436 if (!ch)
437 return -1; /* should not end with slashes */
438 /* we are at the beginning of the path component */
440 if (ch == '.' || bad_ref_char(ch))
441 return -1;
442 /* scan the rest of the path component */
444 while ((ch = *cp++) != 0) {
445 if (bad_ref_char(ch))
446 return -1;
447 if (ch == '/')
448 break;
449 if (ch == '.' && *cp == '.')
450 return -1;
451 }
452 level++;
453 if (!ch) {
454 if (level < 2)
455 return -1; /* at least of form "heads/blah" */
456 return 0;
457 }
458 }
459}
460static struct ref_lock *verify_lock(struct ref_lock *lock,
462 const unsigned char *old_sha1, int mustexist)
463{
464 if (!resolve_ref(lock->ref_name, lock->old_sha1, mustexist, NULL)) {
465 error("Can't verify ref %s", lock->ref_name);
466 unlock_ref(lock);
467 return NULL;
468 }
469 if (hashcmp(lock->old_sha1, old_sha1)) {
470 error("Ref %s is at %s but expected %s", lock->ref_name,
471 sha1_to_hex(lock->old_sha1), sha1_to_hex(old_sha1));
472 unlock_ref(lock);
473 return NULL;
474 }
475 return lock;
476}
477static int remove_empty_dir_recursive(char *path, int len)
479{
480 DIR *dir = opendir(path);
481 struct dirent *e;
482 int ret = 0;
483 if (!dir)
485 return -1;
486 if (path[len-1] != '/')
487 path[len++] = '/';
488 while ((e = readdir(dir)) != NULL) {
489 struct stat st;
490 int namlen;
491 if ((e->d_name[0] == '.') &&
492 ((e->d_name[1] == 0) ||
493 ((e->d_name[1] == '.') && e->d_name[2] == 0)))
494 continue; /* "." and ".." */
495 namlen = strlen(e->d_name);
497 if ((len + namlen < PATH_MAX) &&
498 strcpy(path + len, e->d_name) &&
499 !lstat(path, &st) &&
500 S_ISDIR(st.st_mode) &&
501 !remove_empty_dir_recursive(path, len + namlen))
502 continue; /* happy */
503 /* path too long, stat fails, or non-directory still exists */
505 ret = -1;
506 break;
507 }
508 closedir(dir);
509 if (!ret) {
510 path[len] = 0;
511 ret = rmdir(path);
512 }
513 return ret;
514}
515static int remove_empty_directories(char *file)
517{
518 /* we want to create a file but there is a directory there;
519 * if that is an empty directory (or a directory that contains
520 * only empty directories), remove them.
521 */
522 char path[PATH_MAX];
523 int len = strlen(file);
524 if (len >= PATH_MAX) /* path too long ;-) */
526 return -1;
527 strcpy(path, file);
528 return remove_empty_dir_recursive(path, len);
529}
530static struct ref_lock *lock_ref_sha1_basic(const char *ref, const unsigned char *old_sha1, int *flag)
532{
533 char *ref_file;
534 const char *orig_ref = ref;
535 struct ref_lock *lock;
536 struct stat st;
537 int last_errno = 0;
538 int mustexist = (old_sha1 && !is_null_sha1(old_sha1));
539 lock = xcalloc(1, sizeof(struct ref_lock));
541 lock->lock_fd = -1;
542 ref = resolve_ref(ref, lock->old_sha1, mustexist, flag);
544 if (!ref && errno == EISDIR) {
545 /* we are trying to lock foo but we used to
546 * have foo/bar which now does not exist;
547 * it is normal for the empty directory 'foo'
548 * to remain.
549 */
550 ref_file = git_path("%s", orig_ref);
551 if (remove_empty_directories(ref_file)) {
552 last_errno = errno;
553 error("there are still refs under '%s'", orig_ref);
554 goto error_return;
555 }
556 ref = resolve_ref(orig_ref, lock->old_sha1, mustexist, flag);
557 }
558 if (!ref) {
559 last_errno = errno;
560 error("unable to resolve reference %s: %s",
561 orig_ref, strerror(errno));
562 goto error_return;
563 }
564 if (is_null_sha1(lock->old_sha1)) {
565 /* The ref did not exist and we are creating it.
566 * Make sure there is no existing ref that is packed
567 * whose name begins with our refname, nor a ref whose
568 * name is a proper prefix of our refname.
569 */
570 int namlen = strlen(ref); /* e.g. 'foo/bar' */
571 struct ref_list *list = get_packed_refs();
572 while (list) {
573 /* list->name could be 'foo' or 'foo/bar/baz' */
574 int len = strlen(list->name);
575 int cmplen = (namlen < len) ? namlen : len;
576 const char *lead = (namlen < len) ? list->name : ref;
577 if (!strncmp(ref, list->name, cmplen) &&
579 lead[cmplen] == '/') {
580 error("'%s' exists; cannot create '%s'",
581 list->name, ref);
582 goto error_return;
583 }
584 list = list->next;
585 }
586 }
587 lock->lk = xcalloc(1, sizeof(struct lock_file));
589 lock->ref_name = xstrdup(ref);
591 lock->log_file = xstrdup(git_path("logs/%s", ref));
592 ref_file = git_path("%s", ref);
593 lock->force_write = lstat(ref_file, &st) && errno == ENOENT;
594 if (safe_create_leading_directories(ref_file)) {
596 last_errno = errno;
597 error("unable to create directory for %s", ref_file);
598 goto error_return;
599 }
600 lock->lock_fd = hold_lock_file_for_update(lock->lk, ref_file, 1);
601 return old_sha1 ? verify_lock(lock, old_sha1, mustexist) : lock;
603 error_return:
605 unlock_ref(lock);
606 errno = last_errno;
607 return NULL;
608}
609struct ref_lock *lock_ref_sha1(const char *ref, const unsigned char *old_sha1)
611{
612 char refpath[PATH_MAX];
613 if (check_ref_format(ref))
614 return NULL;
615 strcpy(refpath, mkpath("refs/%s", ref));
616 return lock_ref_sha1_basic(refpath, old_sha1, NULL);
617}
618struct ref_lock *lock_any_ref_for_update(const char *ref, const unsigned char *old_sha1)
620{
621 return lock_ref_sha1_basic(ref, old_sha1, NULL);
622}
623static struct lock_file packlock;
625static int repack_without_ref(const char *refname)
627{
628 struct ref_list *list, *packed_ref_list;
629 int fd;
630 int found = 0;
631 packed_ref_list = get_packed_refs();
633 for (list = packed_ref_list; list; list = list->next) {
634 if (!strcmp(refname, list->name)) {
635 found = 1;
636 break;
637 }
638 }
639 if (!found)
640 return 0;
641 memset(&packlock, 0, sizeof(packlock));
642 fd = hold_lock_file_for_update(&packlock, git_path("packed-refs"), 0);
643 if (fd < 0)
644 return error("cannot delete '%s' from packed refs", refname);
645 for (list = packed_ref_list; list; list = list->next) {
647 char line[PATH_MAX + 100];
648 int len;
649 if (!strcmp(refname, list->name))
651 continue;
652 len = snprintf(line, sizeof(line), "%s %s\n",
653 sha1_to_hex(list->sha1), list->name);
654 /* this should not happen but just being defensive */
655 if (len > sizeof(line))
656 die("too long a refname '%s'", list->name);
657 write_or_die(fd, line, len);
658 }
659 return commit_lock_file(&packlock);
660}
661int delete_ref(const char *refname, unsigned char *sha1)
663{
664 struct ref_lock *lock;
665 int err, i, ret = 0, flag = 0;
666 lock = lock_ref_sha1_basic(refname, sha1, &flag);
668 if (!lock)
669 return 1;
670 if (!(flag & REF_ISPACKED)) {
671 /* loose */
672 i = strlen(lock->lk->filename) - 5; /* .lock */
673 lock->lk->filename[i] = 0;
674 err = unlink(lock->lk->filename);
675 if (err) {
676 ret = 1;
677 error("unlink(%s) failed: %s",
678 lock->lk->filename, strerror(errno));
679 }
680 lock->lk->filename[i] = '.';
681 }
682 /* removing the loose one could have resurrected an earlier
683 * packed one. Also, if it was not loose we need to repack
684 * without it.
685 */
686 ret |= repack_without_ref(refname);
687 err = unlink(lock->log_file);
689 if (err && errno != ENOENT)
690 fprintf(stderr, "warning: unlink(%s) failed: %s",
691 lock->log_file, strerror(errno));
692 invalidate_cached_refs();
693 unlock_ref(lock);
694 return ret;
695}
696void unlock_ref(struct ref_lock *lock)
698{
699 if (lock->lock_fd >= 0) {
700 close(lock->lock_fd);
701 /* Do not free lock->lk -- atexit() still looks at them */
702 if (lock->lk)
703 rollback_lock_file(lock->lk);
704 }
705 free(lock->ref_name);
706 free(lock->log_file);
707 free(lock);
708}
709static int log_ref_write(struct ref_lock *lock,
711 const unsigned char *sha1, const char *msg)
712{
713 int logfd, written, oflags = O_APPEND | O_WRONLY;
714 unsigned maxlen, len;
715 char *logrec;
716 const char *committer;
717 if (log_all_ref_updates) {
719 if (safe_create_leading_directories(lock->log_file) < 0)
720 return error("unable to create directory for %s",
721 lock->log_file);
722 oflags |= O_CREAT;
723 }
724 logfd = open(lock->log_file, oflags, 0666);
726 if (logfd < 0) {
727 if (!log_all_ref_updates && errno == ENOENT)
728 return 0;
729 return error("Unable to append to %s: %s",
730 lock->log_file, strerror(errno));
731 }
732 committer = git_committer_info(1);
734 if (msg) {
735 maxlen = strlen(committer) + strlen(msg) + 2*40 + 5;
736 logrec = xmalloc(maxlen);
737 len = snprintf(logrec, maxlen, "%s %s %s\t%s\n",
738 sha1_to_hex(lock->old_sha1),
739 sha1_to_hex(sha1),
740 committer,
741 msg);
742 }
743 else {
744 maxlen = strlen(committer) + 2*40 + 4;
745 logrec = xmalloc(maxlen);
746 len = snprintf(logrec, maxlen, "%s %s %s\n",
747 sha1_to_hex(lock->old_sha1),
748 sha1_to_hex(sha1),
749 committer);
750 }
751 written = len <= maxlen ? write(logfd, logrec, len) : -1;
752 free(logrec);
753 close(logfd);
754 if (written != len)
755 return error("Unable to append to %s", lock->log_file);
756 return 0;
757}
758int write_ref_sha1(struct ref_lock *lock,
760 const unsigned char *sha1, const char *logmsg)
761{
762 static char term = '\n';
763 if (!lock)
765 return -1;
766 if (!lock->force_write && !hashcmp(lock->old_sha1, sha1)) {
767 unlock_ref(lock);
768 return 0;
769 }
770 if (write(lock->lock_fd, sha1_to_hex(sha1), 40) != 40 ||
771 write(lock->lock_fd, &term, 1) != 1
772 || close(lock->lock_fd) < 0) {
773 error("Couldn't write %s", lock->lk->filename);
774 unlock_ref(lock);
775 return -1;
776 }
777 invalidate_cached_refs();
778 if (log_ref_write(lock, sha1, logmsg) < 0) {
779 unlock_ref(lock);
780 return -1;
781 }
782 if (commit_lock_file(lock->lk)) {
783 error("Couldn't set %s", lock->ref_name);
784 unlock_ref(lock);
785 return -1;
786 }
787 lock->lock_fd = -1;
788 unlock_ref(lock);
789 return 0;
790}
791int read_ref_at(const char *ref, unsigned long at_time, unsigned char *sha1)
793{
794 const char *logfile, *logdata, *logend, *rec, *lastgt, *lastrec;
795 char *tz_c;
796 int logfd, tz;
797 struct stat st;
798 unsigned long date;
799 unsigned char logged_sha1[20];
800 logfile = git_path("logs/%s", ref);
802 logfd = open(logfile, O_RDONLY, 0);
803 if (logfd < 0)
804 die("Unable to read log %s: %s", logfile, strerror(errno));
805 fstat(logfd, &st);
806 if (!st.st_size)
807 die("Log %s is empty.", logfile);
808 logdata = mmap(NULL, st.st_size, PROT_READ, MAP_PRIVATE, logfd, 0);
809 close(logfd);
810 lastrec = NULL;
812 rec = logend = logdata + st.st_size;
813 while (logdata < rec) {
814 if (logdata < rec && *(rec-1) == '\n')
815 rec--;
816 lastgt = NULL;
817 while (logdata < rec && *(rec-1) != '\n') {
818 rec--;
819 if (*rec == '>')
820 lastgt = rec;
821 }
822 if (!lastgt)
823 die("Log %s is corrupt.", logfile);
824 date = strtoul(lastgt + 1, &tz_c, 10);
825 if (date <= at_time) {
826 if (lastrec) {
827 if (get_sha1_hex(lastrec, logged_sha1))
828 die("Log %s is corrupt.", logfile);
829 if (get_sha1_hex(rec + 41, sha1))
830 die("Log %s is corrupt.", logfile);
831 if (hashcmp(logged_sha1, sha1)) {
832 tz = strtoul(tz_c, NULL, 10);
833 fprintf(stderr,
834 "warning: Log %s has gap after %s.\n",
835 logfile, show_rfc2822_date(date, tz));
836 }
837 }
838 else if (date == at_time) {
839 if (get_sha1_hex(rec + 41, sha1))
840 die("Log %s is corrupt.", logfile);
841 }
842 else {
843 if (get_sha1_hex(rec + 41, logged_sha1))
844 die("Log %s is corrupt.", logfile);
845 if (hashcmp(logged_sha1, sha1)) {
846 tz = strtoul(tz_c, NULL, 10);
847 fprintf(stderr,
848 "warning: Log %s unexpectedly ended on %s.\n",
849 logfile, show_rfc2822_date(date, tz));
850 }
851 }
852 munmap((void*)logdata, st.st_size);
853 return 0;
854 }
855 lastrec = rec;
856 }
857 rec = logdata;
859 while (rec < logend && *rec != '>' && *rec != '\n')
860 rec++;
861 if (rec == logend || *rec == '\n')
862 die("Log %s is corrupt.", logfile);
863 date = strtoul(rec + 1, &tz_c, 10);
864 tz = strtoul(tz_c, NULL, 10);
865 if (get_sha1_hex(logdata, sha1))
866 die("Log %s is corrupt.", logfile);
867 munmap((void*)logdata, st.st_size);
868 fprintf(stderr, "warning: Log %s only goes back to %s.\n",
869 logfile, show_rfc2822_date(date, tz));
870 return 0;
871}