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