assert(port_ptr)
if comp_ports._is_private:
- port_pub_ptr = native_bt.port_from_private_port(port_ptr)
+ port_pub_ptr = native_bt.port_from_private(port_ptr)
name = native_bt.port_get_name(port_pub_ptr)
native_bt.put(port_pub_ptr)
else:
def __len__(self):
if self._is_private:
- pub_ptr = native_bt.component_from_private_component(self._component._ptr)
+ pub_ptr = native_bt.component_from_private(self._component._ptr)
count = self._get_port_count_fn(pub_ptr)
native_bt.put(pub_ptr)
else:
class _UserComponent(metaclass=_UserComponentType):
@property
def name(self):
- pub_ptr = native_bt.component_from_private_component(self._ptr)
+ pub_ptr = native_bt.component_from_private(self._ptr)
name = native_bt.component_get_name(pub_ptr)
native_bt.put(pub_ptr)
assert(name is not None)
@property
def graph(self):
- pub_ptr = native_bt.component_from_private_component(self._ptr)
+ pub_ptr = native_bt.component_from_private(self._ptr)
ptr = native_bt.component_get_graph(pub_ptr)
native_bt.put(pub_ptr)
assert(ptr)
@property
def component_class(self):
- pub_ptr = native_bt.component_from_private_component(self._ptr)
+ pub_ptr = native_bt.component_from_private(self._ptr)
cc_ptr = native_bt.component_get_class(pub_ptr)
native_bt.put(pub_ptr)
assert(cc_ptr)
def _create_private_from_ptr(ptr):
obj = _PrivateConnection._create_from_ptr(ptr)
- obj._pub_ptr = native_bt.connection_from_private_connection(ptr)
+ obj._pub_ptr = native_bt.connection_from_private(ptr)
assert(obj._pub_ptr)
return obj
enum bt_component_class_type bt_component_get_class_type(
struct bt_component *component);
struct bt_graph *bt_component_get_graph(struct bt_component *component);
-struct bt_component *bt_component_from_private_component(
+struct bt_component *bt_component_from_private(
struct bt_private_component *private_component);
/* Source component functions */
struct bt_value *params, void *init_method_data)
{
struct bt_component *comp =
- bt_component_from_private_component(priv_comp);
+ bt_component_from_private(priv_comp);
struct bt_component_class *comp_cls = bt_component_get_class(comp);
enum bt_component_status status = BT_COMPONENT_STATUS_OK;
PyObject *py_cls = NULL;
int bt_connection_is_ended(struct bt_connection *connection);
/* Functions (private) */
-struct bt_connection *bt_connection_from_private_connection(
+struct bt_connection *bt_connection_from_private(
struct bt_private_connection *private_connection);
/* Helper functions for Python */
int bt_port_is_connected(struct bt_port *port);
/* Functions (private) */
-struct bt_port *bt_port_from_private_port(struct bt_private_port *private_port);
+struct bt_port *bt_port_from_private(struct bt_private_port *private_port);
struct bt_private_connection *bt_private_port_get_private_connection(
struct bt_private_port *private_port);
struct bt_private_component *bt_private_port_get_private_component(
def _create_private_from_ptr(ptr):
- pub_ptr = native_bt.port_from_private_port(ptr)
+ pub_ptr = native_bt.port_from_private(ptr)
utils._handle_ptr(pub_ptr, 'cannot get port object from private port object')
port_type = native_bt.port_get_type(pub_ptr)
assert(port_type == native_bt.PORT_TYPE_INPUT or port_type == native_bt.PORT_TYPE_OUTPUT)
if comp_ptr is None:
return
- pub_comp_ptr = native_bt.component_from_private_component(comp_ptr)
+ pub_comp_ptr = native_bt.component_from_private(comp_ptr)
assert(pub_comp_ptr)
comp = bt2.component._create_generic_component_from_ptr(pub_comp_ptr)
native_bt.put(comp_ptr)
};
static inline
-struct bt_component *bt_component_from_private(
+struct bt_component *bt_component_borrow_from_private(
struct bt_private_component *private_component)
{
return (void *) private_component;
};
static inline
-struct bt_connection *bt_connection_from_private(
+struct bt_connection *bt_connection_borrow_from_private(
struct bt_private_connection *private_connection)
{
return (void *) private_connection;
static inline
struct bt_notification_iterator_private_connection *
-bt_private_connection_notification_iterator_from_private(
+bt_private_connection_notification_iterator_borrow_from_private(
struct bt_private_connection_private_notification_iterator *private_notification_iterator)
{
return (void *) private_notification_iterator;
};
static inline
-struct bt_port *bt_port_from_private(
+struct bt_port *bt_port_borrow_from_private(
struct bt_private_port *private_port)
{
return (void *) private_port;
struct bt_component;
struct bt_private_component;
-extern struct bt_component *bt_component_from_private_component(
+extern struct bt_component *bt_component_from_private(
struct bt_private_component *private_component);
extern void *bt_private_component_get_user_data(
struct bt_private_connection_private_notification_iterator;
struct bt_notification_iterator *
-bt_private_connection_notification_iterator_from_private_notification_iterator(
+bt_private_connection_notification_iterator_from_private(
struct bt_private_connection_private_notification_iterator *private_notification_iterator);
extern struct bt_private_component *
struct bt_private_connection;
struct bt_notification_iterator;
-extern struct bt_connection *bt_connection_from_private_connection(
+extern struct bt_connection *bt_connection_from_private(
struct bt_private_connection *private_connection);
extern enum bt_connection_status
struct bt_private_component;
struct bt_private_connection;
-struct bt_port *bt_port_from_private_port(struct bt_private_port *private_port);
+struct bt_port *bt_port_from_private(struct bt_private_port *private_port);
extern struct bt_private_connection *bt_private_port_get_private_connection(
struct bt_private_port *private_port);
extern struct bt_private_component *bt_private_port_get_private_component(
g_free(component);
}
-struct bt_component *bt_component_from_private_component(
+struct bt_component *bt_component_from_private(
struct bt_private_component *private_component)
{
- return bt_get(bt_component_from_private(private_component));
+ return bt_get(bt_component_borrow_from_private(private_component));
}
enum bt_component_class_type bt_component_get_class_type(
struct bt_private_component *private_component)
{
struct bt_component *component =
- bt_component_from_private(private_component);
+ bt_component_borrow_from_private(private_component);
return component ? component->user_data : NULL;
}
void *data)
{
struct bt_component *component =
- bt_component_from_private(private_component);
+ bt_component_borrow_from_private(private_component);
enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
if (!component) {
bt_connection_try_remove_from_graph(connection);
}
-struct bt_connection *bt_connection_from_private_connection(
+struct bt_connection *bt_connection_from_private(
struct bt_private_connection *private_connection)
{
- return bt_get(bt_connection_from_private(private_connection));
+ return bt_get(bt_connection_borrow_from_private(private_connection));
}
BT_HIDDEN
goto end;
}
- connection = bt_connection_from_private(private_connection);
+ connection = bt_connection_borrow_from_private(private_connection);
if (bt_graph_is_canceled(bt_connection_borrow_graph(connection))) {
BT_LOGW("Cannot create notification iterator from connection: "
/* bt_component_filter_get_input_port_by_index() logs details/errors */
return bt_private_port_from_port(
bt_component_filter_get_input_port_by_index(
- bt_component_from_private(private_component), index));
+ bt_component_borrow_from_private(private_component), index));
}
struct bt_private_port *
/* bt_component_filter_get_input_port_by_name() logs details/errors */
return bt_private_port_from_port(
bt_component_filter_get_input_port_by_name(
- bt_component_from_private(private_component), name));
+ bt_component_borrow_from_private(private_component), name));
}
enum bt_component_status bt_private_component_filter_add_input_private_port(
enum bt_component_status status = BT_COMPONENT_STATUS_OK;
struct bt_port *port = NULL;
struct bt_component *component =
- bt_component_from_private(private_component);
+ bt_component_borrow_from_private(private_component);
struct bt_graph *graph;
if (!component) {
/* bt_component_filter_get_output_port_by_index() logs details/errors */
return bt_private_port_from_port(
bt_component_filter_get_output_port_by_index(
- bt_component_from_private(private_component), index));
+ bt_component_borrow_from_private(private_component), index));
}
struct bt_private_port *
/* bt_component_filter_get_output_port_by_name() logs details/errors */
return bt_private_port_from_port(
bt_component_filter_get_output_port_by_name(
- bt_component_from_private(private_component), name));
+ bt_component_borrow_from_private(private_component), name));
}
enum bt_component_status bt_private_component_filter_add_output_private_port(
enum bt_component_status status = BT_COMPONENT_STATUS_OK;
struct bt_port *port = NULL;
struct bt_component *component =
- bt_component_from_private(private_component);
+ bt_component_borrow_from_private(private_component);
struct bt_graph *graph;
if (!component) {
struct bt_private_connection_private_notification_iterator *private_iterator)
{
struct bt_notification_iterator_private_connection *iterator =
- bt_private_connection_notification_iterator_from_private(private_iterator);
+ bt_private_connection_notification_iterator_borrow_from_private(private_iterator);
return iterator ? iterator->user_data : NULL;
}
enum bt_notification_iterator_status ret =
BT_NOTIFICATION_ITERATOR_STATUS_OK;
struct bt_notification_iterator_private_connection *iterator =
- bt_private_connection_notification_iterator_from_private(private_iterator);
+ bt_private_connection_notification_iterator_borrow_from_private(private_iterator);
if (!iterator) {
BT_LOGW_STR("Invalid parameter: notification iterator is NULL.");
{
return bt_private_component_from_component(
bt_private_connection_notification_iterator_get_component(
- (void *) bt_private_connection_notification_iterator_from_private(private_iterator)));
+ (void *) bt_private_connection_notification_iterator_borrow_from_private(private_iterator)));
}
static
g_free(port);
}
-struct bt_port *bt_port_from_private_port(
+struct bt_port *bt_port_from_private(
struct bt_private_port *private_port)
{
- return bt_get(bt_port_from_private(private_port));
+ return bt_get(bt_port_borrow_from_private(private_port));
}
BT_HIDDEN
struct bt_private_port *private_port)
{
return bt_private_connection_from_connection(bt_port_get_connection(
- bt_port_from_private(private_port)));
+ bt_port_borrow_from_private(private_port)));
}
struct bt_private_component *bt_private_port_get_private_component(
struct bt_private_port *private_port)
{
return bt_private_component_from_component(bt_port_get_component(
- bt_port_from_private(private_port)));
+ bt_port_borrow_from_private(private_port)));
}
BT_HIDDEN
struct bt_private_port *private_port)
{
enum bt_port_status status = BT_PORT_STATUS_OK;
- struct bt_port *port = bt_port_from_private(private_port);
+ struct bt_port *port = bt_port_borrow_from_private(private_port);
struct bt_component *comp = NULL;
enum bt_component_status comp_status;
struct bt_private_port *private_port)
{
return private_port ?
- bt_port_from_private(private_port)->user_data : NULL;
+ bt_port_borrow_from_private(private_port)->user_data : NULL;
}
/* bt_component_sink_get_input_port_by_index() logs details/errors */
return bt_private_port_from_port(
bt_component_sink_get_input_port_by_index(
- bt_component_from_private(private_component), index));
+ bt_component_borrow_from_private(private_component), index));
}
struct bt_private_port *
/* bt_component_sink_get_input_port_by_name() logs details/errors */
return bt_private_port_from_port(
bt_component_sink_get_input_port_by_name(
- bt_component_from_private(private_component), name));
+ bt_component_borrow_from_private(private_component), name));
}
enum bt_component_status bt_private_component_sink_add_input_private_port(
enum bt_component_status status = BT_COMPONENT_STATUS_OK;
struct bt_port *port = NULL;
struct bt_component *component =
- bt_component_from_private(private_component);
+ bt_component_borrow_from_private(private_component);
struct bt_graph *graph;
if (!component) {
/* bt_component_source_get_output_port_by_name() logs details/errors */
return bt_private_port_from_port(
bt_component_source_get_output_port_by_name(
- bt_component_from_private(private_component), name));
+ bt_component_borrow_from_private(private_component), name));
}
struct bt_private_port *
/* bt_component_source_get_output_port_by_index() logs details/errors */
return bt_private_port_from_port(
bt_component_source_get_output_port_by_index(
- bt_component_from_private(private_component), index));
+ bt_component_borrow_from_private(private_component), index));
}
enum bt_component_status bt_private_component_source_add_output_private_port(
enum bt_component_status status = BT_COMPONENT_STATUS_OK;
struct bt_port *port = NULL;
struct bt_component *component =
- bt_component_from_private(private_component);
+ bt_component_borrow_from_private(private_component);
struct bt_graph *graph;
if (!component) {
{
struct bt_port *port;
- port = bt_port_from_private_port(stream->port);
+ port = bt_port_from_private(stream->port);
print_dbg("stream %s state %s last_inact_ts %" PRId64 " cur_inact_ts %" PRId64,
bt_port_get_name(port),
print_state(stream),
return BT_FALSE;
}
- component = bt_component_from_private_component(lttng_live->private_component);
+ component = bt_component_from_private(lttng_live->private_component);
graph = bt_component_get_graph(component);
ret = bt_graph_is_canceled(graph);
bt_put(graph);
int64_t nr_ports;
int ret;
- component = bt_component_from_private_component(lttng_live->private_component);
+ component = bt_component_from_private(lttng_live->private_component);
nr_ports = bt_component_source_get_output_port_count(component);
if (nr_ports < 0) {
return -1;
bt_private_component_get_user_data(private_component);
struct bt_component *other_component;
enum bt_component_status status = BT_COMPONENT_STATUS_OK;
- struct bt_port *self_port = bt_port_from_private_port(self_private_port);
+ struct bt_port *self_port = bt_port_from_private(self_private_port);
other_component = bt_port_get_component(other_port);
bt_put(other_component); /* weak */
struct bt_notification_iterator *create_notif_iter_on_input_port(
struct bt_private_port *priv_port, int *ret)
{
- struct bt_port *port = bt_port_from_private_port(priv_port);
+ struct bt_port *port = bt_port_from_private(priv_port);
struct bt_notification_iterator *notif_iter = NULL;
struct bt_private_connection *priv_conn = NULL;
enum bt_connection_status conn_status;
}
priv_port = node->data;
- port = bt_port_from_private_port(priv_port);
+ port = bt_port_from_private(priv_port);
assert(port);
if (!bt_port_is_connected(port)) {
* iterator's list of newly connected ports. They will be
* handled by muxer_notif_iter_handle_newly_connected_ports().
*/
- comp = bt_component_from_private_component(muxer_comp->priv_comp);
+ comp = bt_component_from_private(muxer_comp->priv_comp);
assert(comp);
count = bt_component_filter_get_input_port_count(comp);
if (count < 0) {
struct bt_port *port;
assert(priv_port);
- port = bt_port_from_private_port(priv_port);
+ port = bt_port_from_private(priv_port);
assert(port);
if (!bt_port_is_connected(port)) {
struct bt_port *other_port)
{
struct bt_port *self_port =
- bt_port_from_private_port(self_private_port);
+ bt_port_from_private(self_private_port);
struct muxer_comp *muxer_comp =
bt_private_component_get_user_data(priv_comp);
size_t i;
void muxer_port_disconnected(struct bt_private_component *priv_comp,
struct bt_private_port *priv_port)
{
- struct bt_port *port = bt_port_from_private_port(priv_port);
+ struct bt_port *port = bt_port_from_private(priv_port);
struct muxer_comp *muxer_comp =
bt_private_component_get_user_data(priv_comp);
struct event event = {
.type = COMP_ACCEPT_PORT_CONNECTION,
.data.comp_accept_port_connection = {
- .comp = bt_component_from_private_component(private_component),
- .self_port = bt_port_from_private_port(self_private_port),
+ .comp = bt_component_from_private(private_component),
+ .self_port = bt_port_from_private(self_private_port),
.other_port = other_port,
},
};
struct event event = {
.type = COMP_PORT_CONNECTED,
.data.comp_port_connected = {
- .comp = bt_component_from_private_component(private_component),
- .self_port = bt_port_from_private_port(self_private_port),
+ .comp = bt_component_from_private(private_component),
+ .self_port = bt_port_from_private(self_private_port),
.other_port = other_port,
},
};
struct event event = {
.type = COMP_PORT_DISCONNECTED,
.data.comp_port_disconnected = {
- .comp = bt_component_from_private_component(private_component),
- .port = bt_port_from_private_port(private_port),
+ .comp = bt_component_from_private(private_component),
+ .port = bt_port_from_private(private_port),
},
};
struct event event = {
.type = COMP_PORT_CONNECTED,
.data.comp_port_connected = {
- .comp = bt_component_from_private_component(private_component),
- .self_port = bt_port_from_private_port(self_private_port),
+ .comp = bt_component_from_private(private_component),
+ .self_port = bt_port_from_private(self_private_port),
.other_port = other_port,
},
};
struct event event = {
.type = COMP_PORT_DISCONNECTED,
.data.comp_port_disconnected = {
- .comp = bt_component_from_private_component(private_component),
- .port = bt_port_from_private_port(private_port),
+ .comp = bt_component_from_private(private_component),
+ .port = bt_port_from_private(private_port),
},
};
{
struct src_iter_user_data *user_data =
g_new0(struct src_iter_user_data, 1);
- struct bt_port *port = bt_port_from_private_port(private_port);
+ struct bt_port *port = bt_port_from_private(private_port);
const char *port_name;
int ret;