savecore.c revision 1.60 1 1.60 itojun /* $NetBSD: savecore.c,v 1.60 2003/05/18 02:11:13 itojun Exp $ */
2 1.21 cgd
3 1.13 pk /*-
4 1.13 pk * Copyright (c) 1986, 1992, 1993
5 1.13 pk * The Regents of the University of California. All rights reserved.
6 1.1 cgd *
7 1.1 cgd * Redistribution and use in source and binary forms, with or without
8 1.1 cgd * modification, are permitted provided that the following conditions
9 1.1 cgd * are met:
10 1.1 cgd * 1. Redistributions of source code must retain the above copyright
11 1.1 cgd * notice, this list of conditions and the following disclaimer.
12 1.1 cgd * 2. Redistributions in binary form must reproduce the above copyright
13 1.1 cgd * notice, this list of conditions and the following disclaimer in the
14 1.1 cgd * documentation and/or other materials provided with the distribution.
15 1.1 cgd * 3. All advertising materials mentioning features or use of this software
16 1.1 cgd * must display the following acknowledgement:
17 1.1 cgd * This product includes software developed by the University of
18 1.1 cgd * California, Berkeley and its contributors.
19 1.1 cgd * 4. Neither the name of the University nor the names of its contributors
20 1.1 cgd * may be used to endorse or promote products derived from this software
21 1.1 cgd * without specific prior written permission.
22 1.1 cgd *
23 1.1 cgd * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
24 1.1 cgd * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
25 1.1 cgd * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
26 1.1 cgd * ARE DISCLAIMED. IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
27 1.1 cgd * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
28 1.1 cgd * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
29 1.1 cgd * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
30 1.1 cgd * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
31 1.1 cgd * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
32 1.1 cgd * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
33 1.1 cgd * SUCH DAMAGE.
34 1.1 cgd */
35 1.1 cgd
36 1.32 lukem #include <sys/cdefs.h>
37 1.1 cgd #ifndef lint
38 1.32 lukem __COPYRIGHT("@(#) Copyright (c) 1986, 1992, 1993\n\
39 1.32 lukem The Regents of the University of California. All rights reserved.\n");
40 1.1 cgd #endif /* not lint */
41 1.1 cgd
42 1.1 cgd #ifndef lint
43 1.21 cgd #if 0
44 1.34 lukem static char sccsid[] = "@(#)savecore.c 8.5 (Berkeley) 4/28/95";
45 1.21 cgd #else
46 1.60 itojun __RCSID("$NetBSD: savecore.c,v 1.60 2003/05/18 02:11:13 itojun Exp $");
47 1.21 cgd #endif
48 1.1 cgd #endif /* not lint */
49 1.1 cgd
50 1.1 cgd #include <sys/param.h>
51 1.1 cgd #include <sys/mount.h>
52 1.51 simonb #include <sys/msgbuf.h>
53 1.13 pk #include <sys/syslog.h>
54 1.1 cgd #include <sys/time.h>
55 1.13 pk
56 1.1 cgd #include <dirent.h>
57 1.7 cgd #include <errno.h>
58 1.13 pk #include <fcntl.h>
59 1.1 cgd #include <nlist.h>
60 1.1 cgd #include <paths.h>
61 1.51 simonb #include <stddef.h>
62 1.7 cgd #include <stdio.h>
63 1.7 cgd #include <stdlib.h>
64 1.13 pk #include <string.h>
65 1.36 kleink #include <time.h>
66 1.13 pk #include <tzfile.h>
67 1.7 cgd #include <unistd.h>
68 1.52 wiz #include <util.h>
69 1.25 leo #include <limits.h>
70 1.25 leo #include <kvm.h>
71 1.18 cgd
72 1.49 joda extern FILE *zopen(const char *fname, const char *mode);
73 1.1 cgd
74 1.51 simonb #define KREAD(kd, addr, p)\
75 1.25 leo (kvm_read(kd, addr, (char *)(p), sizeof(*(p))) != sizeof(*(p)))
76 1.1 cgd
77 1.13 pk struct nlist current_nl[] = { /* Namelist for currently running system. */
78 1.51 simonb #define X_DUMPDEV 0
79 1.1 cgd { "_dumpdev" },
80 1.51 simonb #define X_DUMPLO 1
81 1.1 cgd { "_dumplo" },
82 1.51 simonb #define X_TIME 2
83 1.1 cgd { "_time" },
84 1.1 cgd #define X_DUMPSIZE 3
85 1.1 cgd { "_dumpsize" },
86 1.51 simonb #define X_VERSION 4
87 1.1 cgd { "_version" },
88 1.51 simonb #define X_DUMPMAG 5
89 1.51 simonb { "_dumpmag" },
90 1.51 simonb #define X_PANICSTR 6
91 1.1 cgd { "_panicstr" },
92 1.51 simonb #define X_PANICSTART 7
93 1.51 simonb { "_panicstart" },
94 1.51 simonb #define X_PANICEND 8
95 1.51 simonb { "_panicend" },
96 1.51 simonb #define X_MSGBUF 9
97 1.51 simonb { "_msgbufp" },
98 1.25 leo { NULL },
99 1.1 cgd };
100 1.13 pk int cursyms[] = { X_DUMPDEV, X_DUMPLO, X_VERSION, X_DUMPMAG, -1 };
101 1.13 pk int dumpsyms[] = { X_TIME, X_DUMPSIZE, X_VERSION, X_PANICSTR, X_DUMPMAG, -1 };
102 1.1 cgd
103 1.13 pk struct nlist dump_nl[] = { /* Name list for dumped system. */
104 1.13 pk { "_dumpdev" }, /* Entries MUST be the same as */
105 1.13 pk { "_dumplo" }, /* those in current_nl[]. */
106 1.1 cgd { "_time" },
107 1.1 cgd { "_dumpsize" },
108 1.1 cgd { "_version" },
109 1.51 simonb { "_dumpmag" },
110 1.1 cgd { "_panicstr" },
111 1.51 simonb { "_panicstart" },
112 1.51 simonb { "_panicend" },
113 1.51 simonb { "_msgbufp" },
114 1.25 leo { NULL },
115 1.1 cgd };
116 1.1 cgd
117 1.13 pk /* Types match kernel declarations. */
118 1.57 christos off_t dumplo; /* where dump starts on dumpdev */
119 1.56 tsutsui u_int32_t dumpmag; /* magic number in dump */
120 1.13 pk int dumpsize; /* amount of memory dumped */
121 1.13 pk
122 1.52 wiz const char *kernel; /* name of used kernel */
123 1.1 cgd char *dirname; /* directory to save dumps in */
124 1.1 cgd char *ddname; /* name of dump device */
125 1.13 pk dev_t dumpdev; /* dump device */
126 1.1 cgd int dumpfd; /* read/write descriptor on block dev */
127 1.25 leo kvm_t *kd_dump; /* kvm descriptor on block dev */
128 1.1 cgd time_t now; /* current date */
129 1.13 pk char panic_mesg[1024];
130 1.28 cgd long panicstr;
131 1.13 pk char vers[1024];
132 1.53 lukem char gzmode[3];
133 1.7 cgd
134 1.50 martin static int clear, compress, force, verbose; /* flags */
135 1.13 pk
136 1.45 wiz void check_kmem(void);
137 1.45 wiz int check_space(void);
138 1.45 wiz void clear_dump(void);
139 1.45 wiz int Create(char *, int);
140 1.45 wiz int dump_exists(void);
141 1.45 wiz char *find_dev(dev_t, int);
142 1.45 wiz int get_crashtime(void);
143 1.45 wiz void kmem_setup(void);
144 1.45 wiz void Lseek(int, off_t, int);
145 1.45 wiz int main(int, char *[]);
146 1.52 wiz int Open(const char *, int rw);
147 1.45 wiz char *rawname(char *s);
148 1.45 wiz void save_core(void);
149 1.45 wiz void usage(void);
150 1.45 wiz void Write(int, void *, int);
151 1.1 cgd
152 1.13 pk int
153 1.45 wiz main(int argc, char *argv[])
154 1.1 cgd {
155 1.53 lukem int ch, level;
156 1.53 lukem char *ep;
157 1.44 wiz
158 1.44 wiz dirname = NULL;
159 1.44 wiz kernel = NULL;
160 1.54 lukem level = 1; /* default to fastest gzip compression */
161 1.53 lukem gzmode[0] = 'w';
162 1.1 cgd
163 1.13 pk openlog("savecore", LOG_PERROR, LOG_DAEMON);
164 1.13 pk
165 1.53 lukem while ((ch = getopt(argc, argv, "cdfN:vzZ:")) != -1)
166 1.1 cgd switch(ch) {
167 1.1 cgd case 'c':
168 1.1 cgd clear = 1;
169 1.1 cgd break;
170 1.13 pk case 'd': /* Not documented. */
171 1.1 cgd case 'v':
172 1.1 cgd verbose = 1;
173 1.1 cgd break;
174 1.1 cgd case 'f':
175 1.1 cgd force = 1;
176 1.1 cgd break;
177 1.13 pk case 'N':
178 1.15 mycroft kernel = optarg;
179 1.13 pk break;
180 1.13 pk case 'z':
181 1.13 pk compress = 1;
182 1.13 pk break;
183 1.53 lukem case 'Z':
184 1.53 lukem level = (int)strtol(optarg, &ep, 10);
185 1.53 lukem if (level < 0 || level > 9) {
186 1.53 lukem (void)syslog(LOG_ERR, "invalid compression %s",
187 1.53 lukem optarg);
188 1.53 lukem usage();
189 1.53 lukem }
190 1.53 lukem break;
191 1.1 cgd case '?':
192 1.1 cgd default:
193 1.1 cgd usage();
194 1.1 cgd }
195 1.1 cgd argc -= optind;
196 1.1 cgd argv += optind;
197 1.1 cgd
198 1.44 wiz if (argc != (clear ? 0 : 1))
199 1.44 wiz usage();
200 1.44 wiz
201 1.54 lukem gzmode[1] = level + '0';
202 1.44 wiz if (!clear)
203 1.1 cgd dirname = argv[0];
204 1.44 wiz
205 1.44 wiz if (kernel == NULL) {
206 1.52 wiz kernel = getbootfile();
207 1.1 cgd }
208 1.1 cgd
209 1.13 pk (void)time(&now);
210 1.13 pk kmem_setup();
211 1.1 cgd
212 1.1 cgd if (clear) {
213 1.1 cgd clear_dump();
214 1.1 cgd exit(0);
215 1.1 cgd }
216 1.13 pk
217 1.13 pk if (!dump_exists() && !force)
218 1.13 pk exit(1);
219 1.13 pk
220 1.1 cgd check_kmem();
221 1.13 pk
222 1.1 cgd if (panicstr)
223 1.13 pk syslog(LOG_ALERT, "reboot after panic: %s", panic_mesg);
224 1.1 cgd else
225 1.13 pk syslog(LOG_ALERT, "reboot");
226 1.1 cgd
227 1.1 cgd if ((!get_crashtime() || !check_space()) && !force)
228 1.1 cgd exit(1);
229 1.1 cgd
230 1.13 pk save_core();
231 1.1 cgd
232 1.13 pk clear_dump();
233 1.13 pk exit(0);
234 1.1 cgd }
235 1.1 cgd
236 1.13 pk void
237 1.45 wiz kmem_setup(void)
238 1.1 cgd {
239 1.45 wiz kvm_t *kd_kern;
240 1.45 wiz char errbuf[_POSIX2_LINE_MAX];
241 1.45 wiz int i, hdrsz;
242 1.1 cgd
243 1.1 cgd /*
244 1.13 pk * Some names we need for the currently running system, others for
245 1.13 pk * the system that was running when the dump was made. The values
246 1.13 pk * obtained from the current system are used to look for things in
247 1.43 darrenr * /dev/kmem that cannot be found in the kernel namelist, but are
248 1.13 pk * presumed to be the same (since the disk partitions are probably
249 1.13 pk * the same!)
250 1.1 cgd */
251 1.42 darrenr kd_kern = kvm_openfiles(kernel, NULL, NULL, O_RDONLY, errbuf);
252 1.25 leo if (kd_kern == NULL) {
253 1.44 wiz syslog(LOG_ERR, "%s: kvm_openfiles: %s", kernel, errbuf);
254 1.25 leo exit(1);
255 1.25 leo }
256 1.25 leo if (kvm_nlist(kd_kern, current_nl) == -1)
257 1.44 wiz syslog(LOG_ERR, "%s: kvm_nlist: %s", kernel,
258 1.45 wiz kvm_geterr(kd_kern));
259 1.25 leo
260 1.1 cgd for (i = 0; cursyms[i] != -1; i++)
261 1.1 cgd if (current_nl[cursyms[i]].n_value == 0) {
262 1.13 pk syslog(LOG_ERR, "%s: %s not in namelist",
263 1.44 wiz kernel, current_nl[cursyms[i]].n_name);
264 1.1 cgd exit(1);
265 1.1 cgd }
266 1.13 pk
267 1.30 pk if (KREAD(kd_kern, current_nl[X_DUMPDEV].n_value, &dumpdev) != 0) {
268 1.30 pk if (verbose)
269 1.30 pk syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_kern));
270 1.30 pk exit(1);
271 1.30 pk }
272 1.5 pk if (dumpdev == NODEV) {
273 1.13 pk syslog(LOG_WARNING, "no core dump (no dumpdev)");
274 1.13 pk exit(1);
275 1.5 pk }
276 1.57 christos {
277 1.57 christos long l_dumplo;
278 1.57 christos
279 1.57 christos if (KREAD(kd_kern, current_nl[X_DUMPLO].n_value, &l_dumplo) != 0) {
280 1.57 christos if (verbose)
281 1.57 christos syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_kern));
282 1.57 christos exit(1);
283 1.57 christos }
284 1.57 christos if (l_dumplo == -1) {
285 1.57 christos syslog(LOG_WARNING, "no core dump (invalid dumplo)");
286 1.30 pk exit(1);
287 1.57 christos }
288 1.57 christos dumplo = DEV_BSIZE * (off_t) l_dumplo;
289 1.46 wiz }
290 1.57 christos
291 1.1 cgd if (verbose)
292 1.57 christos (void)printf("dumplo = %lld (%ld * %ld)\n",
293 1.57 christos (long long)dumplo, (long)(dumplo / DEV_BSIZE), (long)DEV_BSIZE);
294 1.30 pk if (KREAD(kd_kern, current_nl[X_DUMPMAG].n_value, &dumpmag) != 0) {
295 1.30 pk if (verbose)
296 1.30 pk syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_kern));
297 1.30 pk exit(1);
298 1.30 pk }
299 1.25 leo
300 1.45 wiz (void)kvm_read(kd_kern, current_nl[X_VERSION].n_value, vers,
301 1.45 wiz sizeof(vers));
302 1.44 wiz vers[sizeof(vers) - 1] = '\0';
303 1.25 leo
304 1.1 cgd ddname = find_dev(dumpdev, S_IFBLK);
305 1.1 cgd dumpfd = Open(ddname, O_RDWR);
306 1.25 leo
307 1.43 darrenr kd_dump = kvm_openfiles(kernel, ddname, NULL, O_RDWR, errbuf);
308 1.25 leo if (kd_dump == NULL) {
309 1.43 darrenr syslog(LOG_ERR, "%s: kvm_openfiles: %s", kernel, errbuf);
310 1.1 cgd exit(1);
311 1.1 cgd }
312 1.13 pk
313 1.25 leo if (kvm_nlist(kd_dump, dump_nl) == -1)
314 1.43 darrenr syslog(LOG_ERR, "%s: kvm_nlist: %s", kernel,
315 1.44 wiz kvm_geterr(kd_dump));
316 1.25 leo
317 1.25 leo for (i = 0; dumpsyms[i] != -1; i++)
318 1.25 leo if (dump_nl[dumpsyms[i]].n_value == 0) {
319 1.25 leo syslog(LOG_ERR, "%s: %s not in namelist",
320 1.43 darrenr kernel, dump_nl[dumpsyms[i]].n_name);
321 1.25 leo exit(1);
322 1.25 leo }
323 1.57 christos hdrsz = kvm_dump_mkheader(kd_dump, dumplo);
324 1.27 leo
325 1.27 leo /*
326 1.27 leo * If 'hdrsz' == 0, kvm_dump_mkheader() failed on the magic-number
327 1.27 leo * checks, ergo no dump is present...
328 1.27 leo */
329 1.27 leo if (hdrsz == 0) {
330 1.27 leo syslog(LOG_WARNING, "no core dump");
331 1.27 leo exit(1);
332 1.27 leo }
333 1.25 leo if (hdrsz == -1) {
334 1.43 darrenr syslog(LOG_ERR, "%s: kvm_dump_mkheader: %s", kernel,
335 1.45 wiz kvm_geterr(kd_dump));
336 1.25 leo exit(1);
337 1.25 leo }
338 1.25 leo dumplo += hdrsz;
339 1.25 leo kvm_close(kd_kern);
340 1.1 cgd }
341 1.1 cgd
342 1.13 pk void
343 1.45 wiz check_kmem(void)
344 1.1 cgd {
345 1.51 simonb char *cp, *bufdata;
346 1.51 simonb struct kern_msgbuf msgbuf, *bufp;
347 1.51 simonb long panicloc, panicstart, panicend;
348 1.13 pk char core_vers[1024];
349 1.1 cgd
350 1.25 leo (void)kvm_read(kd_dump, dump_nl[X_VERSION].n_value, core_vers,
351 1.45 wiz sizeof(core_vers));
352 1.25 leo core_vers[sizeof(core_vers) - 1] = '\0';
353 1.25 leo
354 1.52 wiz if (strcmp(vers, core_vers) != 0)
355 1.13 pk syslog(LOG_WARNING,
356 1.13 pk "warning: %s version mismatch:\n\t%s\nand\t%s\n",
357 1.44 wiz kernel, vers, core_vers);
358 1.25 leo
359 1.51 simonb panicstart = panicend = 0;
360 1.51 simonb if (KREAD(kd_dump, dump_nl[X_PANICSTART].n_value, &panicstart) != 0) {
361 1.51 simonb if (verbose)
362 1.51 simonb syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_dump));
363 1.51 simonb goto nomsguf;
364 1.51 simonb }
365 1.51 simonb if (KREAD(kd_dump, dump_nl[X_PANICEND].n_value, &panicend) != 0) {
366 1.51 simonb if (verbose)
367 1.51 simonb syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_dump));
368 1.51 simonb goto nomsguf;
369 1.51 simonb }
370 1.51 simonb if (panicstart != 0 && panicend != 0) {
371 1.51 simonb if (KREAD(kd_dump, dump_nl[X_MSGBUF].n_value, &bufp)) {
372 1.51 simonb if (verbose)
373 1.51 simonb syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_dump));
374 1.51 simonb goto nomsguf;
375 1.51 simonb }
376 1.51 simonb if (kvm_read(kd_dump, (long)bufp, &msgbuf,
377 1.51 simonb offsetof(struct kern_msgbuf, msg_bufc)) !=
378 1.51 simonb offsetof(struct kern_msgbuf, msg_bufc)) {
379 1.51 simonb if (verbose)
380 1.51 simonb syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_dump));
381 1.51 simonb goto nomsguf;
382 1.51 simonb }
383 1.51 simonb if (msgbuf.msg_magic != MSG_MAGIC) {
384 1.51 simonb if (verbose)
385 1.51 simonb syslog(LOG_WARNING, "msgbuf magic incorrect");
386 1.51 simonb goto nomsguf;
387 1.51 simonb }
388 1.51 simonb bufdata = malloc(msgbuf.msg_bufs);
389 1.51 simonb if (bufdata == NULL) {
390 1.51 simonb if (verbose)
391 1.51 simonb syslog(LOG_WARNING, "couldn't allocate space for msgbuf data");
392 1.51 simonb goto nomsguf;
393 1.51 simonb }
394 1.51 simonb if (kvm_read(kd_dump, (long)&bufp->msg_bufc, bufdata,
395 1.51 simonb msgbuf.msg_bufs) != msgbuf.msg_bufs) {
396 1.51 simonb if (verbose)
397 1.51 simonb syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_dump));
398 1.51 simonb goto nomsguf;
399 1.51 simonb }
400 1.51 simonb cp = panic_mesg;
401 1.51 simonb while (panicstart != panicend && cp < &panic_mesg[sizeof(panic_mesg)-1]) {
402 1.51 simonb *cp++ = bufdata[panicstart];
403 1.51 simonb panicstart++;
404 1.51 simonb if (panicstart >= msgbuf.msg_bufs)
405 1.51 simonb panicstart = 0;
406 1.51 simonb }
407 1.51 simonb /* Don't end in a new-line */
408 1.51 simonb cp = &panic_mesg[strlen(panic_mesg)] - 1;
409 1.51 simonb if (*cp == '\n')
410 1.51 simonb *cp = '\0';
411 1.51 simonb panic_mesg[sizeof(panic_mesg) - 1] = '\0';
412 1.51 simonb
413 1.51 simonb panicstr = 1; /* anything not zero */
414 1.51 simonb return;
415 1.51 simonb }
416 1.51 simonb nomsguf:
417 1.30 pk if (KREAD(kd_dump, dump_nl[X_PANICSTR].n_value, &panicstr) != 0) {
418 1.30 pk if (verbose)
419 1.30 pk syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_dump));
420 1.30 pk return;
421 1.30 pk }
422 1.1 cgd if (panicstr) {
423 1.45 wiz cp = panic_mesg;
424 1.25 leo panicloc = panicstr;
425 1.25 leo do {
426 1.30 pk if (KREAD(kd_dump, panicloc, cp) != 0) {
427 1.30 pk if (verbose)
428 1.30 pk syslog(LOG_WARNING, "kvm_read: %s",
429 1.45 wiz kvm_geterr(kd_dump));
430 1.30 pk break;
431 1.30 pk }
432 1.25 leo panicloc++;
433 1.30 pk } while (*cp++ && cp < &panic_mesg[sizeof(panic_mesg)-1]);
434 1.30 pk panic_mesg[sizeof(panic_mesg) - 1] = '\0';
435 1.1 cgd }
436 1.1 cgd }
437 1.1 cgd
438 1.13 pk int
439 1.45 wiz dump_exists(void)
440 1.1 cgd {
441 1.56 tsutsui u_int32_t newdumpmag;
442 1.1 cgd
443 1.30 pk if (KREAD(kd_dump, dump_nl[X_DUMPMAG].n_value, &newdumpmag) != 0) {
444 1.30 pk if (verbose)
445 1.30 pk syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_dump));
446 1.30 pk return (0);
447 1.30 pk }
448 1.23 cgd
449 1.23 cgd /* Read the dump size. */
450 1.30 pk if (KREAD(kd_dump, dump_nl[X_DUMPSIZE].n_value, &dumpsize) != 0) {
451 1.30 pk if (verbose)
452 1.30 pk syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_dump));
453 1.30 pk return (0);
454 1.30 pk }
455 1.23 cgd dumpsize *= getpagesize();
456 1.23 cgd
457 1.23 cgd /*
458 1.23 cgd * Return zero if core dump doesn't seem to be there, and note
459 1.23 cgd * it for syslog. This check and return happens after the dump size
460 1.23 cgd * is read, so dumpsize is whether or not the core is valid (for -f).
461 1.23 cgd */
462 1.13 pk if (newdumpmag != dumpmag) {
463 1.1 cgd if (verbose)
464 1.32 lukem syslog(LOG_WARNING,
465 1.32 lukem "magic number mismatch (0x%x != 0x%x)",
466 1.13 pk newdumpmag, dumpmag);
467 1.13 pk syslog(LOG_WARNING, "no core dump");
468 1.1 cgd return (0);
469 1.1 cgd }
470 1.13 pk return (1);
471 1.13 pk }
472 1.13 pk
473 1.25 leo void
474 1.45 wiz clear_dump(void)
475 1.25 leo {
476 1.25 leo if (kvm_dump_inval(kd_dump) == -1)
477 1.25 leo syslog(LOG_ERR, "%s: kvm_clear_dump: %s", ddname,
478 1.45 wiz kvm_geterr(kd_dump));
479 1.25 leo
480 1.25 leo }
481 1.25 leo
482 1.13 pk char buf[1024 * 1024];
483 1.16 deraadt
484 1.13 pk void
485 1.45 wiz save_core(void)
486 1.13 pk {
487 1.32 lukem FILE *fp;
488 1.32 lukem int bounds, ifd, nr, nw, ofd;
489 1.13 pk char *rawp, path[MAXPATHLEN];
490 1.13 pk
491 1.32 lukem ofd = -1;
492 1.13 pk /*
493 1.13 pk * Get the current number and update the bounds file. Do the update
494 1.13 pk * now, because may fail later and don't want to overwrite anything.
495 1.13 pk */
496 1.38 sommerfe umask(066);
497 1.13 pk (void)snprintf(path, sizeof(path), "%s/bounds", dirname);
498 1.13 pk if ((fp = fopen(path, "r")) == NULL)
499 1.13 pk goto err1;
500 1.13 pk if (fgets(buf, sizeof(buf), fp) == NULL) {
501 1.13 pk if (ferror(fp))
502 1.45 wiz err1: syslog(LOG_WARNING, "%s: %m", path);
503 1.13 pk bounds = 0;
504 1.13 pk } else
505 1.13 pk bounds = atoi(buf);
506 1.13 pk if (fp != NULL)
507 1.13 pk (void)fclose(fp);
508 1.13 pk if ((fp = fopen(path, "w")) == NULL)
509 1.13 pk syslog(LOG_ERR, "%s: %m", path);
510 1.13 pk else {
511 1.13 pk (void)fprintf(fp, "%d\n", bounds + 1);
512 1.13 pk (void)fclose(fp);
513 1.13 pk }
514 1.13 pk
515 1.13 pk /* Create the core file. */
516 1.24 mycroft (void)snprintf(path, sizeof(path), "%s/netbsd.%d.core%s",
517 1.49 joda dirname, bounds, compress ? ".gz" : "");
518 1.13 pk if (compress) {
519 1.53 lukem if ((fp = zopen(path, gzmode)) == NULL) {
520 1.45 wiz syslog(LOG_ERR, "%s: %m", path);
521 1.13 pk exit(1);
522 1.13 pk }
523 1.25 leo } else {
524 1.13 pk ofd = Create(path, S_IRUSR | S_IWUSR | S_IRGRP | S_IROTH);
525 1.25 leo fp = fdopen(ofd, "w");
526 1.25 leo if (fp == NULL) {
527 1.45 wiz syslog(LOG_ERR, "%s: fdopen: %m", path);
528 1.25 leo exit(1);
529 1.25 leo }
530 1.25 leo }
531 1.13 pk
532 1.13 pk /* Open the raw device. */
533 1.13 pk rawp = rawname(ddname);
534 1.13 pk if ((ifd = open(rawp, O_RDONLY)) == -1) {
535 1.13 pk syslog(LOG_WARNING, "%s: %m; using block device", rawp);
536 1.13 pk ifd = dumpfd;
537 1.13 pk }
538 1.13 pk
539 1.13 pk /* Seek to the start of the core. */
540 1.57 christos Lseek(ifd, dumplo, SEEK_SET);
541 1.13 pk
542 1.25 leo if (kvm_dump_wrtheader(kd_dump, fp, dumpsize) == -1) {
543 1.25 leo syslog(LOG_ERR, "kvm_dump_wrtheader: %s : %s", path,
544 1.45 wiz kvm_geterr(kd_dump));
545 1.25 leo exit(1);
546 1.25 leo }
547 1.25 leo
548 1.13 pk /* Copy the core file. */
549 1.13 pk syslog(LOG_NOTICE, "writing %score to %s",
550 1.13 pk compress ? "compressed " : "", path);
551 1.13 pk for (; dumpsize > 0; dumpsize -= nr) {
552 1.58 drochner char nbuf[7];
553 1.58 drochner humanize_number(nbuf, 7, dumpsize, "", HN_AUTOSCALE, 0);
554 1.58 drochner (void)printf("%7s\r", nbuf);
555 1.13 pk (void)fflush(stdout);
556 1.13 pk nr = read(ifd, buf, MIN(dumpsize, sizeof(buf)));
557 1.13 pk if (nr <= 0) {
558 1.13 pk if (nr == 0)
559 1.13 pk syslog(LOG_WARNING,
560 1.13 pk "WARNING: EOF on dump device");
561 1.13 pk else
562 1.13 pk syslog(LOG_ERR, "%s: %m", rawp);
563 1.13 pk goto err2;
564 1.13 pk }
565 1.25 leo nw = fwrite(buf, 1, nr, fp);
566 1.13 pk if (nw != nr) {
567 1.13 pk syslog(LOG_ERR, "%s: %s",
568 1.13 pk path, strerror(nw == 0 ? EIO : errno));
569 1.13 pk err2: syslog(LOG_WARNING,
570 1.15 mycroft "WARNING: core may be incomplete");
571 1.13 pk (void)printf("\n");
572 1.13 pk exit(1);
573 1.13 pk }
574 1.13 pk }
575 1.13 pk (void)close(ifd);
576 1.25 leo (void)fclose(fp);
577 1.13 pk
578 1.13 pk /* Copy the kernel. */
579 1.52 wiz ifd = Open(kernel, O_RDONLY);
580 1.13 pk (void)snprintf(path, sizeof(path), "%s/netbsd.%d%s",
581 1.49 joda dirname, bounds, compress ? ".gz" : "");
582 1.13 pk if (compress) {
583 1.53 lukem if ((fp = zopen(path, gzmode)) == NULL) {
584 1.45 wiz syslog(LOG_ERR, "%s: %m", path);
585 1.13 pk exit(1);
586 1.13 pk }
587 1.13 pk } else
588 1.38 sommerfe ofd = Create(path, S_IRUSR | S_IWUSR);
589 1.13 pk syslog(LOG_NOTICE, "writing %skernel to %s",
590 1.13 pk compress ? "compressed " : "", path);
591 1.13 pk while ((nr = read(ifd, buf, sizeof(buf))) > 0) {
592 1.13 pk if (compress)
593 1.13 pk nw = fwrite(buf, 1, nr, fp);
594 1.13 pk else
595 1.13 pk nw = write(ofd, buf, nr);
596 1.13 pk if (nw != nr) {
597 1.13 pk syslog(LOG_ERR, "%s: %s",
598 1.13 pk path, strerror(nw == 0 ? EIO : errno));
599 1.13 pk syslog(LOG_WARNING,
600 1.15 mycroft "WARNING: kernel may be incomplete");
601 1.13 pk exit(1);
602 1.13 pk }
603 1.13 pk }
604 1.13 pk if (nr < 0) {
605 1.52 wiz syslog(LOG_ERR, "%s: %m", kernel);
606 1.45 wiz syslog(LOG_WARNING, "WARNING: kernel may be incomplete");
607 1.13 pk exit(1);
608 1.1 cgd }
609 1.13 pk if (compress)
610 1.13 pk (void)fclose(fp);
611 1.13 pk else
612 1.13 pk (void)close(ofd);
613 1.1 cgd }
614 1.1 cgd
615 1.1 cgd char *
616 1.45 wiz find_dev(dev_t dev, int type)
617 1.1 cgd {
618 1.32 lukem DIR *dfd;
619 1.13 pk struct dirent *dir;
620 1.13 pk struct stat sb;
621 1.60 itojun char *dp, device[MAXPATHLEN + 1], *p;
622 1.60 itojun size_t l;
623 1.1 cgd
624 1.13 pk if ((dfd = opendir(_PATH_DEV)) == NULL) {
625 1.45 wiz syslog(LOG_ERR, "%s: %m", _PATH_DEV);
626 1.13 pk exit(1);
627 1.13 pk }
628 1.60 itojun strlcpy(device, _PATH_DEV, sizeof(device));
629 1.60 itojun p = &device[strlen(device)];
630 1.60 itojun l = sizeof(device) - strlen(device);
631 1.13 pk while ((dir = readdir(dfd))) {
632 1.60 itojun strlcpy(p, dir->d_name, l);
633 1.55 lukem if (lstat(device, &sb)) {
634 1.55 lukem syslog(LOG_ERR, "%s: %m", device);
635 1.13 pk continue;
636 1.13 pk }
637 1.13 pk if ((sb.st_mode & S_IFMT) != type)
638 1.13 pk continue;
639 1.13 pk if (dev == sb.st_rdev) {
640 1.13 pk closedir(dfd);
641 1.55 lukem if ((dp = strdup(device)) == NULL) {
642 1.45 wiz syslog(LOG_ERR, "%m");
643 1.13 pk exit(1);
644 1.13 pk }
645 1.13 pk return (dp);
646 1.13 pk }
647 1.13 pk }
648 1.13 pk closedir(dfd);
649 1.13 pk syslog(LOG_ERR, "can't find device %d/%d", major(dev), minor(dev));
650 1.13 pk exit(1);
651 1.1 cgd }
652 1.1 cgd
653 1.13 pk char *
654 1.45 wiz rawname(char *s)
655 1.1 cgd {
656 1.45 wiz char *sl;
657 1.45 wiz char name[MAXPATHLEN];
658 1.1 cgd
659 1.17 mycroft if ((sl = strrchr(s, '/')) == NULL || sl[1] == '0') {
660 1.13 pk syslog(LOG_ERR,
661 1.13 pk "can't make raw dump device name from %s", s);
662 1.13 pk return (s);
663 1.13 pk }
664 1.33 mrg (void)snprintf(name, sizeof(name), "%.*s/r%s", (int)(sl - s), s,
665 1.33 mrg sl + 1);
666 1.13 pk if ((sl = strdup(name)) == NULL) {
667 1.45 wiz syslog(LOG_ERR, "%m");
668 1.1 cgd exit(1);
669 1.1 cgd }
670 1.13 pk return (sl);
671 1.1 cgd }
672 1.1 cgd
673 1.13 pk int
674 1.45 wiz get_crashtime(void)
675 1.1 cgd {
676 1.45 wiz struct timeval dtime;
677 1.13 pk time_t dumptime; /* Time the dump was taken. */
678 1.1 cgd
679 1.45 wiz if (KREAD(kd_dump, dump_nl[X_TIME].n_value, &dtime) != 0) {
680 1.30 pk if (verbose)
681 1.30 pk syslog(LOG_WARNING, "kvm_read: %s", kvm_geterr(kd_dump));
682 1.30 pk return (0);
683 1.30 pk }
684 1.45 wiz dumptime = dtime.tv_sec;
685 1.13 pk if (dumptime == 0) {
686 1.13 pk if (verbose)
687 1.13 pk syslog(LOG_ERR, "dump time is zero");
688 1.1 cgd return (0);
689 1.13 pk }
690 1.13 pk (void)printf("savecore: system went down at %s", ctime(&dumptime));
691 1.13 pk #define LEEWAY (7 * SECSPERDAY)
692 1.13 pk if (dumptime < now - LEEWAY || dumptime > now + LEEWAY) {
693 1.13 pk (void)printf("dump time is unreasonable\n");
694 1.1 cgd return (0);
695 1.1 cgd }
696 1.13 pk return (1);
697 1.1 cgd }
698 1.1 cgd
699 1.13 pk int
700 1.45 wiz check_space(void)
701 1.1 cgd {
702 1.32 lukem FILE *fp;
703 1.15 mycroft off_t minfree, spacefree, kernelsize, needed;
704 1.13 pk struct stat st;
705 1.13 pk struct statfs fsbuf;
706 1.45 wiz char mbuf[100], path[MAXPATHLEN];
707 1.35 thorpej
708 1.35 thorpej #ifdef __GNUC__
709 1.35 thorpej (void) &minfree;
710 1.35 thorpej #endif
711 1.13 pk
712 1.43 darrenr if (stat(kernel, &st) < 0) {
713 1.43 darrenr syslog(LOG_ERR, "%s: %m", kernel);
714 1.13 pk exit(1);
715 1.13 pk }
716 1.15 mycroft kernelsize = st.st_blocks * S_BLKSIZE;
717 1.13 pk if (statfs(dirname, &fsbuf) < 0) {
718 1.13 pk syslog(LOG_ERR, "%s: %m", dirname);
719 1.13 pk exit(1);
720 1.13 pk }
721 1.37 sommerfe spacefree = fsbuf.f_bavail;
722 1.37 sommerfe spacefree *= fsbuf.f_bsize;
723 1.37 sommerfe spacefree /= 1024;
724 1.1 cgd
725 1.13 pk (void)snprintf(path, sizeof(path), "%s/minfree", dirname);
726 1.13 pk if ((fp = fopen(path, "r")) == NULL)
727 1.13 pk minfree = 0;
728 1.13 pk else {
729 1.45 wiz if (fgets(mbuf, sizeof(mbuf), fp) == NULL)
730 1.13 pk minfree = 0;
731 1.13 pk else
732 1.45 wiz minfree = atoi(mbuf);
733 1.13 pk (void)fclose(fp);
734 1.1 cgd }
735 1.13 pk
736 1.15 mycroft needed = (dumpsize + kernelsize) / 1024;
737 1.13 pk if (minfree > 0 && spacefree - needed < minfree) {
738 1.13 pk syslog(LOG_WARNING,
739 1.40 mycroft "no dump, not enough free space in %s", dirname);
740 1.13 pk return (0);
741 1.1 cgd }
742 1.13 pk if (spacefree - needed < minfree)
743 1.13 pk syslog(LOG_WARNING,
744 1.13 pk "dump performed, but free space threshold crossed");
745 1.13 pk return (1);
746 1.1 cgd }
747 1.1 cgd
748 1.13 pk int
749 1.52 wiz Open(const char *name, int rw)
750 1.1 cgd {
751 1.1 cgd int fd;
752 1.1 cgd
753 1.13 pk if ((fd = open(name, rw, 0)) < 0) {
754 1.13 pk syslog(LOG_ERR, "%s: %m", name);
755 1.1 cgd exit(1);
756 1.1 cgd }
757 1.1 cgd return (fd);
758 1.1 cgd }
759 1.1 cgd
760 1.13 pk void
761 1.45 wiz Lseek(int fd, off_t off, int flag)
762 1.1 cgd {
763 1.13 pk off_t ret;
764 1.1 cgd
765 1.1 cgd ret = lseek(fd, off, flag);
766 1.1 cgd if (ret == -1) {
767 1.13 pk syslog(LOG_ERR, "lseek: %m");
768 1.1 cgd exit(1);
769 1.1 cgd }
770 1.1 cgd }
771 1.1 cgd
772 1.13 pk int
773 1.45 wiz Create(char *file, int mode)
774 1.1 cgd {
775 1.32 lukem int fd;
776 1.1 cgd
777 1.17 mycroft fd = open(file, O_WRONLY | O_CREAT | O_TRUNC, mode);
778 1.1 cgd if (fd < 0) {
779 1.13 pk syslog(LOG_ERR, "%s: %m", file);
780 1.1 cgd exit(1);
781 1.1 cgd }
782 1.1 cgd return (fd);
783 1.1 cgd }
784 1.1 cgd
785 1.13 pk void
786 1.45 wiz Write(int fd, void *bp, int size)
787 1.1 cgd {
788 1.1 cgd int n;
789 1.1 cgd
790 1.13 pk if ((n = write(fd, bp, size)) < size) {
791 1.13 pk syslog(LOG_ERR, "write: %s", strerror(n == -1 ? errno : EIO));
792 1.1 cgd exit(1);
793 1.1 cgd }
794 1.1 cgd }
795 1.1 cgd
796 1.13 pk void
797 1.45 wiz usage(void)
798 1.1 cgd {
799 1.53 lukem (void)syslog(LOG_ERR,
800 1.53 lukem "usage: savecore [-cfvz] [-N system] [-Z level] directory");
801 1.1 cgd exit(1);
802 1.1 cgd }
803