Remove the need to implement the notification iterator's "get" method
[babeltrace.git] / plugins / muxer / muxer.c
CommitLineData
34ac9eaf 1/*
0cb31e39 2 * muxer.c
34ac9eaf 3 *
0cb31e39 4 * Babeltrace Trace Muxer
34ac9eaf
JG
5 *
6 * Copyright 2016 Jérémie Galarneau <jeremie.galarneau@efficios.com>
7 *
8 * Author: Jérémie Galarneau <jeremie.galarneau@efficios.com>
9 *
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:
16 *
17 * The above copyright notice and this permission notice shall be included in
18 * all copies or substantial portions of the Software.
19 *
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
26 * SOFTWARE.
27 */
28
33b34c43
PP
29#include <babeltrace/plugin/plugin-dev.h>
30#include <babeltrace/component/component.h>
d71dcf2c 31#include <babeltrace/component/component-filter.h>
33b34c43
PP
32#include <babeltrace/component/notification/notification.h>
33#include <babeltrace/component/notification/iterator.h>
34#include <babeltrace/component/notification/event.h>
7d61fa8e 35#include <plugins-common.h>
0cb31e39 36#include "muxer.h"
34ac9eaf
JG
37
38static
0cb31e39 39void destroy_muxer_data(struct muxer *muxer)
34ac9eaf 40{
0cb31e39 41 g_free(muxer);
34ac9eaf
JG
42}
43
44static
0cb31e39 45struct muxer *create_muxer(void)
34ac9eaf 46{
0cb31e39 47 struct muxer *muxer;
34ac9eaf 48
0cb31e39
JG
49 muxer = g_new0(struct muxer, 1);
50 if (!muxer) {
34ac9eaf
JG
51 goto end;
52 }
53end:
0cb31e39 54 return muxer;
34ac9eaf
JG
55}
56
57static
64cadc66 58void finalize_muxer(struct bt_private_component *component)
34ac9eaf 59{
890882ef 60 void *data = bt_private_component_get_user_data(component);
34ac9eaf 61
0cb31e39 62 destroy_muxer_data(data);
34ac9eaf
JG
63}
64
0cb31e39 65enum bt_component_status muxer_component_init(
890882ef 66 struct bt_private_component *component, struct bt_value *params,
7d61fa8e 67 UNUSED_VAR void *init_method_data)
34ac9eaf
JG
68{
69 enum bt_component_status ret;
0cb31e39 70 struct muxer *muxer = create_muxer();
34ac9eaf 71
0cb31e39 72 if (!muxer) {
34ac9eaf
JG
73 ret = BT_COMPONENT_STATUS_NOMEM;
74 goto end;
75 }
76
890882ef 77 ret = bt_private_component_set_user_data(component, muxer);
34ac9eaf
JG
78 if (ret != BT_COMPONENT_STATUS_OK) {
79 goto error;
80 }
81end:
82 return ret;
83error:
0cb31e39 84 destroy_muxer_data(muxer);
34ac9eaf
JG
85 return ret;
86}
87
d3eb6e8f 88static
41a2b7ae 89struct bt_notification_iterator_next_return muxer_iterator_next(
890882ef 90 struct bt_private_notification_iterator *iterator)
d3eb6e8f 91{
41a2b7ae
PP
92 struct bt_notification_iterator_next_return ret = {
93 .status = BT_NOTIFICATION_ITERATOR_STATUS_ERROR,
94 };
d3eb6e8f 95
41a2b7ae 96 return ret;
d3e4dcd8
PP
97}
98
34ac9eaf 99/* Initialize plug-in entry points. */
6ba0b073 100BT_PLUGIN(muxer);
0cb31e39 101BT_PLUGIN_DESCRIPTION("Babeltrace Trace Muxer Plug-In.");
34ac9eaf
JG
102BT_PLUGIN_AUTHOR("Jérémie Galarneau");
103BT_PLUGIN_LICENSE("MIT");
41a2b7ae 104BT_PLUGIN_FILTER_COMPONENT_CLASS(muxer, muxer_iterator_next);
d3e4dcd8 105BT_PLUGIN_FILTER_COMPONENT_CLASS_DESCRIPTION(muxer,
6ba0b073 106 "Time-correlate multiple traces.");
d3e4dcd8 107BT_PLUGIN_FILTER_COMPONENT_CLASS_INIT_METHOD(muxer, muxer_component_init);
64cadc66 108BT_PLUGIN_FILTER_COMPONENT_CLASS_FINALIZE_METHOD(muxer, finalize_muxer);
This page took 0.031965 seconds and 4 git commands to generate.