Adapt `flt.utils.trimmer` to current API
[babeltrace.git] / lib / graph / component-source.c
CommitLineData
d94d92ac 1/*
e2f7325d 2 * Copyright 2017-2018 Philippe Proulx <pproulx@efficios.com>
d94d92ac
PP
3 * Copyright 2015 Jérémie Galarneau <jeremie.galarneau@efficios.com>
4 *
d94d92ac
PP
5 * Permission is hereby granted, free of charge, to any person obtaining a copy
6 * of this software and associated documentation files (the "Software"), to deal
7 * in the Software without restriction, including without limitation the rights
8 * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell
9 * copies of the Software, and to permit persons to whom the Software is
10 * furnished to do so, subject to the following conditions:
11 *
12 * The above copyright notice and this permission notice shall be included in
13 * all copies or substantial portions of the Software.
14 *
15 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
16 * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY,
17 * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE
18 * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER
19 * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM,
20 * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
21 * SOFTWARE.
22 */
23
24#define BT_LOG_TAG "COMP-SOURCE"
25#include <babeltrace/lib-logging-internal.h>
26
c5b9b441
PP
27#include <babeltrace/assert-internal.h>
28#include <babeltrace/assert-pre-internal.h>
d94d92ac
PP
29#include <babeltrace/compiler-internal.h>
30#include <babeltrace/graph/self-component-source.h>
0d72b8c3 31#include <babeltrace/graph/component-source-const.h>
d94d92ac
PP
32#include <babeltrace/graph/component-source-internal.h>
33#include <babeltrace/graph/component-internal.h>
34#include <babeltrace/graph/port-internal.h>
7474e7d3 35#include <babeltrace/graph/message-iterator-const.h>
d6e69534 36#include <babeltrace/graph/message-iterator-internal.h>
d94d92ac 37#include <babeltrace/graph/graph.h>
d94d92ac
PP
38
39BT_HIDDEN
40void bt_component_source_destroy(struct bt_component *component)
41{
42}
43
44BT_HIDDEN
45struct bt_component *bt_component_source_create(
0d72b8c3 46 const struct bt_component_class *class)
d94d92ac
PP
47{
48 struct bt_component_source *source = NULL;
49
50 source = g_new0(struct bt_component_source, 1);
51 if (!source) {
52 BT_LOGE_STR("Failed to allocate one source component.");
53 goto end;
54 }
55
56end:
57 return (void *) source;
58}
59
60uint64_t bt_component_source_get_output_port_count(
0d72b8c3 61 const struct bt_component_source *comp)
d94d92ac
PP
62{
63 return bt_component_get_output_port_count((void *) comp);
64}
65
0d72b8c3
PP
66const struct bt_port_output *
67bt_component_source_borrow_output_port_by_name_const(
68 const struct bt_component_source *comp, const char *name)
d94d92ac
PP
69{
70 return bt_component_borrow_output_port_by_name((void *) comp, name);
71}
72
73struct bt_self_component_port_output *
74bt_self_component_source_borrow_output_port_by_name(
75 struct bt_self_component_source *comp, const char *name)
76{
77 return (void *) bt_component_borrow_output_port_by_name(
78 (void *) comp, name);
79}
80
0d72b8c3
PP
81const struct bt_port_output *
82bt_component_source_borrow_output_port_by_index_const(
83 const struct bt_component_source *comp, uint64_t index)
d94d92ac
PP
84{
85 return bt_component_borrow_output_port_by_index((void *) comp, index);
86}
87
88struct bt_self_component_port_output *
89bt_self_component_source_borrow_output_port_by_index(
90 struct bt_self_component_source *comp, uint64_t index)
91{
92 return (void *) bt_component_borrow_output_port_by_index(
93 (void *) comp, index);
94}
95
96enum bt_self_component_status bt_self_component_source_add_output_port(
97 struct bt_self_component_source *self_comp,
98 const char *name, void *user_data,
99 struct bt_self_component_port_output **self_port)
100{
101 struct bt_component *comp = (void *) self_comp;
102 int status = BT_SELF_COMPONENT_STATUS_OK;
103 struct bt_port *port = NULL;
104
105 /* bt_component_add_output_port() logs details and errors */
106 port = (void *) bt_component_add_output_port(comp, name, user_data);
107 if (!port) {
108 status = BT_SELF_COMPONENT_STATUS_NOMEM;
109 goto end;
110 }
111
112 if (self_port) {
113 /* Move reference to user */
114 *self_port = (void *) port;
115 port = NULL;
116 }
117
118end:
119 bt_object_put_ref(port);
120 return status;
121}
c5b9b441
PP
122
123void bt_component_source_get_ref(
124 const struct bt_component_source *component_source)
125{
126 bt_object_get_ref(component_source);
127}
128
129void bt_component_source_put_ref(
130 const struct bt_component_source *component_source)
131{
132 bt_object_put_ref(component_source);
133}
This page took 0.029269 seconds and 4 git commands to generate.