X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=lib%2Fgraph%2Fiterator.c;h=a2111746793fa71a8def54e06bbc022a37cc66d7;hb=56e18c4ce186892c36d7f2cb5078087425e60134;hp=0deb40c7721467bd3f40b3b5ca5d93cd1bbc2306;hpb=d4393e0875e7b08f6ee97d617cc5f2c9286742a4;p=babeltrace.git diff --git a/lib/graph/iterator.c b/lib/graph/iterator.c index 0deb40c7..a2111746 100644 --- a/lib/graph/iterator.c +++ b/lib/graph/iterator.c @@ -30,12 +30,12 @@ #include #include -#include -#include -#include -#include -#include -#include +#include +#include +#include +#include +#include +#include #include #include #include @@ -53,7 +53,6 @@ #include #include #include -#include #include #include #include @@ -69,16 +68,9 @@ */ #define NOTIF_BATCH_SIZE 15 -struct discarded_elements_state { - struct bt_clock_value *cur_begin; - uint64_t cur_count; -}; - struct stream_state { struct bt_stream *stream; /* owned by this */ struct bt_packet *cur_packet; /* owned by this */ - struct discarded_elements_state discarded_packets_state; - struct discarded_elements_state discarded_events_state; uint64_t expected_notif_seq_num; bt_bool is_ended; }; @@ -96,8 +88,6 @@ void destroy_stream_state(struct stream_state *stream_state) bt_put(stream_state->cur_packet); BT_LOGV_STR("Putting stream state's stream."); bt_put(stream_state->stream); - bt_put(stream_state->discarded_packets_state.cur_begin); - bt_put(stream_state->discarded_events_state.cur_begin); g_free(stream_state); } @@ -112,15 +102,6 @@ struct stream_state *create_stream_state(struct bt_stream *stream) goto end; } - /* - * The packet index is a monotonic counter which may not start - * at 0 at the beginning of the stream. We therefore need to - * have an internal object initial state of -1ULL to distinguish - * between initial state and having seen a packet with - * the sequence number 0. - */ - stream_state->discarded_packets_state.cur_count = -1ULL; - /* * We keep a reference to the stream until we know it's ended. */