Remove Babeltrace 1 files and reorganize the tree
[babeltrace.git] / lib / component / port.c
CommitLineData
8b285017 1/*
7d55361f 2 * port.c
8b285017
JG
3 *
4 * Babeltrace Port
5 *
6 * Copyright 2017 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
b2e0c907
PP
29#include <babeltrace/graph/component-internal.h>
30#include <babeltrace/graph/port-internal.h>
31#include <babeltrace/graph/connection-internal.h>
8b285017
JG
32#include <babeltrace/object-internal.h>
33#include <babeltrace/compiler.h>
34
35static
36void bt_port_destroy(struct bt_object *obj)
37{
38 struct bt_port *port = container_of(obj, struct bt_port, base);
39
40 if (port->name) {
41 g_string_free(port->name, TRUE);
42 }
8b285017
JG
43 g_free(port);
44}
45
890882ef
PP
46struct bt_port *bt_port_from_private_port(
47 struct bt_private_port *private_port)
48{
49 return bt_get(bt_port_from_private(private_port));
50}
51
8b285017
JG
52BT_HIDDEN
53struct bt_port *bt_port_create(struct bt_component *parent_component,
54 enum bt_port_type type, const char *name)
55{
72b913fb 56 struct bt_port *port = NULL;
8b285017
JG
57
58 assert(name);
59 assert(parent_component);
60 assert(type == BT_PORT_TYPE_INPUT || type == BT_PORT_TYPE_OUTPUT);
61
72b913fb 62 if (strlen(name) == 0) {
8b285017
JG
63 goto end;
64 }
65
66 port = g_new0(struct bt_port, 1);
67 if (!port) {
68 goto end;
69 }
70
71 bt_object_init(port, bt_port_destroy);
72 port->name = g_string_new(name);
73 if (!port->name) {
74 BT_PUT(port);
75 goto end;
76 }
77
78 port->type = type;
8b285017
JG
79
80 bt_object_set_parent(port, &parent_component->base);
81end:
82 return port;
83}
84
85const char *bt_port_get_name(struct bt_port *port)
86{
87 return port ? port->name->str : NULL;
88}
89
90enum bt_port_type bt_port_get_type(struct bt_port *port)
91{
92 return port ? port->type : BT_PORT_TYPE_UNKOWN;
93}
94
72b913fb 95struct bt_connection *bt_port_get_connection(struct bt_port *port)
8b285017 96{
72b913fb 97 struct bt_connection *connection = NULL;
8b285017 98
72b913fb 99 if (!port || !port->connection) {
8b285017
JG
100 goto end;
101 }
102
72b913fb 103 connection = bt_get(port->connection);
8b285017
JG
104end:
105 return connection;
106}
107
108struct bt_component *bt_port_get_component(struct bt_port *port)
109{
110 return (struct bt_component *) bt_object_get_parent(port);
111}
112
890882ef
PP
113struct bt_private_connection *bt_private_port_get_private_connection(
114 struct bt_private_port *private_port)
115{
116 return bt_private_connection_from_connection(bt_port_get_connection(
117 bt_port_from_private(private_port)));
118}
119
120struct bt_private_component *bt_private_port_get_private_component(
121 struct bt_private_port *private_port)
122{
123 return bt_private_component_from_component(bt_port_get_component(
124 bt_port_from_private(private_port)));
125}
126
8b285017 127BT_HIDDEN
72b913fb 128void bt_port_set_connection(struct bt_port *port,
8b285017 129 struct bt_connection *connection)
72b913fb
PP
130{
131 /*
132 * Don't take a reference on connection as its existence is
133 * guaranteed by the existence of the graph in which the
134 * connection exists.
135 */
136 port->connection = connection;
137}
138
890882ef
PP
139int bt_private_port_remove_from_component(
140 struct bt_private_port *private_port)
8b285017
JG
141{
142 int ret = 0;
890882ef 143 struct bt_port *port = bt_port_from_private(private_port);
72b913fb 144 struct bt_component *comp = NULL;
8b285017 145
72b913fb 146 if (!port) {
8b285017
JG
147 ret = -1;
148 goto end;
149 }
150
72b913fb
PP
151 comp = (void *) bt_object_get_parent(port);
152 ret = bt_component_remove_port(comp, port);
153
8b285017 154end:
72b913fb 155 bt_put(comp);
8b285017
JG
156 return ret;
157}
158
72b913fb 159int bt_port_disconnect(struct bt_port *port)
8b285017 160{
72b913fb 161 int ret = 0;
8b285017 162
72b913fb
PP
163 if (!port) {
164 ret = -1;
8b285017
JG
165 goto end;
166 }
167
72b913fb 168 if (port->connection) {
2038affb 169 bt_connection_disconnect_ports(port->connection);
72b913fb
PP
170 }
171
8b285017 172end:
72b913fb 173 return ret;
8b285017
JG
174}
175
72b913fb 176int bt_port_is_connected(struct bt_port *port)
8b285017 177{
72b913fb 178 int ret;
8b285017 179
72b913fb
PP
180 if (!port) {
181 ret = -1;
8b285017
JG
182 goto end;
183 }
184
72b913fb
PP
185 ret = port->connection ? 1 : 0;
186
8b285017 187end:
72b913fb 188 return ret;
8b285017 189}
a45a0b60
PP
190
191int bt_private_port_set_user_data(
192 struct bt_private_port *private_port, void *user_data)
193{
194 int ret = 0;
195
196 if (!private_port) {
197 ret = -1;
198 goto end;
199 }
200
201 bt_port_from_private(private_port)->user_data = user_data;
202
203end:
204 return ret;
205}
206
207void *bt_private_port_get_user_data(
208 struct bt_private_port *private_port)
209{
210 return private_port ?
211 bt_port_from_private(private_port)->user_data : NULL;
212}
This page took 0.03259 seconds and 4 git commands to generate.