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