savecore.c revision 1.13 1 1.13 pk /*-
2 1.13 pk * Copyright (c) 1986, 1992, 1993
3 1.13 pk * The Regents of the University of California. All rights reserved.
4 1.1 cgd *
5 1.1 cgd * Redistribution and use in source and binary forms, with or without
6 1.1 cgd * modification, are permitted provided that the following conditions
7 1.1 cgd * are met:
8 1.1 cgd * 1. Redistributions of source code must retain the above copyright
9 1.1 cgd * notice, this list of conditions and the following disclaimer.
10 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer in the
12 1.1 cgd * documentation and/or other materials provided with the distribution.
13 1.1 cgd * 3. All advertising materials mentioning features or use of this software
14 1.1 cgd * must display the following acknowledgement:
15 1.1 cgd * This product includes software developed by the University of
16 1.1 cgd * California, Berkeley and its contributors.
17 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
18 1.1 cgd * may be used to endorse or promote products derived from this software
19 1.1 cgd * without specific prior written permission.
20 1.1 cgd *
21 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
22 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
24 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
25 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
26 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
27 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
28 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
29 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
30 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
31 1.1 cgd * SUCH DAMAGE.
32 1.1 cgd */
33 1.1 cgd
34 1.1 cgd #ifndef lint
35 1.13 pk static char copyright[] =
36 1.13 pk "@(#) Copyright (c) 1986, 1992, 1993\n\
37 1.13 pk The Regents of the University of California. All rights reserved.\n";
38 1.1 cgd #endif /* not lint */
39 1.1 cgd
40 1.1 cgd #ifndef lint
41 1.13 pk static char sccsid[] = "@(#)savecore.c 8.3 (Berkeley) 1/2/94";
42 1.1 cgd #endif /* not lint */
43 1.1 cgd
44 1.1 cgd #include <sys/param.h>
45 1.13 pk #include <sys/stat.h>
46 1.1 cgd #include <sys/mount.h>
47 1.13 pk #include <sys/syslog.h>
48 1.1 cgd #include <sys/time.h>
49 1.13 pk
50 1.1 cgd #include <dirent.h>
51 1.7 cgd #include <errno.h>
52 1.13 pk #include <fcntl.h>
53 1.1 cgd #include <nlist.h>
54 1.1 cgd #include <paths.h>
55 1.7 cgd #include <stdio.h>
56 1.7 cgd #include <stdlib.h>
57 1.13 pk #include <string.h>
58 1.13 pk #include <tzfile.h>
59 1.7 cgd #include <unistd.h>
60 1.1 cgd
61 1.6 cgd #define ok(number) ((number) - KERNBASE)
62 1.1 cgd
63 1.13 pk struct nlist current_nl[] = { /* Namelist for currently running system. */
64 1.1 cgd #define X_DUMPDEV 0
65 1.1 cgd { "_dumpdev" },
66 1.1 cgd #define X_DUMPLO 1
67 1.1 cgd { "_dumplo" },
68 1.1 cgd #define X_TIME 2
69 1.1 cgd { "_time" },
70 1.1 cgd #define X_DUMPSIZE 3
71 1.1 cgd { "_dumpsize" },
72 1.1 cgd #define X_VERSION 4
73 1.1 cgd { "_version" },
74 1.1 cgd #define X_PANICSTR 5
75 1.1 cgd { "_panicstr" },
76 1.1 cgd #define X_DUMPMAG 6
77 1.1 cgd { "_dumpmag" },
78 1.1 cgd { "" },
79 1.1 cgd };
80 1.13 pk int cursyms[] = { X_DUMPDEV, X_DUMPLO, X_VERSION, X_DUMPMAG, -1 };
81 1.13 pk int dumpsyms[] = { X_TIME, X_DUMPSIZE, X_VERSION, X_PANICSTR, X_DUMPMAG, -1 };
82 1.1 cgd
83 1.13 pk struct nlist dump_nl[] = { /* Name list for dumped system. */
84 1.13 pk { "_dumpdev" }, /* Entries MUST be the same as */
85 1.13 pk { "_dumplo" }, /* those in current_nl[]. */
86 1.1 cgd { "_time" },
87 1.1 cgd { "_dumpsize" },
88 1.1 cgd { "_version" },
89 1.1 cgd { "_panicstr" },
90 1.1 cgd { "_dumpmag" },
91 1.1 cgd { "" },
92 1.1 cgd };
93 1.1 cgd
94 1.13 pk /* Types match kernel declarations. */
95 1.13 pk long dumplo; /* where dump starts on dumpdev */
96 1.13 pk int dumpmag; /* magic number in dump */
97 1.13 pk int dumpsize; /* amount of memory dumped */
98 1.13 pk
99 1.13 pk char *vmunix;
100 1.1 cgd char *dirname; /* directory to save dumps in */
101 1.1 cgd char *ddname; /* name of dump device */
102 1.13 pk dev_t dumpdev; /* dump device */
103 1.1 cgd int dumpfd; /* read/write descriptor on block dev */
104 1.1 cgd time_t now; /* current date */
105 1.13 pk char panic_mesg[1024];
106 1.1 cgd int panicstr;
107 1.13 pk char vers[1024];
108 1.7 cgd
109 1.13 pk int clear, compress, force, verbose; /* flags */
110 1.13 pk
111 1.13 pk void check_kmem __P((void));
112 1.13 pk int check_space __P((void));
113 1.13 pk void clear_dump __P((void));
114 1.13 pk int Create __P((char *, int));
115 1.13 pk int dump_exists __P((void));
116 1.7 cgd char *find_dev __P((dev_t, int));
117 1.13 pk int get_crashtime __P((void));
118 1.13 pk void kmem_setup __P((void));
119 1.13 pk void log __P((int, char *, ...));
120 1.13 pk void Lseek __P((int, off_t, int));
121 1.13 pk int Open __P((char *, int rw));
122 1.13 pk int Read __P((int, void *, int));
123 1.13 pk char *rawname __P((char *s));
124 1.13 pk void save_core __P((void));
125 1.13 pk void usage __P((void));
126 1.13 pk void Write __P((int, void *, int));
127 1.1 cgd
128 1.13 pk int
129 1.1 cgd main(argc, argv)
130 1.1 cgd int argc;
131 1.13 pk char *argv[];
132 1.1 cgd {
133 1.1 cgd int ch;
134 1.1 cgd
135 1.13 pk openlog("savecore", LOG_PERROR, LOG_DAEMON);
136 1.13 pk
137 1.13 pk while ((ch = getopt(argc, argv, "cdfNvz")) != EOF)
138 1.1 cgd switch(ch) {
139 1.1 cgd case 'c':
140 1.1 cgd clear = 1;
141 1.1 cgd break;
142 1.13 pk case 'd': /* Not documented. */
143 1.1 cgd case 'v':
144 1.1 cgd verbose = 1;
145 1.1 cgd break;
146 1.1 cgd case 'f':
147 1.1 cgd force = 1;
148 1.1 cgd break;
149 1.13 pk case 'N':
150 1.13 pk vmunix = optarg;
151 1.13 pk break;
152 1.13 pk case 'z':
153 1.13 pk compress = 1;
154 1.13 pk break;
155 1.1 cgd case '?':
156 1.1 cgd default:
157 1.1 cgd usage();
158 1.1 cgd }
159 1.1 cgd argc -= optind;
160 1.1 cgd argv += optind;
161 1.1 cgd
162 1.1 cgd if (!clear) {
163 1.1 cgd if (argc != 1 && argc != 2)
164 1.1 cgd usage();
165 1.1 cgd dirname = argv[0];
166 1.1 cgd }
167 1.1 cgd if (argc == 2)
168 1.13 pk vmunix = argv[1];
169 1.1 cgd
170 1.13 pk (void)time(&now);
171 1.13 pk kmem_setup();
172 1.1 cgd
173 1.1 cgd if (clear) {
174 1.1 cgd clear_dump();
175 1.1 cgd exit(0);
176 1.1 cgd }
177 1.13 pk
178 1.13 pk if (!dump_exists() && !force)
179 1.13 pk exit(1);
180 1.13 pk
181 1.1 cgd check_kmem();
182 1.13 pk
183 1.1 cgd if (panicstr)
184 1.13 pk syslog(LOG_ALERT, "reboot after panic: %s", panic_mesg);
185 1.1 cgd else
186 1.13 pk syslog(LOG_ALERT, "reboot");
187 1.1 cgd
188 1.1 cgd if ((!get_crashtime() || !check_space()) && !force)
189 1.1 cgd exit(1);
190 1.1 cgd
191 1.13 pk save_core();
192 1.1 cgd
193 1.13 pk clear_dump();
194 1.13 pk exit(0);
195 1.1 cgd }
196 1.1 cgd
197 1.13 pk void
198 1.13 pk kmem_setup()
199 1.1 cgd {
200 1.1 cgd FILE *fp;
201 1.13 pk int kmem, i;
202 1.1 cgd char *dump_sys;
203 1.1 cgd
204 1.1 cgd /*
205 1.13 pk * Some names we need for the currently running system, others for
206 1.13 pk * the system that was running when the dump was made. The values
207 1.13 pk * obtained from the current system are used to look for things in
208 1.13 pk * /dev/kmem that cannot be found in the dump_sys namelist, but are
209 1.13 pk * presumed to be the same (since the disk partitions are probably
210 1.13 pk * the same!)
211 1.1 cgd */
212 1.13 pk if ((nlist(_PATH_UNIX, current_nl)) == -1)
213 1.13 pk syslog(LOG_ERR, "%s: nlist: %s", _PATH_UNIX, strerror(errno));
214 1.1 cgd for (i = 0; cursyms[i] != -1; i++)
215 1.1 cgd if (current_nl[cursyms[i]].n_value == 0) {
216 1.13 pk syslog(LOG_ERR, "%s: %s not in namelist",
217 1.13 pk _PATH_UNIX, current_nl[cursyms[i]].n_name);
218 1.1 cgd exit(1);
219 1.1 cgd }
220 1.13 pk
221 1.13 pk dump_sys = vmunix ? vmunix : _PATH_UNIX;
222 1.13 pk if ((nlist(dump_sys, dump_nl)) == -1)
223 1.13 pk syslog(LOG_ERR, "%s: nlist: %s", dump_sys, strerror(errno));
224 1.1 cgd for (i = 0; dumpsyms[i] != -1; i++)
225 1.1 cgd if (dump_nl[dumpsyms[i]].n_value == 0) {
226 1.13 pk syslog(LOG_ERR, "%s: %s not in namelist",
227 1.13 pk dump_sys, dump_nl[dumpsyms[i]].n_name);
228 1.1 cgd exit(1);
229 1.1 cgd }
230 1.13 pk
231 1.1 cgd kmem = Open(_PATH_KMEM, O_RDONLY);
232 1.13 pk Lseek(kmem, (off_t)current_nl[X_DUMPDEV].n_value, L_SET);
233 1.13 pk (void)Read(kmem, &dumpdev, sizeof(dumpdev));
234 1.5 pk if (dumpdev == NODEV) {
235 1.13 pk syslog(LOG_WARNING, "no core dump (no dumpdev)");
236 1.13 pk exit(1);
237 1.5 pk }
238 1.13 pk Lseek(kmem, (off_t)current_nl[X_DUMPLO].n_value, L_SET);
239 1.13 pk (void)Read(kmem, &dumplo, sizeof(dumplo));
240 1.1 cgd if (verbose)
241 1.13 pk (void)printf("dumplo = %d (%d * %d)\n",
242 1.13 pk dumplo, dumplo/DEV_BSIZE, DEV_BSIZE);
243 1.13 pk Lseek(kmem, (off_t)current_nl[X_DUMPMAG].n_value, L_SET);
244 1.13 pk (void)Read(kmem, &dumpmag, sizeof(dumpmag));
245 1.1 cgd dumplo *= DEV_BSIZE;
246 1.1 cgd ddname = find_dev(dumpdev, S_IFBLK);
247 1.1 cgd dumpfd = Open(ddname, O_RDWR);
248 1.1 cgd fp = fdopen(kmem, "r");
249 1.1 cgd if (fp == NULL) {
250 1.13 pk syslog(LOG_ERR, "%s: fdopen: %m", _PATH_KMEM);
251 1.1 cgd exit(1);
252 1.1 cgd }
253 1.13 pk if (vmunix)
254 1.1 cgd return;
255 1.13 pk (void)fseek(fp, (off_t)current_nl[X_VERSION].n_value, L_SET);
256 1.13 pk (void)fgets(vers, sizeof(vers), fp);
257 1.13 pk
258 1.13 pk /* Don't fclose(fp), we use dumpfd later. */
259 1.1 cgd }
260 1.1 cgd
261 1.13 pk void
262 1.1 cgd check_kmem()
263 1.1 cgd {
264 1.13 pk register char *cp;
265 1.1 cgd FILE *fp;
266 1.13 pk char core_vers[1024];
267 1.1 cgd
268 1.1 cgd fp = fdopen(dumpfd, "r");
269 1.1 cgd if (fp == NULL) {
270 1.13 pk syslog(LOG_ERR, "%s: fdopen: %m", ddname);
271 1.1 cgd exit(1);
272 1.1 cgd }
273 1.13 pk fseek(fp, (off_t)(dumplo + ok(dump_nl[X_VERSION].n_value)), L_SET);
274 1.13 pk fgets(core_vers, sizeof(core_vers), fp);
275 1.13 pk if (strcmp(vers, core_vers) && vmunix == 0)
276 1.13 pk syslog(LOG_WARNING,
277 1.13 pk "warning: %s version mismatch:\n\t%s\nand\t%s\n",
278 1.13 pk _PATH_UNIX, vers, core_vers);
279 1.13 pk (void)fseek(fp,
280 1.13 pk (off_t)(dumplo + ok(dump_nl[X_PANICSTR].n_value)), L_SET);
281 1.13 pk (void)fread(&panicstr, sizeof(panicstr), 1, fp);
282 1.1 cgd if (panicstr) {
283 1.13 pk (void)fseek(fp, dumplo + ok(panicstr), L_SET);
284 1.1 cgd cp = panic_mesg;
285 1.1 cgd do
286 1.1 cgd *cp = getc(fp);
287 1.1 cgd while (*cp++ && cp < &panic_mesg[sizeof(panic_mesg)]);
288 1.1 cgd }
289 1.13 pk /* Don't fclose(fp), we use dumpfd later. */
290 1.13 pk }
291 1.13 pk
292 1.13 pk void
293 1.13 pk clear_dump()
294 1.13 pk {
295 1.13 pk long newdumplo;
296 1.13 pk
297 1.13 pk newdumplo = 0;
298 1.13 pk Lseek(dumpfd, (off_t)(dumplo + ok(dump_nl[X_DUMPMAG].n_value)), L_SET);
299 1.13 pk Write(dumpfd, &newdumplo, sizeof(newdumplo));
300 1.1 cgd }
301 1.1 cgd
302 1.13 pk int
303 1.13 pk dump_exists()
304 1.1 cgd {
305 1.13 pk int newdumpmag;
306 1.1 cgd
307 1.13 pk Lseek(dumpfd, (off_t)(dumplo + ok(dump_nl[X_DUMPMAG].n_value)), L_SET);
308 1.13 pk (void)Read(dumpfd, &newdumpmag, sizeof(newdumpmag));
309 1.13 pk if (newdumpmag != dumpmag) {
310 1.1 cgd if (verbose)
311 1.13 pk syslog(LOG_WARNING, "magic number mismatch (%x != %x)",
312 1.13 pk newdumpmag, dumpmag);
313 1.13 pk syslog(LOG_WARNING, "no core dump");
314 1.1 cgd return (0);
315 1.1 cgd }
316 1.13 pk return (1);
317 1.13 pk }
318 1.13 pk
319 1.13 pk char buf[1024 * 1024];
320 1.13 pk
321 1.13 pk void
322 1.13 pk save_core()
323 1.13 pk {
324 1.13 pk register FILE *fp;
325 1.13 pk register int bounds, ifd, nr, nw, ofd;
326 1.13 pk char *rawp, path[MAXPATHLEN];
327 1.13 pk
328 1.13 pk /*
329 1.13 pk * Get the current number and update the bounds file. Do the update
330 1.13 pk * now, because may fail later and don't want to overwrite anything.
331 1.13 pk */
332 1.13 pk (void)snprintf(path, sizeof(path), "%s/bounds", dirname);
333 1.13 pk if ((fp = fopen(path, "r")) == NULL)
334 1.13 pk goto err1;
335 1.13 pk if (fgets(buf, sizeof(buf), fp) == NULL) {
336 1.13 pk if (ferror(fp))
337 1.13 pk err1: syslog(LOG_WARNING, "%s: %s", path, strerror(errno));
338 1.13 pk bounds = 0;
339 1.13 pk } else
340 1.13 pk bounds = atoi(buf);
341 1.13 pk if (fp != NULL)
342 1.13 pk (void)fclose(fp);
343 1.13 pk if ((fp = fopen(path, "w")) == NULL)
344 1.13 pk syslog(LOG_ERR, "%s: %m", path);
345 1.13 pk else {
346 1.13 pk (void)fprintf(fp, "%d\n", bounds + 1);
347 1.13 pk (void)fclose(fp);
348 1.13 pk }
349 1.13 pk (void)fclose(fp);
350 1.13 pk
351 1.13 pk /* Create the core file. */
352 1.13 pk (void)snprintf(path, sizeof(path), "%s/vmcore.%d%s",
353 1.13 pk dirname, bounds, compress ? ".Z" : "");
354 1.13 pk if (compress) {
355 1.13 pk if ((fp = zopen(path, "w", 0)) == NULL) {
356 1.13 pk syslog(LOG_ERR, "%s: %s", path, strerror(errno));
357 1.13 pk exit(1);
358 1.13 pk }
359 1.13 pk } else
360 1.13 pk ofd = Create(path, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
361 1.13 pk
362 1.13 pk /* Open the raw device. */
363 1.13 pk rawp = rawname(ddname);
364 1.13 pk if ((ifd = open(rawp, O_RDONLY)) == -1) {
365 1.13 pk syslog(LOG_WARNING, "%s: %m; using block device", rawp);
366 1.13 pk ifd = dumpfd;
367 1.13 pk }
368 1.13 pk
369 1.13 pk /* Read the dump size. */
370 1.13 pk Lseek(dumpfd, (off_t)(dumplo + ok(dump_nl[X_DUMPSIZE].n_value)), L_SET);
371 1.13 pk (void)Read(dumpfd, &dumpsize, sizeof(dumpsize));
372 1.13 pk
373 1.13 pk /* Seek to the start of the core. */
374 1.13 pk Lseek(ifd, (off_t)dumplo, L_SET);
375 1.13 pk
376 1.13 pk /* Copy the core file. */
377 1.13 pk dumpsize *= NBPG;
378 1.13 pk syslog(LOG_NOTICE, "writing %score to %s",
379 1.13 pk compress ? "compressed " : "", path);
380 1.13 pk for (; dumpsize > 0; dumpsize -= nr) {
381 1.13 pk (void)printf("%6dK\r", dumpsize / 1024);
382 1.13 pk (void)fflush(stdout);
383 1.13 pk nr = read(ifd, buf, MIN(dumpsize, sizeof(buf)));
384 1.13 pk if (nr <= 0) {
385 1.13 pk if (nr == 0)
386 1.13 pk syslog(LOG_WARNING,
387 1.13 pk "WARNING: EOF on dump device");
388 1.13 pk else
389 1.13 pk syslog(LOG_ERR, "%s: %m", rawp);
390 1.13 pk goto err2;
391 1.13 pk }
392 1.13 pk if (compress)
393 1.13 pk nw = fwrite(buf, 1, nr, fp);
394 1.13 pk else
395 1.13 pk nw = write(ofd, buf, nr);
396 1.13 pk if (nw != nr) {
397 1.13 pk syslog(LOG_ERR, "%s: %s",
398 1.13 pk path, strerror(nw == 0 ? EIO : errno));
399 1.13 pk err2: syslog(LOG_WARNING,
400 1.13 pk "WARNING: vmcore may be incomplete");
401 1.13 pk (void)printf("\n");
402 1.13 pk exit(1);
403 1.13 pk }
404 1.13 pk }
405 1.13 pk (void)printf("\n");
406 1.13 pk (void)close(ifd);
407 1.13 pk if (compress)
408 1.13 pk (void)fclose(fp);
409 1.13 pk else
410 1.13 pk (void)close(ofd);
411 1.13 pk
412 1.13 pk /* Copy the kernel. */
413 1.13 pk ifd = Open(vmunix ? vmunix : _PATH_UNIX, O_RDONLY);
414 1.13 pk (void)snprintf(path, sizeof(path), "%s/netbsd.%d%s",
415 1.13 pk dirname, bounds, compress ? ".Z" : "");
416 1.13 pk if (compress) {
417 1.13 pk if ((fp = zopen(path, "w", 0)) == NULL) {
418 1.13 pk syslog(LOG_ERR, "%s: %s", path, strerror(errno));
419 1.13 pk exit(1);
420 1.13 pk }
421 1.13 pk } else
422 1.13 pk ofd = Create(path, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
423 1.13 pk syslog(LOG_NOTICE, "writing %skernel to %s",
424 1.13 pk compress ? "compressed " : "", path);
425 1.13 pk while ((nr = read(ifd, buf, sizeof(buf))) > 0) {
426 1.13 pk if (compress)
427 1.13 pk nw = fwrite(buf, 1, nr, fp);
428 1.13 pk else
429 1.13 pk nw = write(ofd, buf, nr);
430 1.13 pk if (nw != nr) {
431 1.13 pk syslog(LOG_ERR, "%s: %s",
432 1.13 pk path, strerror(nw == 0 ? EIO : errno));
433 1.13 pk syslog(LOG_WARNING,
434 1.13 pk "WARNING: vmunix may be incomplete");
435 1.13 pk exit(1);
436 1.13 pk }
437 1.13 pk }
438 1.13 pk if (nr < 0) {
439 1.13 pk syslog(LOG_ERR, "%s: %s",
440 1.13 pk vmunix ? vmunix : _PATH_UNIX, strerror(errno));
441 1.13 pk syslog(LOG_WARNING,
442 1.13 pk "WARNING: vmunix may be incomplete");
443 1.13 pk exit(1);
444 1.1 cgd }
445 1.13 pk if (compress)
446 1.13 pk (void)fclose(fp);
447 1.13 pk else
448 1.13 pk (void)close(ofd);
449 1.1 cgd }
450 1.1 cgd
451 1.1 cgd char *
452 1.13 pk find_dev(dev, type)
453 1.13 pk register dev_t dev;
454 1.13 pk register int type;
455 1.1 cgd {
456 1.13 pk register DIR *dfd;
457 1.13 pk struct dirent *dir;
458 1.13 pk struct stat sb;
459 1.13 pk char *dp, devname[MAXPATHLEN + 1];
460 1.1 cgd
461 1.13 pk if ((dfd = opendir(_PATH_DEV)) == NULL) {
462 1.13 pk syslog(LOG_ERR, "%s: %s", _PATH_DEV, strerror(errno));
463 1.13 pk exit(1);
464 1.13 pk }
465 1.13 pk (void)strcpy(devname, _PATH_DEV);
466 1.13 pk while ((dir = readdir(dfd))) {
467 1.13 pk (void)strcpy(devname + sizeof(_PATH_DEV) - 1, dir->d_name);
468 1.13 pk if (lstat(devname, &sb)) {
469 1.13 pk syslog(LOG_ERR, "%s: %s", devname, strerror(errno));
470 1.13 pk continue;
471 1.13 pk }
472 1.13 pk if ((sb.st_mode & S_IFMT) != type)
473 1.13 pk continue;
474 1.13 pk if (dev == sb.st_rdev) {
475 1.13 pk closedir(dfd);
476 1.13 pk if ((dp = strdup(devname)) == NULL) {
477 1.13 pk syslog(LOG_ERR, "%s", strerror(errno));
478 1.13 pk exit(1);
479 1.13 pk }
480 1.13 pk return (dp);
481 1.13 pk }
482 1.13 pk }
483 1.13 pk closedir(dfd);
484 1.13 pk syslog(LOG_ERR, "can't find device %d/%d", major(dev), minor(dev));
485 1.13 pk exit(1);
486 1.1 cgd }
487 1.1 cgd
488 1.13 pk char *
489 1.13 pk rawname(s)
490 1.13 pk char *s;
491 1.1 cgd {
492 1.13 pk char *sl, name[MAXPATHLEN];
493 1.1 cgd
494 1.13 pk if ((sl = rindex(s, '/')) == NULL || sl[1] == '0') {
495 1.13 pk syslog(LOG_ERR,
496 1.13 pk "can't make raw dump device name from %s", s);
497 1.13 pk return (s);
498 1.13 pk }
499 1.13 pk (void)snprintf(name, sizeof(name), "%.*s/r%s", sl - s, s, sl + 1);
500 1.13 pk if ((sl = strdup(name)) == NULL) {
501 1.13 pk syslog(LOG_ERR, "%s", strerror(errno));
502 1.1 cgd exit(1);
503 1.1 cgd }
504 1.13 pk return (sl);
505 1.1 cgd }
506 1.1 cgd
507 1.13 pk int
508 1.13 pk get_crashtime()
509 1.1 cgd {
510 1.13 pk time_t dumptime; /* Time the dump was taken. */
511 1.1 cgd
512 1.13 pk Lseek(dumpfd, (off_t)(dumplo + ok(dump_nl[X_TIME].n_value)), L_SET);
513 1.13 pk (void)Read(dumpfd, &dumptime, sizeof(dumptime));
514 1.13 pk if (dumptime == 0) {
515 1.13 pk if (verbose)
516 1.13 pk syslog(LOG_ERR, "dump time is zero");
517 1.1 cgd return (0);
518 1.13 pk }
519 1.13 pk (void)printf("savecore: system went down at %s", ctime(&dumptime));
520 1.13 pk #define LEEWAY (7 * SECSPERDAY)
521 1.13 pk if (dumptime < now - LEEWAY || dumptime > now + LEEWAY) {
522 1.13 pk (void)printf("dump time is unreasonable\n");
523 1.1 cgd return (0);
524 1.1 cgd }
525 1.13 pk return (1);
526 1.1 cgd }
527 1.1 cgd
528 1.13 pk int
529 1.13 pk check_space()
530 1.1 cgd {
531 1.1 cgd register FILE *fp;
532 1.13 pk char *tvmunix;
533 1.13 pk off_t minfree, spacefree, vmunixsize, needed;
534 1.13 pk struct stat st;
535 1.13 pk struct statfs fsbuf;
536 1.13 pk char buf[100], path[MAXPATHLEN];
537 1.13 pk
538 1.13 pk tvmunix = vmunix ? vmunix : _PATH_UNIX;
539 1.13 pk if (stat(tvmunix, &st) < 0) {
540 1.13 pk syslog(LOG_ERR, "%s: %m", tvmunix);
541 1.13 pk exit(1);
542 1.13 pk }
543 1.13 pk vmunixsize = st.st_blocks * S_BLKSIZE;
544 1.13 pk if (statfs(dirname, &fsbuf) < 0) {
545 1.13 pk syslog(LOG_ERR, "%s: %m", dirname);
546 1.13 pk exit(1);
547 1.13 pk }
548 1.13 pk spacefree = (fsbuf.f_bavail * fsbuf.f_bsize) / 1024;
549 1.1 cgd
550 1.13 pk (void)snprintf(path, sizeof(path), "%s/minfree", dirname);
551 1.13 pk if ((fp = fopen(path, "r")) == NULL)
552 1.13 pk minfree = 0;
553 1.13 pk else {
554 1.13 pk if (fgets(buf, sizeof(buf), fp) == NULL)
555 1.13 pk minfree = 0;
556 1.13 pk else
557 1.13 pk minfree = atoi(buf);
558 1.13 pk (void)fclose(fp);
559 1.1 cgd }
560 1.13 pk
561 1.13 pk needed = (dumpsize + vmunixsize) / 1024;
562 1.13 pk if (minfree > 0 && spacefree - needed < minfree) {
563 1.13 pk syslog(LOG_WARNING,
564 1.13 pk "no dump, not enough free space on device");
565 1.13 pk return (0);
566 1.1 cgd }
567 1.13 pk if (spacefree - needed < minfree)
568 1.13 pk syslog(LOG_WARNING,
569 1.13 pk "dump performed, but free space threshold crossed");
570 1.13 pk return (1);
571 1.1 cgd }
572 1.1 cgd
573 1.13 pk int
574 1.1 cgd Open(name, rw)
575 1.1 cgd char *name;
576 1.1 cgd int rw;
577 1.1 cgd {
578 1.1 cgd int fd;
579 1.1 cgd
580 1.13 pk if ((fd = open(name, rw, 0)) < 0) {
581 1.13 pk syslog(LOG_ERR, "%s: %m", name);
582 1.1 cgd exit(1);
583 1.1 cgd }
584 1.1 cgd return (fd);
585 1.1 cgd }
586 1.1 cgd
587 1.13 pk int
588 1.13 pk Read(fd, bp, size)
589 1.1 cgd int fd, size;
590 1.13 pk void *bp;
591 1.1 cgd {
592 1.13 pk int nr;
593 1.1 cgd
594 1.13 pk nr = read(fd, bp, size);
595 1.13 pk if (nr != size) {
596 1.13 pk syslog(LOG_ERR, "read: %m");
597 1.1 cgd exit(1);
598 1.1 cgd }
599 1.13 pk return (nr);
600 1.1 cgd }
601 1.1 cgd
602 1.13 pk void
603 1.1 cgd Lseek(fd, off, flag)
604 1.1 cgd int fd, flag;
605 1.13 pk off_t off;
606 1.1 cgd {
607 1.13 pk off_t ret;
608 1.1 cgd
609 1.1 cgd ret = lseek(fd, off, flag);
610 1.1 cgd if (ret == -1) {
611 1.13 pk syslog(LOG_ERR, "lseek: %m");
612 1.1 cgd exit(1);
613 1.1 cgd }
614 1.1 cgd }
615 1.1 cgd
616 1.13 pk int
617 1.1 cgd Create(file, mode)
618 1.1 cgd char *file;
619 1.1 cgd int mode;
620 1.1 cgd {
621 1.1 cgd register int fd;
622 1.1 cgd
623 1.1 cgd fd = creat(file, mode);
624 1.1 cgd if (fd < 0) {
625 1.13 pk syslog(LOG_ERR, "%s: %m", file);
626 1.1 cgd exit(1);
627 1.1 cgd }
628 1.1 cgd return (fd);
629 1.1 cgd }
630 1.1 cgd
631 1.13 pk void
632 1.13 pk Write(fd, bp, size)
633 1.1 cgd int fd, size;
634 1.13 pk void *bp;
635 1.1 cgd {
636 1.1 cgd int n;
637 1.1 cgd
638 1.13 pk if ((n = write(fd, bp, size)) < size) {
639 1.13 pk syslog(LOG_ERR, "write: %s", strerror(n == -1 ? errno : EIO));
640 1.1 cgd exit(1);
641 1.1 cgd }
642 1.1 cgd }
643 1.1 cgd
644 1.13 pk void
645 1.1 cgd usage()
646 1.1 cgd {
647 1.13 pk (void)syslog(LOG_ERR, "usage: savecore [-cfvz] [-N system] directory");
648 1.1 cgd exit(1);
649 1.1 cgd }
650