/* For each event, print header, context, payload */
/* TODO: order events by timestamps across streams */
for (;;) {
- ret = sin->pos.parent.event_cb(&sin->pos.parent, sin->stream);
+ ret = sin->pos.parent.event_cb(&sin->pos.parent, &sin->stream);
if (ret == EOF)
break;
else if (ret) {
fprintf(stdout, "[error] Reading event failed.\n");
goto error;
}
- ret = sout->parent.event_cb(&sout->parent, sin->stream);
+ ret = sout->parent.event_cb(&sout->parent, &sin->stream);
if (ret) {
fprintf(stdout, "[error] Writing event failed.\n");
goto error;
/* For each stream (TODO: order events by timestamp) */
for (stream_id = 0; stream_id < tin->streams->len; stream_id++) {
- struct ctf_stream *stream = g_ptr_array_index(tin->streams, stream_id);
+ struct ctf_stream_class *stream = g_ptr_array_index(tin->streams, stream_id);
if (!stream)
continue;