continue;
stream_pos->packet_seek(&stream_pos->parent, i, SEEK_SET);
- while (cfs->parent.timestamp < timestamp) {
+ do {
ret = stream_read_event(cfs);
- if (ret < 0)
- break;
- }
+ } while (cfs->parent.timestamp < timestamp && ret >= 0);
+
return 0;
}
return EOF;
/* for each stream_class */
for (i = 0; i < tin->streams->len; i++) {
- struct ctf_stream_class *stream_class;
+ struct ctf_stream_declaration *stream_class;
stream_class = g_ptr_array_index(tin->streams, i);
/* for each file_stream */
for (j = 0; j < stream_class->streams->len; j++) {
- struct ctf_stream *stream;
+ struct ctf_stream_definition *stream;
struct ctf_file_stream *cfs;
stream = g_ptr_array_index(stream_class->streams, j);
i++) {
struct stream_saved_pos *saved_pos;
struct ctf_stream_pos *stream_pos;
- struct ctf_stream *stream;
+ struct ctf_stream_definition *stream;
saved_pos = &g_array_index(
iter_pos->u.restore->stream_saved_pos,
/* Populate heap with each stream */
for (stream_id = 0; stream_id < tin->streams->len;
stream_id++) {
- struct ctf_stream_class *stream;
+ struct ctf_stream_declaration *stream;
int filenr;
stream = g_ptr_array_index(tin->streams,
for (stream_class_id = 0; stream_class_id < tin->streams->len;
stream_class_id++) {
- struct ctf_stream_class *stream_class;
+ struct ctf_stream_declaration *stream_class;
stream_class = g_ptr_array_index(tin->streams,
stream_class_id);
for (stream_id = 0;
stream_id < stream_class->streams->len;
stream_id++) {
- struct ctf_stream *stream;
+ struct ctf_stream_definition *stream;
struct ctf_file_stream *cfs;
struct stream_saved_pos saved_pos;
/* Populate heap with each stream */
for (stream_id = 0; stream_id < tin->streams->len;
stream_id++) {
- struct ctf_stream_class *stream;
+ struct ctf_stream_declaration *stream;
int filenr;
stream = g_ptr_array_index(tin->streams, stream_id);
/* Populate heap with each stream */
for (stream_id = 0; stream_id < tin->streams->len;
stream_id++) {
- struct ctf_stream_class *stream;
+ struct ctf_stream_declaration *stream;
int filenr;
stream = g_ptr_array_index(tin->streams, stream_id);