This test method is meant to test a sink, but currently tests a filter,
fix that.
Change-Id: Icca321f50a43b709b64f15c885c37c6e7106653d
Signed-off-by: Simon Marchi <simon.marchi@efficios.com>
Reviewed-on: https://review.lttng.org/c/babeltrace/+/2735
Tested-by: jenkins <jenkins@lttng.org>
)
def test_sink_self_port_user_data(self):
)
def test_sink_self_port_user_data(self):
- class MyIter(bt2._UserMessageIterator):
- def __next__(self):
- raise bt2.Stop
-
- class MySink(bt2._UserFilterComponent, message_iterator_class=MyIter):
+ class MySink(bt2._UserSinkComponent):
def __init__(comp_self, config, params, obj):
nonlocal user_datas
def __init__(comp_self, config, params, obj):
nonlocal user_datas
p = comp_self._add_input_port('port2', set())
user_datas.append(p.user_data)
p = comp_self._add_input_port('port2', set())
user_datas.append(p.user_data)
+ def _user_consume(self):
+ pass
+
user_datas = []
self._create_comp(MySink)
user_datas = []
self._create_comp(MySink)