X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fviewer-stream.h;h=63fb71cb6ad39ed896e6f675456629612b0e586f;hb=8bb66c3cd60938352927ee865759433387324250;hp=7c42dfad39a7444038400101b88334aae622237a;hpb=ebb29c10d382c55529138ae70eb5a05bf3ccb9a6;p=lttng-tools.git diff --git a/src/bin/lttng-relayd/viewer-stream.h b/src/bin/lttng-relayd/viewer-stream.h index 7c42dfad3..63fb71cb6 100644 --- a/src/bin/lttng-relayd/viewer-stream.h +++ b/src/bin/lttng-relayd/viewer-stream.h @@ -50,8 +50,7 @@ struct relay_viewer_stream { struct relay_stream *stream; struct { - /* FD from which to read the stream data. */ - struct stream_fd *fd; + struct fs_handle *handle; struct lttng_trace_chunk *trace_chunk; } stream_file; /* index file from which to read the index data. */ @@ -81,6 +80,7 @@ struct relay_viewer_stream { }; struct relay_viewer_stream *viewer_stream_create(struct relay_stream *stream, + struct lttng_trace_chunk *viewer_trace_chunk, enum lttng_viewer_seek seek_t); struct relay_viewer_stream *viewer_stream_get_by_id(uint64_t id); @@ -90,5 +90,7 @@ int viewer_stream_rotate(struct relay_viewer_stream *vstream); bool viewer_stream_is_tracefile_seq_readable(struct relay_viewer_stream *vstream, uint64_t seq); void print_viewer_streams(void); +void viewer_stream_close_files(struct relay_viewer_stream *vstream); +void viewer_stream_sync_tracefile_array_tail(struct relay_viewer_stream *vstream); #endif /* _VIEWER_STREAM_H */