Print this page
make: unifdef SUN5_0 (defined)
| Split |
Close |
| Expand all |
| Collapse all |
--- old/usr/src/cmd/make/lib/vroot/lock.cc
+++ new/usr/src/cmd/make/lib/vroot/lock.cc
1 1 /*
2 2 * CDDL HEADER START
3 3 *
4 4 * The contents of this file are subject to the terms of the
5 5 * Common Development and Distribution License (the "License").
6 6 * You may not use this file except in compliance with the License.
7 7 *
8 8 * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9 9 * or http://www.opensolaris.org/os/licensing.
10 10 * See the License for the specific language governing permissions
11 11 * and limitations under the License.
12 12 *
13 13 * When distributing Covered Code, include this CDDL HEADER in each
14 14 * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15 15 * If applicable, add the following below this CDDL HEADER, with the
16 16 * fields enclosed by brackets "[]" replaced with your own identifying
17 17 * information: Portions Copyright [yyyy] [name of copyright owner]
18 18 *
19 19 * CDDL HEADER END
20 20 */
21 21 /*
22 22 * Copyright 2004 Sun Microsystems, Inc. All rights reserved.
23 23 * Use is subject to license terms.
24 24 */
25 25
26 26 #include <avo/intl.h> /* for NOCATGETS */
27 27 #include <stdio.h>
28 28 #include <stdlib.h>
29 29 #include <string.h>
30 30 #include <sys/errno.h>
31 31 #include <sys/param.h>
32 32 #include <sys/stat.h>
33 33 #include <sys/types.h>
34 34 #include <unistd.h>
35 35 #include <vroot/vroot.h>
36 36 #include <mksdmsi18n/mksdmsi18n.h>
37 37 #include <signal.h>
38 38 #include <errno.h> /* errno */
39 39
40 40 #if !defined(linux)
41 41 extern char *sys_errlist[];
42 42 extern int sys_nerr;
43 43 #endif
44 44
45 45 static void file_lock_error(char *msg, char *file, char *str, int arg1, int arg2);
46 46
47 47 #define BLOCK_INTERUPTS sigfillset(&newset) ; \
48 48 sigprocmask(SIG_SETMASK, &newset, &oldset)
49 49
50 50 #define UNBLOCK_INTERUPTS \
51 51 sigprocmask(SIG_SETMASK, &oldset, &newset)
52 52
53 53 /*
54 54 * This code stolen from the NSE library and changed to not depend
55 55 * upon any NSE routines or header files.
56 56 *
57 57 * Simple file locking.
58 58 * Create a symlink to a file. The "test and set" will be
59 59 * atomic as creating the symlink provides both functions.
60 60 *
61 61 * The timeout value specifies how long to wait for stale locks
62 62 * to disappear. If the lock is more than 'timeout' seconds old
63 63 * then it is ok to blow it away. This part has a small window
64 64 * of vunerability as the operations of testing the time,
65 65 * removing the lock and creating a new one are not atomic.
66 66 * It would be possible for two processes to both decide to blow
67 67 * away the lock and then have process A remove the lock and establish
68 68 * its own, and then then have process B remove the lock which accidentily
69 69 * removes A's lock rather than the stale one.
70 70 *
71 71 * A further complication is with the NFS. If the file in question is
72 72 * being served by an NFS server, then its time is set by that server.
73 73 * We can not use the time on the client machine to check for a stale
74 74 * lock. Therefore, a temp file on the server is created to get
75 75 * the servers current time.
76 76 *
77 77 * Returns an error message. NULL return means the lock was obtained.
78 78 *
79 79 * 12/6/91 Added the parameter "file_locked". Before this parameter
80 80 * was added, the calling procedure would have to wait for file_lock()
81 81 * to return before it sets the flag. If the user interrupted "make"
82 82 * between the time the lock was acquired and the time file_lock()
83 83 * returns, make wouldn't know that the file has been locked, and therefore
84 84 * it wouldn' remove the lock. Setting the flag right after locking the file
85 85 * makes this window much smaller.
86 86 */
87 87
88 88 int
89 89 file_lock(char *name, char *lockname, int *file_locked, int timeout)
90 90 {
91 91 int counter = 0;
92 92 static char msg[MAXPATHLEN+1];
93 93 int printed_warning = 0;
94 94 int r;
95 95 struct stat statb;
96 96 sigset_t newset;
97 97 sigset_t oldset;
98 98
99 99 *file_locked = 0;
100 100 if (timeout <= 0) {
101 101 timeout = 120;
102 102 }
103 103 for (;;) {
104 104 BLOCK_INTERUPTS;
105 105 r = symlink(name, lockname);
106 106 if (r == 0) {
107 107 *file_locked = 1;
108 108 UNBLOCK_INTERUPTS;
109 109 return 0; /* success */
110 110 }
111 111 UNBLOCK_INTERUPTS;
112 112
113 113 if (errno != EEXIST) {
114 114 file_lock_error(msg, name, (char *)NOCATGETS("symlink(%s, %s)"),
115 115 (int) name, (int) lockname);
116 116 fprintf(stderr, "%s", msg);
117 117 return errno;
118 118 }
119 119
120 120 counter = 0;
121 121 for (;;) {
122 122 sleep(1);
123 123 r = lstat(lockname, &statb);
|
↓ open down ↓ |
123 lines elided |
↑ open up ↑ |
124 124 if (r == -1) {
125 125 /*
126 126 * The lock must have just gone away - try
127 127 * again.
128 128 */
129 129 break;
130 130 }
131 131
132 132 if ((counter > 5) && (!printed_warning)) {
133 133 /* Print waiting message after 5 secs */
134 -#if defined(SUN5_0) || defined(HP_UX) || defined(linux)
135 134 (void) getcwd(msg, MAXPATHLEN);
136 -#else
137 - (void) getwd(msg);
138 -#endif
139 135 fprintf(stderr,
140 136 catgets(libmksdmsi18n_catd, 1, 162, "file_lock: file %s is already locked.\n"),
141 137 name);
142 138 fprintf(stderr,
143 139 catgets(libmksdmsi18n_catd, 1, 163, "file_lock: will periodically check the lockfile %s for two minutes.\n"),
144 140 lockname);
145 141 fprintf(stderr,
146 142 catgets(libmksdmsi18n_catd, 1, 144, "Current working directory %s\n"),
147 143 msg);
148 144
149 145 printed_warning = 1;
150 146 }
151 147
152 148 if (++counter > timeout ) {
153 149 /*
154 150 * Waited enough - return an error..
155 151 */
156 152 return EEXIST;
157 153 }
158 154 }
159 155 }
160 156 /* NOTREACHED */
161 157 }
162 158
163 159 /*
164 160 * Format a message telling why the lock could not be created.
165 161 */
166 162 static void
167 163 file_lock_error(char *msg, char *file, char *str, int arg1, int arg2)
168 164 {
169 165 int len;
|
↓ open down ↓ |
21 lines elided |
↑ open up ↑ |
170 166
171 167 sprintf(msg, catgets(libmksdmsi18n_catd, 1, 145, "Could not lock file `%s'; "), file);
172 168 len = strlen(msg);
173 169 sprintf(&msg[len], str, arg1, arg2);
174 170 strcat(msg, catgets(libmksdmsi18n_catd, 1, 146, " failed - "));
175 171 #if !defined(linux)
176 172 if (errno < sys_nerr) {
177 173 #ifdef SUN4_x
178 174 strcat(msg, sys_errlist[errno]);
179 175 #endif
180 -#ifdef SUN5_0
181 176 strcat(msg, strerror(errno));
182 -#endif
183 177 } else {
184 178 len = strlen(msg);
185 179 sprintf(&msg[len], NOCATGETS("errno %d"), errno);
186 180 }
187 181 #else
188 182 strcat(msg, strerror(errno));
189 183 #endif
190 184 }
191 185
XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX