xref: /freebsd/usr.bin/lastcomm/readrec.c (revision 02e9120893770924227138ba49df1edb3896112a)
1 /*-
2  * SPDX-License-Identifier: BSD-2-Clause
3  *
4  * Copyright (c) 2007 Diomidis Spinellis
5  * All rights reserved.
6  *
7  * Redistribution and use in source and binary forms, with or without
8  * modification, are permitted provided that the following conditions
9  * are met:
10  * 1. Redistributions of source code must retain the above copyright
11  *    notice, this list of conditions and the following disclaimer.
12  * 2. Redistributions in binary form must reproduce the above copyright
13  *    notice, this list of conditions and the following disclaimer in the
14  *    documentation and/or other materials provided with the distribution.
15  *
16  * THIS SOFTWARE IS PROVIDED BY THE AUTHOR AND CONTRIBUTORS ``AS IS'' AND
17  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19  * ARE DISCLAIMED.  IN NO EVENT SHALL THE AUTHOR OR CONTRIBUTORS BE LIABLE
20  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
21  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
22  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
23  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
24  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
25  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
26  * SUCH DAMAGE.
27  *
28  */
29 
30 #include <sys/param.h>
31 #include <sys/stat.h>
32 #include <sys/types.h>
33 #include <sys/acct.h>
34 
35 #include <errno.h>
36 #include <stddef.h>
37 #include <stdio.h>
38 #include <string.h>
39 
40 int	 readrec_forward(FILE *f, struct acctv3 *av2);
41 int	 readrec_backward(FILE *f, struct acctv3 *av2);
42 
43 /*
44  * Reverse offsetof: return the offset of field f
45  * from the end of the structure s.
46  */
47 #define roffsetof(s, f) (sizeof(s) - offsetof(s, f))
48 
49 /*
50  * Read exactly one record of size size from stream f into ptr.
51  * Failure to read the complete record is considered a file format error,
52  * and will set errno to EFTYPE.
53  * Return 0 on success, EOF on end of file or error.
54  */
55 static int
56 fread_record(void *ptr, size_t size, FILE *f)
57 {
58 	size_t rv;
59 
60 	if ((rv = fread(ptr, 1, size, f)) == size)
61 		return (0);
62 	else if (ferror(f) || rv == 0)
63 		return (EOF);
64 	else {
65 		/* Short read. */
66 		errno = EFTYPE;
67 		return (EOF);
68 	}
69 }
70 
71 /*
72  * Return the value of a comp_t field.
73  */
74 static float
75 decode_comp(comp_t v)
76 {
77 	int result, exp;
78 
79 	result = v & 017777;
80 	for (exp = v >> 13; exp; exp--)
81 		result <<= 3;
82 	return ((double)result / AHZV1);
83 }
84 
85 /*
86  * Read a v1 accounting record stored at the current
87  * position of stream f.
88  * Convert the data to the current record format.
89  * Return EOF on error or end-of-file.
90  */
91 static int
92 readrec_v1(FILE *f, struct acctv3 *av3)
93 {
94 	struct acctv1 av1;
95 	int rv;
96 
97 	if ((rv = fread_record(&av1, sizeof(av1), f)) == EOF)
98 		return (EOF);
99 	av3->ac_zero = 0;
100 	av3->ac_version = 3;
101 	av3->ac_len = av3->ac_len2 = sizeof(*av3);
102 	memcpy(av3->ac_comm, av1.ac_comm, AC_COMM_LEN);
103 	av3->ac_utime = decode_comp(av1.ac_utime) * 1000000;
104 	av3->ac_stime = decode_comp(av1.ac_stime) * 1000000;
105 	av3->ac_etime = decode_comp(av1.ac_etime) * 1000000;
106 	av3->ac_btime = av1.ac_btime;
107 	av3->ac_uid = av1.ac_uid;
108 	av3->ac_gid = av1.ac_gid;
109 	av3->ac_mem = av1.ac_mem;
110 	av3->ac_io = decode_comp(av1.ac_io);
111 	av3->ac_tty = av1.ac_tty;
112 	av3->ac_flagx = av1.ac_flag | ANVER;
113 	return (0);
114 }
115 
116 /*
117  * Read an v2 accounting record stored at the current
118  * position of stream f.
119  * Return EOF on error or end-of-file.
120  */
121 static int
122 readrec_v2(FILE *f, struct acctv3 *av3)
123 {
124 	struct acctv2 av2;
125 	int rv;
126 
127 	if ((rv = fread_record(&av2, sizeof(av2), f)) == EOF)
128 		return (EOF);
129 	av3->ac_zero = 0;
130 	av3->ac_version = 3;
131 	av3->ac_len = av3->ac_len2 = sizeof(*av3);
132 	memcpy(av3->ac_comm, av2.ac_comm, AC_COMM_LEN);
133 	av3->ac_utime = av2.ac_utime;
134 	av3->ac_stime = av2.ac_stime;
135 	av3->ac_etime = av2.ac_etime;
136 	av3->ac_btime = av2.ac_btime;
137 	av3->ac_uid = av2.ac_uid;
138 	av3->ac_gid = av2.ac_gid;
139 	av3->ac_mem = av2.ac_mem;
140 	av3->ac_io = av2.ac_io;
141 	av3->ac_tty = av2.ac_tty;
142 	av3->ac_flagx = av2.ac_flagx;
143 	return (0);
144 }
145 
146 /*
147  * Read an v2 accounting record stored at the current
148  * position of stream f.
149  * Return EOF on error or end-of-file.
150  */
151 static int
152 readrec_v3(FILE *f, struct acctv3 *av3)
153 {
154 
155 	return (fread_record(av3, sizeof(*av3), f));
156 }
157 
158 /*
159  * Read a new-style (post-v1) accounting record stored at
160  * the current position of stream f.
161  * Convert the data to the current record format.
162  * Return EOF on error or end-of-file.
163  */
164 static int
165 readrec_vx(FILE *f, struct acctv3 *av3)
166 {
167 	uint8_t magic, version;
168 
169 	if (fread_record(&magic, sizeof(magic), f) == EOF ||
170 	    fread_record(&version, sizeof(version), f) == EOF ||
171 	    ungetc(version, f) == EOF ||
172 	    ungetc(magic, f) == EOF)
173 		return (EOF);
174 	switch (version) {
175 	case 2:
176 		return (readrec_v2(f, av3));
177 	case 3:
178 		return (readrec_v3(f, av3));
179 
180 	/* Add handling for more versions here. */
181 
182 	default:
183 		errno = EFTYPE;
184 		return (EOF);
185 	}
186 }
187 
188 /*
189  * Read an accounting record stored at the current
190  * position of stream f.
191  * Old-format records are converted to the current record
192  * format.
193  * Return the number of records read (1 or 0 at the end-of-file),
194  * or EOF on error.
195  */
196 int
197 readrec_forward(FILE *f, struct acctv3 *av3)
198 {
199 	int magic, rv;
200 
201 	if ((magic = getc(f)) == EOF)
202 		return (ferror(f) ? EOF : 0);
203 	if (ungetc(magic, f) == EOF)
204 		return (EOF);
205 	if (magic != 0)
206 		/* Old record format. */
207 		rv = readrec_v1(f, av3);
208 	else
209 		/* New record formats. */
210 		rv = readrec_vx(f, av3);
211 	return (rv == EOF ? EOF : 1);
212 }
213 
214 /*
215  * Read an accounting record ending at the current
216  * position of stream f.
217  * Old-format records are converted to the current record
218  * format.
219  * The file pointer is positioned at the beginning of the
220  * record read.
221  * Return the number of records read (1 or 0 at the end-of-file),
222  * or EOF on error.
223  */
224 int
225 readrec_backward(FILE *f, struct acctv3 *av3)
226 {
227 	off_t pos;
228 	int c;
229 	uint16_t len;
230 
231 	if ((pos = ftell(f)) == -1)
232 		return (EOF);
233 	if (pos == 0)
234 		return (0);
235 	if (fseek(f, -roffsetof(struct acctv3, ac_trailer),
236 	    SEEK_CUR) == EOF ||
237 	    (c = getc(f)) == EOF)
238 		return (EOF);
239 	if (c & ANVER) {
240 		/*
241 		 * New record formats.  For v2 and v3 offset from the
242 		 * end for ac_len2 should be same.
243 		 */
244 		if (fseeko(f, pos - roffsetof(struct acctv2, ac_len2),
245 		    SEEK_SET) == EOF ||
246 		    fread_record(&len, sizeof(len), f) == EOF ||
247 		    fseeko(f, pos - len, SEEK_SET) == EOF ||
248 		    readrec_vx(f, av3) == EOF ||
249 		    fseeko(f, pos - len, SEEK_SET) == EOF)
250 			return (EOF);
251 		else
252 			return (1);
253 	} else {
254 		/* Old record format. */
255 		if (fseeko(f, pos - sizeof(struct acctv1), SEEK_SET) == EOF ||
256 		    readrec_v1(f, av3) == EOF ||
257 		    fseeko(f, pos - sizeof(struct acctv1), SEEK_SET) == EOF)
258 			return (EOF);
259 		else
260 			return (1);
261 	}
262 }
263