continue;
stream_pos->packet_seek(&stream_pos->parent, i, SEEK_SET);
+ ret = bt_packet_seek_get_error();
+ if (ret < 0) {
+ return EOF;
+ }
do {
ret = stream_read_event(cfs);
} while (cfs->parent.real_timestamp < timestamp && ret == 0);
*/
for (i = stream_pos->packet_index->len - 1; i >= 0; i--) {
stream_pos->packet_seek(&stream_pos->parent, i, SEEK_SET);
+ ret = bt_packet_seek_get_error();
+ if (ret < 0) {
+ return EOF;
+ }
count = 0;
/* read each event until we reach the end of the stream */
do {
}
ret = stream_read_event(file_stream);
- if (file_stream->pos.parent.trace->interval_set) {
+ if (file_stream->pos.parent.trace &&
+ file_stream->pos.parent.trace->interval_set) {
event_outside_interval =
file_stream->parent.real_timestamp >
file_stream->pos.parent.trace->interval_real.timestamp_end;
*/
ret = 0;
goto reinsert;
+ } else if (ret == -ERANGE) {
+ removed = bt_heap_remove(iter->stream_heap);
+ assert(removed == file_stream);
+ goto end;
} else if (ret) {
goto end;
}