projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix: handle packet_seek errors
[babeltrace.git]
/
formats
/
lttng-live
/
lttng-live-comm.c
diff --git
a/formats/lttng-live/lttng-live-comm.c
b/formats/lttng-live/lttng-live-comm.c
index e08926380efab45e306a01ec59607012f51fbc90..cb871a1318113e4909ba3db8ad3ceae132ed7e05 100644
(file)
--- a/
formats/lttng-live/lttng-live-comm.c
+++ b/
formats/lttng-live/lttng-live-comm.c
@@
-1223,7
+1223,8
@@
void ctf_live_packet_seek(struct bt_stream_pos *stream_pos, size_t index,
ret = handle_seek_position(index, whence, viewer_stream, pos,
file_stream);
if (ret != 0) {
ret = handle_seek_position(index, whence, viewer_stream, pos,
file_stream);
if (ret != 0) {
- return;
+ ret = -1;
+ goto end;
}
retry:
}
retry:
@@
-1265,7
+1266,8
@@
retry:
if (!lttng_live_should_quit()) {
fprintf(stderr, "[error] get_next_index failed\n");
}
if (!lttng_live_should_quit()) {
fprintf(stderr, "[error] get_next_index failed\n");
}
- return;
+ ret = -1;
+ goto end;
}
printf_verbose("Index received : packet_size : %" PRIu64
", offset %" PRIu64 ", content_size %" PRIu64
}
printf_verbose("Index received : packet_size : %" PRIu64
", offset %" PRIu64 ", content_size %" PRIu64
@@
-1294,7
+1296,8
@@
retry:
file_stream->parent.stream_id = stream_id;
viewer_stream->ctf_stream_id = stream_id;
file_stream->parent.stream_id = stream_id;
viewer_stream->ctf_stream_id = stream_id;
- return;
+ ret = 0;
+ goto end;
}
pos->packet_size = cur_index->packet_size;
}
pos->packet_size = cur_index->packet_size;
@@
-1386,15
+1389,18
@@
retry:
pos->offset = EOF;
if (!lttng_live_should_quit()) {
fprintf(stderr, "[error] get_data_packet failed\n");
pos->offset = EOF;
if (!lttng_live_should_quit()) {
fprintf(stderr, "[error] get_data_packet failed\n");
+ ret = -1;
+ } else {
+ ret = 0;
}
}
-
return
;
+
goto end
;
}
viewer_stream->data_pending = 0;
read_packet_header(pos, file_stream);
}
viewer_stream->data_pending = 0;
read_packet_header(pos, file_stream);
-
+ ret = 0;
end:
end:
-
return
;
+
bt_packet_seek_set_error(ret)
;
}
int lttng_live_create_viewer_session(struct lttng_live_ctx *ctx)
}
int lttng_live_create_viewer_session(struct lttng_live_ctx *ctx)
This page took
0.023656 seconds
and
4
git commands to generate.