#include "jscan.h"
static void dump_debug_stream(struct jstream *js);
static int dump_debug_subrecord(struct jstream *js, off_t *off,
off_t recsize, int level);
static int dump_debug_payload(int16_t rectype, struct jstream *js, off_t off,
int recsize, int level);
void
dump_debug(struct jsession *ss, struct jdata *jd)
{
struct jstream *js;
if ((js = jaddrecord(ss, jd)) != NULL) {
dump_debug_stream(js);
jscan_dispose(js);
}
jsession_update_transid(ss, jd->jd_transid);
}
static void
dump_debug_stream(struct jstream *js)
{
struct journal_rawrecbeg head;
int16_t sid;
jsread(js, 0, &head, sizeof(head));
sid = head.streamid & JREC_STREAMID_MASK;
printf("STREAM %04x %016jx {\n",
(int)(u_int16_t)head.streamid,
(uintmax_t)head.transid);
if (sid >= JREC_STREAMID_JMIN && sid < JREC_STREAMID_JMAX) {
off_t off = sizeof(head);
dump_debug_subrecord(js, &off,
js->js_normalized_total - sizeof(head),
1);
} else {
switch(head.streamid & JREC_STREAMID_MASK) {
case JREC_STREAMID_SYNCPT & JREC_STREAMID_MASK:
printf(" SYNCPT\n");
break;
case JREC_STREAMID_PAD & JREC_STREAMID_MASK:
printf(" PAD\n");
break;
case JREC_STREAMID_DISCONT & JREC_STREAMID_MASK:
printf(" DISCONT\n");
break;
case JREC_STREAMID_ANNOTATE & JREC_STREAMID_MASK:
printf(" ANNOTATION\n");
break;
default:
printf(" UNKNOWN\n");
break;
}
}
printf("}\n");
}
static int
dump_debug_subrecord(struct jstream *js, off_t *off, off_t recsize, int level)
{
struct journal_subrecord sub;
int payload;
int subsize;
int error;
off_t base = *off;
error = 0;
while (recsize > 0) {
if ((error = jsread(js, base, &sub, sizeof(sub))) != 0) {
break;
}
printf("%*.*s", level * 4, level * 4, "");
printf("@%jd ", (intmax_t)base);
printf("RECORD %s [%04x/%d]", type_to_name(sub.rectype),
(int)(u_int16_t)sub.rectype, sub.recsize);
if (sub.recsize == -1) {
if ((sub.rectype & JMASK_NESTED) == 0) {
printf("Record size of -1 only works for nested records\n");
error = -1;
break;
}
payload = 0x7FFFFFFF;
subsize = 0x7FFFFFFF;
} else {
payload = sub.recsize - sizeof(sub);
subsize = (sub.recsize + 7) & ~7;
}
if (sub.rectype & JMASK_NESTED) {
printf(" {\n");
if (payload) {
*off = base + sizeof(sub);
error = dump_debug_subrecord(js, off, payload, level + 1);
}
printf("%*.*s}\n", level * 4, level * 4, "");
} else if (sub.rectype & JMASK_SUBRECORD) {
printf(" DATA (%d)", payload);
error = dump_debug_payload(sub.rectype, js, base + sizeof(sub), payload, level);
*off = base + sizeof(sub) + payload;
printf("\n");
} else {
printf("[%d bytes of unknown content]\n", sub.recsize);
}
if (error)
break;
if (sub.recsize == -1) {
recsize -= ((*off + 7) & ~7) - base;
base = (*off + 7) & ~7;
} else {
if (subsize == 0)
subsize = sizeof(sub);
recsize -= subsize;
base += subsize;
}
if (sub.rectype & JMASK_LAST)
break;
}
*off = base;
return(error);
}
static int
dump_debug_payload(int16_t rectype, struct jstream *js, off_t off,
int recsize, int level)
{
enum { DT_NONE, DT_STRING, DT_DEC, DT_HEX, DT_OCT,
DT_DATA, DT_TIMESTAMP } dt = DT_DATA;
const char *buf;
int error;
int i;
int j;
error = jsreadp(js, off, (const void **)&buf, recsize);
if (error)
return (error);
switch(rectype & ~JMASK_LAST) {
case JLEAF_PAD:
case JLEAF_ABORT:
break;
case JLEAF_FILEDATA:
break;
case JLEAF_PATH1:
case JLEAF_PATH2:
case JLEAF_PATH3:
case JLEAF_PATH4:
dt = DT_STRING;
break;
case JLEAF_UID:
case JLEAF_GID:
case JLEAF_VTYPE:
dt = DT_DEC;
break;
case JLEAF_MODES:
dt = DT_OCT;
break;
case JLEAF_FFLAGS:
dt = DT_HEX;
break;
case JLEAF_PID:
case JLEAF_PPID:
dt = DT_DEC;
break;
case JLEAF_COMM:
dt = DT_STRING;
break;
case JLEAF_ATTRNAME:
dt = DT_STRING;
break;
case JLEAF_PATH_REF:
dt = DT_STRING;
break;
case JLEAF_RESERVED_0F:
break;
case JLEAF_SYMLINKDATA:
dt = DT_STRING;
break;
case JLEAF_SEEKPOS:
dt = DT_HEX;
break;
case JLEAF_INUM:
dt = DT_HEX;
break;
case JLEAF_NLINK:
dt = DT_DEC;
break;
case JLEAF_FSID:
dt = DT_HEX;
break;
case JLEAF_SIZE:
dt = DT_HEX;
break;
case JLEAF_ATIME:
case JLEAF_MTIME:
case JLEAF_CTIME:
dt = DT_TIMESTAMP;
break;
case JLEAF_GEN:
dt = DT_HEX;
break;
case JLEAF_FLAGS:
dt = DT_HEX;
break;
case JLEAF_UDEV:
dt = DT_HEX;
break;
case JLEAF_FILEREV:
dt = DT_HEX;
break;
default:
break;
}
switch(dt) {
case DT_NONE:
break;
case DT_STRING:
printf(" \"");
for (i = 0; i < recsize; ++i)
stringout(stdout, buf[i], 1);
printf("\"");
break;
case DT_DEC:
switch(recsize) {
case 1:
printf(" %d", (int)*(const u_int8_t *)buf);
break;
case 2:
printf(" %d", (int)*(const u_int16_t *)buf);
break;
case 4:
printf(" %d", (int)*(const u_int32_t *)buf);
break;
case 8:
printf(" %jd", (intmax_t)*(const int64_t *)buf);
break;
default:
printf(" ?");
break;
}
break;
case DT_HEX:
switch(recsize) {
case 1:
printf(" 0x%02x", (int)*(const u_int8_t *)buf);
break;
case 2:
printf(" 0x%04x", (int)*(const u_int16_t *)buf);
break;
case 4:
printf(" 0x%08x", (int)*(const u_int32_t *)buf);
break;
case 8:
printf(" 0x%016jx", (uintmax_t)*(const u_int64_t *)buf);
break;
default:
printf(" ?");
break;
}
break;
case DT_OCT:
switch(recsize) {
case 1:
printf(" %03o", (int)*(const u_int8_t *)buf);
break;
case 2:
printf(" %06o", (int)*(const u_int16_t *)buf);
break;
case 4:
printf(" %011o", (int)*(const u_int32_t *)buf);
break;
case 8:
printf(" %022jo", (intmax_t)*(const int64_t *)buf);
break;
default:
printf(" ?");
break;
}
break;
case DT_TIMESTAMP:
{
struct tm *tp;
time_t t = ((const struct timespec *)buf)->tv_sec;
char outbuf[64];
tp = localtime(&t);
strftime(outbuf, sizeof(outbuf), " <%d-%b-%Y %H:%M:%S>", tp);
printf("%s", outbuf);
}
break;
case DT_DATA:
default:
if (recsize < 16) {
for (i = 0; i < recsize; ++i)
printf(" %02x", (int)(unsigned char)buf[i]);
printf(" \"");
for (i = 0; i < recsize; ++i)
stringout(stdout, buf[i], 0);
printf("\"");
} else {
printf(" {\n");
for (i = 0; i < recsize; i += 16) {
printf("%*.*s", level * 4 + 4, level * 4 + 4, "");
for (j = i; j < i + 16 && j < recsize; ++j)
printf(" %02x", (int)(unsigned char)buf[j]);
for (; j < i + 16; ++j)
printf(" ");
printf(" \"");
for (j = i; j < i + 16 && j < recsize; ++j)
stringout(stdout, buf[j], 0);
printf("\"\n");
}
printf("%*.*s}", level * 4, level * 4, "");
}
break;
}
return (0);
}
