#include <stdlib.h>
static
-int bt_dummy_write_event(struct stream_pos *ppos, struct ctf_stream *stream)
+int bt_dummy_write_event(struct stream_pos *ppos, struct ctf_stream_definition *stream)
{
return 0;
}
}
static
-int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream *stream)
+int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition *stream)
{
struct ctf_text_stream_pos *pos =
}
static
-struct ctf_event_definition *extract_ctf_stream_event(struct ctf_stream *stream)
+struct ctf_event_definition *extract_ctf_stream_event(struct ctf_stream_definition *stream)
{
struct ctf_stream_declaration *stream_class = stream->stream_class;
struct ctf_event *event_class;
}
void process_callbacks(struct bt_ctf_iter *iter,
- struct ctf_stream *stream)
+ struct ctf_stream_definition *stream)
{
struct bt_stream_callbacks *bt_stream_cb;
struct bt_callback_chain *bt_chain;
* Update stream current timestamp, keep at clock frequency.
*/
static
-void ctf_update_timestamp(struct ctf_stream *stream,
+void ctf_update_timestamp(struct ctf_stream_definition *stream,
struct definition_integer *integer_definition)
{
struct declaration_integer *integer_declaration =
* applying offsets as needed (unix time).
*/
void ctf_print_timestamp(FILE *fp,
- struct ctf_stream *stream,
+ struct ctf_stream_definition *stream,
uint64_t timestamp)
{
uint64_t ts_sec = 0, ts_nsec;
}
static
-int ctf_read_event(struct stream_pos *ppos, struct ctf_stream *stream)
+int ctf_read_event(struct stream_pos *ppos, struct ctf_stream_definition *stream)
{
struct ctf_stream_pos *pos =
container_of(ppos, struct ctf_stream_pos, parent);
}
static
-int ctf_write_event(struct stream_pos *pos, struct ctf_stream *stream)
+int ctf_write_event(struct stream_pos *pos, struct ctf_stream_definition *stream)
{
struct ctf_stream_declaration *stream_class = stream->stream_class;
struct ctf_event_definition *event;
static
struct ctf_event_definition *create_event_definitions(struct ctf_trace *td,
- struct ctf_stream *stream,
+ struct ctf_stream_definition *stream,
struct ctf_event *event)
{
struct ctf_event_definition *stream_event = g_new0(struct ctf_event_definition, 1);
}
static
-int create_stream_definitions(struct ctf_trace *td, struct ctf_stream *stream)
+int create_stream_definitions(struct ctf_trace *td, struct ctf_stream_definition *stream)
{
struct ctf_stream_declaration *stream_class;
int ret;
}
static
-int create_trace_definitions(struct ctf_trace *td, struct ctf_stream *stream)
+int create_trace_definitions(struct ctf_trace *td, struct ctf_stream_definition *stream)
{
int ret;
#include <babeltrace/ctf-ir/metadata.h>
static inline
-uint64_t ctf_get_timestamp_raw(struct ctf_stream *stream,
+uint64_t ctf_get_timestamp_raw(struct ctf_stream_definition *stream,
uint64_t timestamp)
{
uint64_t ts_nsec;
}
static inline
-uint64_t ctf_get_timestamp(struct ctf_stream *stream,
+uint64_t ctf_get_timestamp(struct ctf_stream_definition *stream,
uint64_t timestamp)
{
uint64_t ts_nsec;
struct ctf_trace;
struct ctf_stream_declaration;
-struct ctf_stream;
+struct ctf_stream_definition;
struct ctf_event;
-struct ctf_stream;
+struct ctf_stream_definition;
struct ctf_clock;
-struct ctf_stream {
+struct ctf_stream_definition {
struct ctf_stream_declaration *stream_class;
uint64_t timestamp; /* Current timestamp, in ns */
uint64_t event_id; /* Current event ID */
/* innermost definition scope. to be used as parent of stream. */
struct definition_scope *definition_scope;
GPtrArray *streams; /* Array of struct ctf_stream_declaration pointers */
- struct ctf_stream *metadata;
+ struct ctf_stream_definition *metadata;
GHashTable *clocks;
struct ctf_clock *single_clock; /* currently supports only one clock */
struct trace_collection *collection; /* Container of this trace */
CTF_STREAM_stream_id = (1 << 0),
} field_mask;
- GPtrArray *streams; /* Array of struct ctf_stream pointers */
+ GPtrArray *streams; /* Array of struct ctf_stream_definition pointers */
};
#define CTF_EVENT_SET_FIELD(ctf_event, field) \
int refcount; /* free when decremented to 0 */
};
-void process_callbacks(struct bt_ctf_iter *iter, struct ctf_stream *stream);
+void process_callbacks(struct bt_ctf_iter *iter, struct ctf_stream_definition *stream);
#endif /* _BABELTRACE_CALLBACKS_INTERNAL_H */
#include <babeltrace/ctf/callbacks-internal.h>
#include <glib.h>
-struct ctf_stream;
+struct ctf_stream_definition;
struct ctf_event_definition;
/*
* the structure to manipulate events
*/
struct bt_ctf_event {
- struct ctf_stream *stream;
+ struct ctf_stream_definition *stream;
struct ctf_event_definition *event;
};
#define TSDL_MAGIC 0x75D11D57
struct ctf_file_stream {
- struct ctf_stream parent;
+ struct ctf_stream_definition parent;
struct ctf_stream_pos pos; /* current stream position */
};
}
}
-void ctf_print_timestamp(FILE *fp, struct ctf_stream *stream,
+void ctf_print_timestamp(FILE *fp, struct ctf_stream_definition *stream,
uint64_t timestamp);
#endif /* _BABELTRACE_CTF_TYPES_H */
/* Preallocate this many fields for structures */
#define DEFAULT_NR_STRUCT_FIELDS 8
-struct ctf_stream;
+struct ctf_stream_definition;
struct stream_pos;
struct format;
struct definition;
/* read/write dispatch table. Specific to plugin used for stream. */
rw_dispatch *rw_table; /* rw dispatch table */
int (*event_cb)(struct stream_pos *pos,
- struct ctf_stream *stream);
+ struct ctf_stream_definition *stream);
};
static inline
stream_class = g_ptr_array_index(tin->streams, i);
/* for each file_stream */
for (j = 0; j < stream_class->streams->len; j++) {
- struct ctf_stream *stream;
+ struct ctf_stream_definition *stream;
struct ctf_file_stream *cfs;
stream = g_ptr_array_index(stream_class->streams, j);
i++) {
struct stream_saved_pos *saved_pos;
struct ctf_stream_pos *stream_pos;
- struct ctf_stream *stream;
+ struct ctf_stream_definition *stream;
saved_pos = &g_array_index(
iter_pos->u.restore->stream_saved_pos,
for (stream_id = 0;
stream_id < stream_class->streams->len;
stream_id++) {
- struct ctf_stream *stream;
+ struct ctf_stream_definition *stream;
struct ctf_file_stream *cfs;
struct stream_saved_pos saved_pos;