super().__init__(params, obj, logging_level)
is_cc_object = isinstance(
- component_class, (bt2._SourceComponentClass, bt2._FilterComponentClass)
+ component_class,
+ (bt2._SourceComponentClassConst, bt2._FilterComponentClassConst),
)
is_user_cc_type = isinstance(
component_class, bt2_component._UserComponentType
class _TraceCollectionMessageIteratorProxySink(bt2_component._UserSinkComponent):
- def __init__(self, params, msg_list):
+ def __init__(self, config, params, msg_list):
assert type(msg_list) is list
self._msg_list = msg_list
self._add_input_port('in')
def _user_graph_is_configured(self):
- self._msg_iter = self._create_input_port_message_iterator(
- self._input_ports['in']
- )
+ self._msg_iter = self._create_message_iterator(self._input_ports['in'])
def _user_consume(self):
assert self._msg_list[0] is None
self._stream_inter_port_to_range = {}
for src_comp_and_spec in self._src_comps_and_specs:
- try:
- inputs = src_comp_and_spec.spec.params['inputs']
- except KeyError as e:
- raise ValueError(
- 'all source components must be created with an "inputs" parameter in stream intersection mode'
- ) from e
-
- params = {'inputs': inputs}
-
- # query the port's component for the `babeltrace.trace-info`
+ # Query the port's component for the `babeltrace.trace-infos`
# object which contains the range for each stream, from which we can
# compute the intersection of the streams in each trace.
query_exec = bt2.QueryExecutor(
- src_comp_and_spec.spec.component_class, 'babeltrace.trace-info', params
+ src_comp_and_spec.spec.component_class,
+ 'babeltrace.trace-infos',
+ src_comp_and_spec.spec.params,
)
trace_infos = query_exec.query()
for trace_info in trace_infos:
begin = max(
- [stream['range-ns']['begin'] for stream in trace_info['streams']]
+ [
+ stream['range-ns']['begin']
+ for stream in trace_info['stream-infos']
+ ]
)
end = min(
- [stream['range-ns']['end'] for stream in trace_info['streams']]
+ [stream['range-ns']['end'] for stream in trace_info['stream-infos']]
)
# Each port associated to this trace will have this computed
# range.
- for stream in trace_info['streams']:
+ for stream in trace_info['stream-infos']:
# A port name is unique within a component, but not
# necessarily across all components. Use a component
# and port name pair to make it unique across the graph.
if not self._connect_ports:
return
- if type(port) is bt2_port._InputPort:
+ if type(port) is bt2_port._InputPortConst:
return
if component not in [comp.comp for comp in self._src_comps_and_specs]: