fifolog/lib/fifolog_reader.c

59 	struct fifolog_reader *fr;
62 	fr = calloc(sizeof *fr, 1);
63 	if (fr == NULL)
66 	retval = fifolog_int_open(&fr->ff, fname, 0);
70 	fr->olen = fr->ff->recsize * 16;
71 	fr->obuf = calloc(fr->olen, 1);
72 	if (fr->obuf == NULL)
75 	i = inflateInit(fr->ff->zs);
78 	fr->magic = FIFOLOG_READER_MAGIC;
79 	return (fr);
130 fifolog_reader_seek(const struct fifolog_reader *fr, time_t t0)
138 	CHECK_OBJ_NOTNULL(fr, FIFOLOG_READER_MAGIC);
144 	e = fifolog_reader_findsync(fr->ff, &o);
149 	assert(fr->ff->recbuf[4] & FIFOLOG_FLG_SYNC);
150 	seq = be32dec(fr->ff->recbuf);
151 	t = be32dec(fr->ff->recbuf + 5);
155 		retval = fifolog_int_findend(fr->ff, &s);
159 		e = fifolog_reader_findsync(fr->ff, &s);
164 			seq = be32dec(fr->ff->recbuf);
165 			t = be32dec(fr->ff->recbuf + 5);
170 	s = st = (fr->ff->logsize - o) / 2;
173 		if (o + st > fr->ff->logsize + 1) {
177 		e = fifolog_int_read(fr->ff, o + st);
183 		seqs = be32dec(fr->ff->recbuf);
189 		if (!(fr->ff->recbuf[4] & FIFOLOG_FLG_SYNC)) {
194 		tt = be32dec(fr->ff->recbuf + 5);
202 	fprintf(stderr, "Read from %jx\n", o * fr->ff->recsize);
207 fifolog_reader_chop(struct fifolog_reader *fr, fifolog_reader_render_t *func, void *priv)
212 	p = fr->obuf;
213 	q = fr->obuf + (fr->olen - fr->ff->zs->avail_out);
222 			fr->now = be32dec(p + 4);
237 		func(priv, fr->now, u, p + w, v);
247 fifolog_reader_process(struct fifolog_reader *fr, off_t from, fifolog_reader_render_t *func, void *priv, time_t end)
256 	CHECK_OBJ_NOTNULL(fr, FIFOLOG_READER_MAGIC);
257 	zs = fr->ff->zs;
260 		e = fifolog_int_read(fr->ff, o);
263 		if (++o >= fr->ff->logsize)
265 		seq = be32dec(fr->ff->recbuf);
269 		zs->avail_in = fr->ff->recsize - 5;
270 		zs->next_in = fr->ff->recbuf + 5;
271 		if (fr->ff->recbuf[4] & FIFOLOG_FLG_1BYTE)
272 			zs->avail_in -= fr->ff->recbuf[fr->ff->recsize - 1];
273 		if (fr->ff->recbuf[4] & FIFOLOG_FLG_4BYTE)
275 			    be32dec(fr->ff->recbuf + fr->ff->recsize - 4);
276 		if (fr->ff->recbuf[4] & FIFOLOG_FLG_SYNC) {
279 			zs->next_out = fr->obuf;
280 			zs->avail_out = fr->olen;
281 			t = be32dec(fr->ff->recbuf + 5);
294 				    (int)(zs->next_in - fr->ff->recbuf),
296 				    (int)(zs->next_out - fr->obuf),
297 				    zs->avail_out, fr->olen);
312 			if (zs->avail_out != fr->olen) {
313 				q = fr->obuf + (fr->olen - zs->avail_out);
314 				p = fifolog_reader_chop(fr, func, priv);
316 					(void)memmove(fr->obuf, p, q - p);
317 				zs->avail_out = fr->olen - (q - p);
318 				zs->next_out = fr->obuf + (q - p);