projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Fix: get rid of consumed flag
[babeltrace.git]
/
formats
/
ctf
/
ctf.c
diff --git
a/formats/ctf/ctf.c
b/formats/ctf/ctf.c
index b3f7699afc925bca91b6fbf0dce5c38aca091ce5..cf9554739c6647701ecfd44132b7eacd80fdaa38 100644
(file)
--- a/
formats/ctf/ctf.c
+++ b/
formats/ctf/ctf.c
@@
-337,8
+337,6
@@
int ctf_read_event(struct stream_pos *ppos, struct ctf_stream_definition *stream
/* save the current position as a restore point */
pos->last_offset = pos->offset;
/* save the current position as a restore point */
pos->last_offset = pos->offset;
- /* we just read the event, it is consumed when used by the caller */
- stream->consumed = 0;
/*
* This is the EOF check after we've advanced the position in
/*
* This is the EOF check after we've advanced the position in
@@
-908,6
+906,7
@@
int ctf_open_trace_metadata_read(struct ctf_trace *td,
int ret = 0;
metadata_stream = g_new0(struct ctf_file_stream, 1);
int ret = 0;
metadata_stream = g_new0(struct ctf_file_stream, 1);
+ metadata_stream->pos.last_offset = LAST_OFFSET_POISON;
if (packet_seek) {
metadata_stream->pos.packet_seek = packet_seek;
if (packet_seek) {
metadata_stream->pos.packet_seek = packet_seek;
@@
-1402,6
+1401,7
@@
int ctf_open_file_stream_read(struct ctf_trace *td, const char *path, int flags,
}
file_stream = g_new0(struct ctf_file_stream, 1);
}
file_stream = g_new0(struct ctf_file_stream, 1);
+ file_stream->pos.last_offset = LAST_OFFSET_POISON;
if (packet_seek) {
file_stream->pos.packet_seek = packet_seek;
if (packet_seek) {
file_stream->pos.packet_seek = packet_seek;
@@
-1624,6
+1624,7
@@
int ctf_open_mmap_stream_read(struct ctf_trace *td,
struct ctf_file_stream *file_stream;
file_stream = g_new0(struct ctf_file_stream, 1);
struct ctf_file_stream *file_stream;
file_stream = g_new0(struct ctf_file_stream, 1);
+ file_stream->pos.last_offset = LAST_OFFSET_POISON;
ctf_init_mmap_pos(&file_stream->pos, mmap_info);
file_stream->pos.packet_seek = packet_seek;
ctf_init_mmap_pos(&file_stream->pos, mmap_info);
file_stream->pos.packet_seek = packet_seek;
This page took
0.023337 seconds
and
4
git commands to generate.