X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=src%2Flib%2Fgraph%2Fcomponent-sink.c;h=9d4e11d47cc17d9a4859cb77db6d6f8f0ddb02ca;hp=b218144d145d863f3630843c21880a3b6d2e6d87;hb=9b4f9b425f2efce9a6ccc25f7ae062ebc1116a7d;hpb=1e92035335352f8a67cbc3de28a0ad44b7ee02a1 diff --git a/src/lib/graph/component-sink.c b/src/lib/graph/component-sink.c index b218144d..9d4e11d4 100644 --- a/src/lib/graph/component-sink.c +++ b/src/lib/graph/component-sink.c @@ -26,6 +26,7 @@ #include "common/assert.h" #include "lib/assert-pre.h" +#include "lib/assert-post.h" #include "compat/compiler.h" #include #include @@ -34,6 +35,7 @@ #include "component-sink.h" #include "component.h" +#include "graph.h" #include "lib/func-status.h" BT_HIDDEN @@ -141,6 +143,16 @@ end: return status; } +bt_bool bt_self_component_sink_is_interrupted( + const struct bt_self_component_sink *self_comp) +{ + struct bt_component *comp = (void *) self_comp; + + BT_ASSERT_PRE_NON_NULL(comp, "Component"); + return (bt_bool) bt_graph_is_interrupted( + bt_component_borrow_graph(comp)); +} + void bt_component_sink_get_ref( const struct bt_component_sink *component_sink) {