X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=formats%2Fctf%2Fevents.c;h=0e32d21e3542b72bee804c6eba37a39527e0c9ea;hp=b35f54a8ecba9cee1f5000323b47b3c082462c7a;hb=a7765dd4491b15629e3884493db0f29611b84e65;hpb=48d5f76c4831624cb4332c7707c2615c2474284c diff --git a/formats/ctf/events.c b/formats/ctf/events.c index b35f54a8..0e32d21e 100644 --- a/formats/ctf/events.c +++ b/formats/ctf/events.c @@ -38,86 +38,6 @@ */ __thread int bt_ctf_last_field_error = 0; -struct bt_ctf_iter *bt_ctf_iter_create(struct bt_context *ctx, - struct bt_iter_pos *begin_pos, - struct bt_iter_pos *end_pos) -{ - struct bt_ctf_iter *iter; - int ret; - - iter = g_new0(struct bt_ctf_iter, 1); - ret = bt_iter_init(&iter->parent, ctx, begin_pos, end_pos); - if (ret) { - g_free(iter); - return NULL; - } - iter->callbacks = g_array_new(0, 1, sizeof(struct bt_stream_callbacks)); - iter->recalculate_dep_graph = 0; - iter->main_callbacks.callback = NULL; - iter->dep_gc = g_ptr_array_new(); - return iter; -} - -void bt_ctf_iter_destroy(struct bt_ctf_iter *iter) -{ - struct bt_stream_callbacks *bt_stream_cb; - struct bt_callback_chain *bt_chain; - int i, j; - - /* free all events callbacks */ - if (iter->main_callbacks.callback) - g_array_free(iter->main_callbacks.callback, TRUE); - - /* free per-event callbacks */ - for (i = 0; i < iter->callbacks->len; i++) { - bt_stream_cb = &g_array_index(iter->callbacks, - struct bt_stream_callbacks, i); - if (!bt_stream_cb || !bt_stream_cb->per_id_callbacks) - continue; - for (j = 0; j < bt_stream_cb->per_id_callbacks->len; j++) { - bt_chain = &g_array_index(bt_stream_cb->per_id_callbacks, - struct bt_callback_chain, j); - if (bt_chain->callback) { - g_array_free(bt_chain->callback, TRUE); - } - } - g_array_free(bt_stream_cb->per_id_callbacks, TRUE); - } - - bt_iter_fini(&iter->parent); - g_free(iter); -} - -struct bt_iter *bt_ctf_get_iter(struct bt_ctf_iter *iter) -{ - return &iter->parent; -} - -struct bt_ctf_event *bt_ctf_iter_read_event(struct bt_ctf_iter *iter) -{ - struct ctf_file_stream *file_stream; - struct bt_ctf_event *ret = &iter->current_ctf_event; - - file_stream = heap_maximum(iter->parent.stream_heap); - if (!file_stream) { - /* end of file for all streams */ - goto stop; - } - ret->stream = &file_stream->parent; - ret->event = g_ptr_array_index(ret->stream->events_by_id, - ret->stream->event_id); - - if (ret->stream->stream_id > iter->callbacks->len) - goto end; - - process_callbacks(iter, ret->stream); - -end: - return ret; -stop: - return NULL; -} - struct definition *bt_ctf_get_top_level_scope(struct bt_ctf_event *event, enum bt_ctf_scope scope) {