class Babeltrace2::BTGraph
Constants
- AddComponentStatus
- AddInterrupterStatus
- AddListenerStatus
- ConnectPortsStatus
- ListenerFuncStatus
- RunOnceStatus
- RunStatus
- SimpleSinkComponentConsumeFuncStatus
- SimpleSinkComponentInitializeFuncStatus
Public Class Methods
new(handle = nil, retain: true, auto_release: true, mip_version: 0)
click to toggle source
Calls superclass method
# File lib/babeltrace2/graph/graph.rb, line 335 def initialize(handle = nil, retain: true, auto_release: true, mip_version: 0) if handle super(handle, retain: retain, auto_release: auto_release) else handle = Babeltrace2.bt_graph_create(mip_version) raise Babeltrace2.process_error if handle.null? super(handle) end end
Public Instance Methods
add(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil)
Alias for: add_component
add_component(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 400 def add_component(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil) case component_class.type when :BT_COMPONENT_CLASS_TYPE_SOURCE add_source_component(component_class, name, params: params, logging_level: logging_level, initialize_method_data: initialize_method_data) when :BT_COMPONENT_CLASS_TYPE_FILTER add_filter_component(component_class, name, params: params, logging_level: logging_level, initialize_method_data: initialize_method_data) when :BT_COMPONENT_CLASS_TYPE_SINK add_sink_component(component_class, name, params: params, logging_level: logging_level, initialize_method_data: initialize_method_data) else raise "invalid component type" end end
Also aliased as: add
add_filter(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil)
Alias for: add_filter_component
add_filter_component(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 364 def add_filter_component(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil) ptr = FFI::MemoryPointer.new(:pointer) res = if initialize_method_data Babeltrace2.bt_graph_add_filter_component_with_initialize_method_data( @handle, component_class, name, BTValue.from_value(params), initialize_method_data, logging_level, ptr) else Babeltrace2.bt_graph_add_filter_component( @handle, component_class, name, BTValue.from_value(params), logging_level, ptr) end raise Babeltrace2.process_error(res) if res != :BT_GRAPH_ADD_COMPONENT_STATUS_OK BTComponentFilter.new(BTComponentFilterHandle.new(ptr.read_pointer), retain: true) end
Also aliased as: add_filter
add_filter_component_input_port_added_listener(user_func, user_data: nil)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 482 def add_filter_component_input_port_added_listener(user_func, user_data: nil) ptr = FFI::MemoryPointer.new(:uint64) user_func = Babeltrace2._wrap_graph_filter_component_input_port_added_listener_func( @handle, user_func) res = Babeltrace2.bt_graph_add_filter_component_input_port_added_listener( @handle, user_func, user_data, ptr) raise Babeltrace2.process_error(res) if res != :BT_GRAPH_ADD_LISTENER_STATUS_OK ptr.read_uint64 end
add_filter_component_output_port_added_listener(user_func, user_data: nil)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 512 def add_filter_component_output_port_added_listener(user_func, user_data: nil) ptr = FFI::MemoryPointer.new(:uint64) user_func = Babeltrace2._wrap_graph_filter_component_output_port_added_listener_func( @handle, user_func) res = Babeltrace2.bt_graph_add_filter_component_output_port_added_listener( @handle, user_func, user_data, ptr) raise Babeltrace2.process_error(res) if res != :BT_GRAPH_ADD_LISTENER_STATUS_OK ptr.read_uint64 end
add_interrupter(interrupter)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 470 def add_interrupter(interrupter) res = Babeltrace2.bt_graph_add_interrupter(@handle, interrupter) raise Babeltrace2.process_error(res) if res != :BT_GRAPH_ADD_INTERRUPTER_STATUS_OK self end
add_simple_sink(name, consume_func, initialize_func: nil, finalize_func: nil, user_data: nil)
Alias for: add_simple_sink_component
add_simple_sink_component(name, consume_func, initialize_func: nil, finalize_func: nil, user_data: nil)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 422 def add_simple_sink_component(name, consume_func, initialize_func: nil, finalize_func: nil, user_data: nil) initialize_func = Babeltrace2._wrap_graph_simple_sink_component_initialize_func(initialize_func) if initialize_func consume_func = Babeltrace2._wrap_graph_simple_sink_component_consume_func(consume_func) ptr = FFI::MemoryPointer.new(:pointer) res = Babeltrace2.bt_graph_add_simple_sink_component(@handle, name, initialize_func, consume_func, finalize_func, user_data, ptr) raise Babeltrace2.process_error(res) if res != :BT_GRAPH_ADD_COMPONENT_STATUS_OK handle = BTComponentSinkHandle.new(ptr.read_pointer) id = handle.to_i Babeltrace2._callbacks[id][:initialize_func] = initialize_func Babeltrace2._callbacks[id][:consume_func] = consume_func Babeltrace2._callbacks[id][:finalize_func] = finalize_func BTComponentSink.new(handle, retain: true) end
Also aliased as: add_simple_sink
add_sink(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil)
Alias for: add_sink_component
add_sink_component(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 382 def add_sink_component(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil) ptr = FFI::MemoryPointer.new(:pointer) res = if initialize_method_data Babeltrace2.bt_graph_add_sink_component_with_initialize_method_data( @handle, component_class, name, BTValue.from_value(params), initialize_method_data, logging_level, ptr) else Babeltrace2.bt_graph_add_sink_component( @handle, component_class, name, BTValue.from_value(params), logging_level, ptr) end raise Babeltrace2.process_error(res) if res != :BT_GRAPH_ADD_COMPONENT_STATUS_OK BTComponentSink.new(BTComponentSinkHandle.new(ptr.read_pointer), retain: true) end
Also aliased as: add_sink
add_sink_component_input_port_added_listener(user_func, user_data: nil)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 492 def add_sink_component_input_port_added_listener(user_func, user_data: nil) ptr = FFI::MemoryPointer.new(:uint64) user_func = Babeltrace2._wrap_graph_sink_component_input_port_added_listener_func( @handle, user_func) res = Babeltrace2.bt_graph_add_sink_component_input_port_added_listener( @handle, user_func, user_data, ptr) raise Babeltrace2.process_error(res) if res != :BT_GRAPH_ADD_LISTENER_STATUS_OK ptr.read_uint64 end
add_source(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil)
Alias for: add_source_component
add_source_component(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 346 def add_source_component(component_class, name, params: {}, logging_level: BTLogging.default_level, initialize_method_data: nil) ptr = FFI::MemoryPointer.new(:pointer) res = if initialize_method_data Babeltrace2.bt_graph_add_source_component_with_initialize_method_data( @handle, component_class, name, BTValue.from_value(params), initialize_method_data, logging_level, ptr) else Babeltrace2.bt_graph_add_source_component( @handle, component_class, name, BTValue.from_value(params), logging_level, ptr) end raise Babeltrace2.process_error(res) if res != :BT_GRAPH_ADD_COMPONENT_STATUS_OK BTComponentSource.new(BTComponentSourceHandle.new(ptr.read_pointer), retain: true) end
Also aliased as: add_source
add_source_component_output_port_added_listener(user_func, user_data: nil)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 502 def add_source_component_output_port_added_listener(user_func, user_data: nil) ptr = FFI::MemoryPointer.new(:uint64) user_func = Babeltrace2._wrap_graph_source_component_output_port_added_listener_func( @handle, user_func) res = Babeltrace2.bt_graph_add_source_component_output_port_added_listener( @handle, user_func, user_data, ptr) raise Babeltrace2.process_error(res) if res != :BT_GRAPH_ADD_LISTENER_STATUS_OK ptr.read_uint64 end
connect_ports(upstream_port, downstream_port)
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 439 def connect_ports(upstream_port, downstream_port) raise "upstream port already connected" if upstream_port.connected? raise "downstream port already connected" if downstream_port.connected? ptr = FFI::MemoryPointer.new(:pointer) res = Babeltrace2.bt_graph_connect_ports(@handle, upstream_port, downstream_port, ptr) raise Babeltrace2.process_error(res) if res != :BT_GRAPH_CONNECT_PORTS_STATUS_OK BTConnection.new(BTConnectionHandle.new(ptr.read_pointer), retain: true) end
get_default_interrupter()
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 476 def get_default_interrupter handle = Babeltrace2.bt_graph_borrow_default_interrupter(@handle) BTInterrupter.new(handle, retain: true) end
Also aliased as: default_interrupter
run()
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 448 def run while ((res = Babeltrace2.bt_graph_run(@handle)) == :BT_GRAPH_RUN_STATUS_AGAIN) sleep BT_SLEEP_TIME end raise Babeltrace2.process_error(res) if res != :BT_GRAPH_RUN_STATUS_OK self end
run_once()
click to toggle source
# File lib/babeltrace2/graph/graph.rb, line 456 def run_once while ((res = Babeltrace2.bt_graph_run_once(@handle)) == :BT_GRAPH_RUN_ONCE_STATUS_AGAIN) sleep BT_SLEEP_TIME end case res when :BT_GRAPH_RUN_ONCE_STATUS_OK self when :BT_GRAPH_RUN_ONCE_STATUS_END raise StopIteration else raise Babeltrace2.process_error(res) end end