X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=src%2Flib%2Fgraph%2Fcomponent-source.c;h=5701563ac7d5d74c834102ed720574c0cd264157;hb=1353b066072e6c389ff35853bac83f65597e7a6a;hp=404da6917a7233b4123de42d861007aa8751a3b6;hpb=350ad6c1c5f45a4e90c33e3c1354125c209bbf02;p=babeltrace.git diff --git a/src/lib/graph/component-source.c b/src/lib/graph/component-source.c index 404da691..5701563a 100644 --- a/src/lib/graph/component-source.c +++ b/src/lib/graph/component-source.c @@ -1,48 +1,30 @@ /* + * SPDX-License-Identifier: MIT + * * Copyright 2017-2018 Philippe Proulx * Copyright 2015 Jérémie Galarneau - * - * Permission is hereby granted, free of charge, to any person obtaining a copy - * of this software and associated documentation files (the "Software"), to deal - * in the Software without restriction, including without limitation the rights - * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell - * copies of the Software, and to permit persons to whom the Software is - * furnished to do so, subject to the following conditions: - * - * The above copyright notice and this permission notice shall be included in - * all copies or substantial portions of the Software. - * - * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE - * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, - * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE - * SOFTWARE. */ #define BT_LOG_TAG "LIB/COMPONENT-SOURCE" -#include "lib/lib-logging.h" +#include "lib/logging.h" #include "common/assert.h" -#include "lib/assert-pre.h" +#include "lib/assert-cond.h" #include "compat/compiler.h" -#include -#include -#include +#include +#include #include #include "component-source.h" #include "component.h" #include "port.h" #include "message/iterator.h" +#include "lib/func-status.h" -BT_HIDDEN void bt_component_source_destroy(struct bt_component *component) { } -BT_HIDDEN struct bt_component *bt_component_source_create( const struct bt_component_class *class) { @@ -50,7 +32,8 @@ struct bt_component *bt_component_source_create( source = g_new0(struct bt_component_source, 1); if (!source) { - BT_LOGE_STR("Failed to allocate one source component."); + BT_LIB_LOGE_APPEND_CAUSE( + "Failed to allocate one source component."); goto end; } @@ -58,77 +41,109 @@ end: return (void *) source; } +BT_EXPORT const bt_component_class_source * bt_component_source_borrow_class_const( const bt_component_source *component) { struct bt_component_class *cls; - BT_ASSERT_PRE_NON_NULL(component, "Component"); + BT_ASSERT_PRE_DEV_COMP_NON_NULL(component); cls = component->parent.class; - BT_ASSERT(cls); - BT_ASSERT(cls->type == BT_COMPONENT_CLASS_TYPE_SOURCE); + BT_ASSERT_DBG(cls); + BT_ASSERT_DBG(cls->type == BT_COMPONENT_CLASS_TYPE_SOURCE); return (bt_component_class_source *) cls; } +BT_EXPORT uint64_t bt_component_source_get_output_port_count( const struct bt_component_source *comp) { - return bt_component_get_output_port_count((void *) comp); + /* bt_component_get_output_port_count() checks preconditions */ + return bt_component_get_output_port_count((void *) comp, __func__); } +BT_EXPORT const struct bt_port_output * bt_component_source_borrow_output_port_by_name_const( const struct bt_component_source *comp, const char *name) { - return bt_component_borrow_output_port_by_name((void *) comp, name); + /* + * bt_component_borrow_output_port_by_name() logs details/errors + * and checks preconditions. + */ + return bt_component_borrow_output_port_by_name((void *) comp, name, + __func__); } +BT_EXPORT struct bt_self_component_port_output * bt_self_component_source_borrow_output_port_by_name( struct bt_self_component_source *comp, const char *name) { + /* + * bt_component_borrow_output_port_by_name() logs details/errors + * and checks preconditions. + */ return (void *) bt_component_borrow_output_port_by_name( - (void *) comp, name); + (void *) comp, name, __func__); } +BT_EXPORT const struct bt_port_output * bt_component_source_borrow_output_port_by_index_const( const struct bt_component_source *comp, uint64_t index) { - return bt_component_borrow_output_port_by_index((void *) comp, index); + /* + * bt_component_borrow_output_port_by_index() logs + * details/errors and checks preconditions. + */ + return bt_component_borrow_output_port_by_index((void *) comp, index, + __func__); } +BT_EXPORT struct bt_self_component_port_output * bt_self_component_source_borrow_output_port_by_index( struct bt_self_component_source *comp, uint64_t index) { + /* + * bt_component_borrow_output_port_by_index() logs + * details/errors and checks preconditions. + */ return (void *) bt_component_borrow_output_port_by_index( - (void *) comp, index); + (void *) comp, index, __func__); } -enum bt_self_component_status bt_self_component_source_add_output_port( +BT_EXPORT +enum bt_self_component_add_port_status bt_self_component_source_add_output_port( struct bt_self_component_source *self_comp, const char *name, void *user_data, struct bt_self_component_port_output **self_port) { struct bt_component *comp = (void *) self_comp; - enum bt_self_component_status status; + enum bt_self_component_add_port_status status; struct bt_port *port = NULL; - /* bt_component_add_output_port() logs details and errors */ - status = bt_component_add_output_port(comp, name, user_data, &port); - if (status != BT_SELF_COMPONENT_STATUS_OK) { + BT_ASSERT_PRE_NO_ERROR(); + BT_ASSERT_PRE_OUTPUT_PORT_NAME_UNIQUE(comp, name); + + /* + * bt_component_add_output_port() logs details/errors and checks + * preconditions. + */ + status = bt_component_add_output_port(comp, name, user_data, &port, + __func__); + if (status != BT_FUNC_STATUS_OK) { goto end; } if (self_port) { /* Move reference to user */ *self_port = (void *) port; - port = NULL; } end: @@ -136,12 +151,14 @@ end: return status; } +BT_EXPORT void bt_component_source_get_ref( const struct bt_component_source *component_source) { bt_object_get_ref(component_source); } +BT_EXPORT void bt_component_source_put_ref( const struct bt_component_source *component_source) {