4 * Babeltrace Notification Iterator
6 * Copyright 2015 Jérémie Galarneau <jeremie.galarneau@efficios.com>
8 * Author: Jérémie Galarneau <jeremie.galarneau@efficios.com>
10 * Permission is hereby granted, free of charge, to any person obtaining a copy
11 * of this software and associated documentation files (the "Software"), to deal
12 * in the Software without restriction, including without limitation the rights
13 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
14 * copies of the Software, and to permit persons to whom the Software is
15 * furnished to do so, subject to the following conditions:
17 * The above copyright notice and this permission notice shall be included in
18 * all copies or substantial portions of the Software.
20 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
21 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
22 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
23 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
24 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
25 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
29 #include <babeltrace/compiler.h>
30 #include <babeltrace/ref.h>
31 #include <babeltrace/component/component.h>
32 #include <babeltrace/component/component-source-internal.h>
33 #include <babeltrace/component/component-class-internal.h>
34 #include <babeltrace/component/notification/iterator.h>
35 #include <babeltrace/component/notification/iterator-internal.h>
38 void bt_notification_iterator_destroy(struct bt_object
*obj
)
40 struct bt_notification_iterator
*iterator
;
41 struct bt_component_class
*comp_class
;
44 iterator
= container_of(obj
, struct bt_notification_iterator
,
46 assert(iterator
->component
);
47 comp_class
= iterator
->component
->class;
49 /* Call user-defined destroy method */
50 switch (comp_class
->type
) {
51 case BT_COMPONENT_CLASS_TYPE_SOURCE
:
53 struct bt_component_class_source
*source_class
;
55 source_class
= container_of(comp_class
, struct bt_component_class_source
, parent
);
57 if (source_class
->methods
.iterator
.destroy
) {
58 source_class
->methods
.iterator
.destroy(
59 bt_private_notification_iterator_from_notification_iterator(iterator
));
63 case BT_COMPONENT_CLASS_TYPE_FILTER
:
65 struct bt_component_class_filter
*filter_class
;
67 filter_class
= container_of(comp_class
, struct bt_component_class_filter
, parent
);
69 if (filter_class
->methods
.iterator
.destroy
) {
70 filter_class
->methods
.iterator
.destroy(
71 bt_private_notification_iterator_from_notification_iterator(iterator
));
80 BT_PUT(iterator
->component
);
85 struct bt_notification_iterator
*bt_notification_iterator_create(
86 struct bt_component
*component
)
88 enum bt_component_class_type type
;
89 struct bt_notification_iterator
*iterator
= NULL
;
95 type
= bt_component_get_class_type(component
);
97 case BT_COMPONENT_CLASS_TYPE_SOURCE
:
98 case BT_COMPONENT_CLASS_TYPE_FILTER
:
104 iterator
= g_new0(struct bt_notification_iterator
, 1);
109 iterator
->component
= bt_get(component
);
110 bt_object_init(iterator
, bt_notification_iterator_destroy
);
116 enum bt_notification_iterator_status
bt_notification_iterator_validate(
117 struct bt_notification_iterator
*iterator
)
119 enum bt_notification_iterator_status ret
=
120 BT_NOTIFICATION_ITERATOR_STATUS_OK
;
123 ret
= BT_NOTIFICATION_ITERATOR_STATUS_INVAL
;
130 void *bt_private_notification_iterator_get_user_data(
131 struct bt_private_notification_iterator
*private_iterator
)
133 struct bt_notification_iterator
*iterator
=
134 bt_notification_iterator_from_private(private_iterator
);
136 return iterator
? iterator
->user_data
: NULL
;
139 enum bt_notification_iterator_status
140 bt_private_notification_iterator_set_user_data(
141 struct bt_private_notification_iterator
*private_iterator
,
144 enum bt_notification_iterator_status ret
=
145 BT_NOTIFICATION_ITERATOR_STATUS_OK
;
146 struct bt_notification_iterator
*iterator
=
147 bt_notification_iterator_from_private(private_iterator
);
150 ret
= BT_NOTIFICATION_ITERATOR_STATUS_INVAL
;
154 iterator
->user_data
= data
;
159 struct bt_notification
*bt_notification_iterator_get_notification(
160 struct bt_notification_iterator
*iterator
)
162 struct bt_private_notification_iterator
*priv_iterator
=
163 bt_private_notification_iterator_from_notification_iterator(iterator
);
164 bt_component_class_notification_iterator_get_method get_method
= NULL
;
167 assert(iterator
->component
);
168 assert(iterator
->component
->class);
170 switch (iterator
->component
->class->type
) {
171 case BT_COMPONENT_CLASS_TYPE_SOURCE
:
173 struct bt_component_class_source
*source_class
=
174 container_of(iterator
->component
->class,
175 struct bt_component_class_source
, parent
);
177 assert(source_class
->methods
.iterator
.get
);
178 get_method
= source_class
->methods
.iterator
.get
;
181 case BT_COMPONENT_CLASS_TYPE_FILTER
:
183 struct bt_component_class_filter
*filter_class
=
184 container_of(iterator
->component
->class,
185 struct bt_component_class_filter
, parent
);
187 assert(filter_class
->methods
.iterator
.get
);
188 get_method
= filter_class
->methods
.iterator
.get
;
197 return get_method(priv_iterator
);
200 enum bt_notification_iterator_status
201 bt_notification_iterator_next(struct bt_notification_iterator
*iterator
)
203 struct bt_private_notification_iterator
*priv_iterator
=
204 bt_private_notification_iterator_from_notification_iterator(iterator
);
205 bt_component_class_notification_iterator_next_method next_method
= NULL
;
208 assert(iterator
->component
);
209 assert(iterator
->component
->class);
211 switch (iterator
->component
->class->type
) {
212 case BT_COMPONENT_CLASS_TYPE_SOURCE
:
214 struct bt_component_class_source
*source_class
=
215 container_of(iterator
->component
->class,
216 struct bt_component_class_source
, parent
);
218 assert(source_class
->methods
.iterator
.next
);
219 next_method
= source_class
->methods
.iterator
.next
;
222 case BT_COMPONENT_CLASS_TYPE_FILTER
:
224 struct bt_component_class_filter
*filter_class
=
225 container_of(iterator
->component
->class,
226 struct bt_component_class_filter
, parent
);
228 assert(filter_class
->methods
.iterator
.next
);
229 next_method
= filter_class
->methods
.iterator
.next
;
238 return next_method(priv_iterator
);
241 struct bt_component
*bt_notification_iterator_get_component(
242 struct bt_notification_iterator
*iterator
)
244 return bt_get(iterator
->component
);
247 enum bt_notification_iterator_status
bt_notification_iterator_seek_time(
248 struct bt_notification_iterator
*iterator
,
249 enum bt_notification_iterator_seek_origin seek_origin
,
252 enum bt_notification_iterator_status ret
=
253 BT_NOTIFICATION_ITERATOR_STATUS_UNSUPPORTED
;