]>
Commit | Line | Data |
---|---|---|
021b6e45 JH |
1 | /* |
2 | * Copyright (c) 2005, Junio C Hamano | |
3 | */ | |
021b6e45 JH |
4 | #include "cache.h" |
5 | ||
6 | static struct lock_file *lock_file_list; | |
5e7f56ac | 7 | static const char *alternate_index_output; |
021b6e45 JH |
8 | |
9 | static void remove_lock_file(void) | |
10 | { | |
5e635e39 JH |
11 | pid_t me = getpid(); |
12 | ||
021b6e45 | 13 | while (lock_file_list) { |
5e635e39 JH |
14 | if (lock_file_list->owner == me && |
15 | lock_file_list->filename[0]) | |
021b6e45 JH |
16 | unlink(lock_file_list->filename); |
17 | lock_file_list = lock_file_list->next; | |
18 | } | |
19 | } | |
20 | ||
21 | static void remove_lock_file_on_signal(int signo) | |
22 | { | |
23 | remove_lock_file(); | |
24 | signal(SIGINT, SIG_DFL); | |
25 | raise(signo); | |
26 | } | |
27 | ||
40aaae88 | 28 | static int lock_file(struct lock_file *lk, const char *path) |
021b6e45 JH |
29 | { |
30 | int fd; | |
31 | sprintf(lk->filename, "%s.lock", path); | |
32 | fd = open(lk->filename, O_RDWR | O_CREAT | O_EXCL, 0666); | |
138086a7 | 33 | if (0 <= fd) { |
5e635e39 | 34 | lk->owner = getpid(); |
1084b845 | 35 | if (!lk->on_list) { |
138086a7 JH |
36 | lk->next = lock_file_list; |
37 | lock_file_list = lk; | |
1084b845 JH |
38 | lk->on_list = 1; |
39 | } | |
40 | if (lock_file_list) { | |
138086a7 JH |
41 | signal(SIGINT, remove_lock_file_on_signal); |
42 | atexit(remove_lock_file); | |
43 | } | |
44 | if (adjust_shared_perm(lk->filename)) | |
45 | return error("cannot fix permission bits on %s", | |
46 | lk->filename); | |
021b6e45 | 47 | } |
1084b845 JH |
48 | else |
49 | lk->filename[0] = 0; | |
021b6e45 JH |
50 | return fd; |
51 | } | |
52 | ||
40aaae88 JH |
53 | int hold_lock_file_for_update(struct lock_file *lk, const char *path, int die_on_error) |
54 | { | |
55 | int fd = lock_file(lk, path); | |
56 | if (fd < 0 && die_on_error) | |
f9e8a43a | 57 | die("unable to create '%s.lock': %s", path, strerror(errno)); |
40aaae88 JH |
58 | return fd; |
59 | } | |
60 | ||
021b6e45 JH |
61 | int commit_lock_file(struct lock_file *lk) |
62 | { | |
63 | char result_file[PATH_MAX]; | |
64 | int i; | |
65 | strcpy(result_file, lk->filename); | |
66 | i = strlen(result_file) - 5; /* .lock */ | |
67 | result_file[i] = 0; | |
68 | i = rename(lk->filename, result_file); | |
69 | lk->filename[0] = 0; | |
70 | return i; | |
71 | } | |
72 | ||
30ca07a2 JH |
73 | int hold_locked_index(struct lock_file *lk, int die_on_error) |
74 | { | |
75 | return hold_lock_file_for_update(lk, get_index_file(), die_on_error); | |
76 | } | |
77 | ||
5e7f56ac JH |
78 | void set_alternate_index_output(const char *name) |
79 | { | |
80 | alternate_index_output = name; | |
81 | } | |
82 | ||
30ca07a2 JH |
83 | int commit_locked_index(struct lock_file *lk) |
84 | { | |
5e7f56ac JH |
85 | if (alternate_index_output) { |
86 | int result = rename(lk->filename, alternate_index_output); | |
30ca07a2 JH |
87 | lk->filename[0] = 0; |
88 | return result; | |
89 | } | |
90 | else | |
91 | return commit_lock_file(lk); | |
92 | } | |
93 | ||
021b6e45 JH |
94 | void rollback_lock_file(struct lock_file *lk) |
95 | { | |
96 | if (lk->filename[0]) | |
97 | unlink(lk->filename); | |
98 | lk->filename[0] = 0; | |
99 | } |