projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
lib: notification iterator: transfer a batch of notifications
[babeltrace.git]
/
plugins
/
ctf
/
fs-src
/
data-stream-file.h
diff --git
a/plugins/ctf/fs-src/data-stream-file.h
b/plugins/ctf/fs-src/data-stream-file.h
index 56397dff46d31c351be035119ad14967706b9049..be035606e293870757bda19f6dc586b4364a9f89 100644
(file)
--- a/
plugins/ctf/fs-src/data-stream-file.h
+++ b/
plugins/ctf/fs-src/data-stream-file.h
@@
-27,7
+27,7
@@
#include <stdbool.h>
#include <glib.h>
#include <babeltrace/babeltrace-internal.h>
#include <stdbool.h>
#include <glib.h>
#include <babeltrace/babeltrace-internal.h>
-#include <babeltrace/
ctf-ir/
trace.h>
+#include <babeltrace/
babel
trace.h>
#include "../common/notif-iter/notif-iter.h"
#include "lttng-index.h"
#include "../common/notif-iter/notif-iter.h"
#include "lttng-index.h"
@@
-85,17
+85,20
@@
struct ctf_fs_ds_file_info {
};
struct ctf_fs_ds_file {
};
struct ctf_fs_ds_file {
+ /* Weak */
+ struct bt_graph *graph;
+
/* Owned by this */
struct ctf_fs_file *file;
/* Owned by this */
/* Owned by this */
struct ctf_fs_file *file;
/* Owned by this */
- struct bt_
ctf_
stream *stream;
+ struct bt_stream *stream;
/* Owned by this */
struct bt_clock_class_priority_map *cc_prio_map;
/* Weak */
/* Owned by this */
struct bt_clock_class_priority_map *cc_prio_map;
/* Weak */
- struct bt_
ctf_
notif_iter *notif_iter;
+ struct bt_notif_iter *notif_iter;
void *mmap_addr;
void *mmap_addr;
@@
-105,12
+108,9
@@
struct ctf_fs_ds_file {
*/
size_t mmap_max_len;
*/
size_t mmap_max_len;
- /* Length of the current mapping. */
+ /* Length of the current mapping.
Never exceeds the file's length.
*/
size_t mmap_len;
size_t mmap_len;
- /* Length of the current mapping which *exists* in the backing file. */
- size_t mmap_valid_len;
-
/* Offset in the file where the current mapping starts. */
off_t mmap_offset;
/* Offset in the file where the current mapping starts. */
off_t mmap_offset;
@@
-126,21
+126,23
@@
struct ctf_fs_ds_file {
BT_HIDDEN
struct ctf_fs_ds_file *ctf_fs_ds_file_create(
struct ctf_fs_trace *ctf_fs_trace,
BT_HIDDEN
struct ctf_fs_ds_file *ctf_fs_ds_file_create(
struct ctf_fs_trace *ctf_fs_trace,
- struct bt_ctf_notif_iter *notif_iter,
- struct bt_ctf_stream *stream, const char *path);
+ struct bt_graph *graph,
+ struct bt_notif_iter *notif_iter,
+ struct bt_stream *stream, const char *path);
BT_HIDDEN
BT_HIDDEN
-int ctf_fs_ds_file_
get
_packet_header_context_fields(
+int ctf_fs_ds_file_
borrow
_packet_header_context_fields(
struct ctf_fs_ds_file *ds_file,
struct ctf_fs_ds_file *ds_file,
- struct bt_
ctf_
field **packet_header_field,
- struct bt_
ctf_
field **packet_context_field);
+ struct bt_field **packet_header_field,
+ struct bt_field **packet_context_field);
BT_HIDDEN
void ctf_fs_ds_file_destroy(struct ctf_fs_ds_file *stream);
BT_HIDDEN
BT_HIDDEN
void ctf_fs_ds_file_destroy(struct ctf_fs_ds_file *stream);
BT_HIDDEN
-struct bt_notification_iterator_next_return ctf_fs_ds_file_next(
- struct ctf_fs_ds_file *stream);
+enum bt_notification_iterator_status ctf_fs_ds_file_next(
+ struct ctf_fs_ds_file *ds_file,
+ struct bt_notification **notif);
BT_HIDDEN
struct ctf_fs_ds_index *ctf_fs_ds_file_build_index(
BT_HIDDEN
struct ctf_fs_ds_index *ctf_fs_ds_file_build_index(
@@
-149,6
+151,6
@@
struct ctf_fs_ds_index *ctf_fs_ds_file_build_index(
BT_HIDDEN
void ctf_fs_ds_index_destroy(struct ctf_fs_ds_index *index);
BT_HIDDEN
void ctf_fs_ds_index_destroy(struct ctf_fs_ds_index *index);
-extern struct bt_
ctf_
notif_iter_medium_ops ctf_fs_ds_file_medops;
+extern struct bt_notif_iter_medium_ops ctf_fs_ds_file_medops;
#endif /* CTF_FS_DS_FILE_H */
#endif /* CTF_FS_DS_FILE_H */
This page took
0.031268 seconds
and
4
git commands to generate.