projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix: Report success even if we find at least one valid stream in find_max_timestamp_c...
[babeltrace.git]
/
lib
/
iterator.c
diff --git
a/lib/iterator.c
b/lib/iterator.c
index 411b377ecf8cda2e6a1ec2ada151e0ed3d944eae..b205a93764ddc1940db73a35365977a586314b7b 100644
(file)
--- a/
lib/iterator.c
+++ b/
lib/iterator.c
@@
-253,7
+253,7
@@
static int find_max_timestamp_ctf_stream_class(
struct ctf_file_stream **cfsp,
uint64_t *max_timestamp)
{
struct ctf_file_stream **cfsp,
uint64_t *max_timestamp)
{
- int ret = EOF, i;
+ int ret = EOF, i
, found = 0
;
for (i = 0; i < stream_class->streams->len; i++) {
struct ctf_stream_definition *stream;
for (i = 0; i < stream_class->streams->len; i++) {
struct ctf_stream_definition *stream;
@@
-272,9
+272,13
@@
static int find_max_timestamp_ctf_stream_class(
if (current_max_ts >= *max_timestamp) {
*max_timestamp = current_max_ts;
*cfsp = cfs;
if (current_max_ts >= *max_timestamp) {
*max_timestamp = current_max_ts;
*cfsp = cfs;
+ found = 1;
}
}
assert(ret >= 0 || ret == EOF);
}
}
assert(ret >= 0 || ret == EOF);
+ if (found) {
+ return 0;
+ }
return ret;
}
return ret;
}
@@
-471,6
+475,10
@@
int bt_iter_set_pos(struct bt_iter *iter, const struct bt_iter_pos *iter_pos)
if (ret != 0 && ret != EOF) {
goto error;
}
if (ret != 0 && ret != EOF) {
goto error;
}
+ if (ret == EOF) {
+ /* Do not add EOF streams */
+ continue;
+ }
ret = heap_insert(iter->stream_heap, file_stream);
if (ret)
goto error;
ret = heap_insert(iter->stream_heap, file_stream);
if (ret)
goto error;
This page took
0.023336 seconds
and
4
git commands to generate.