class Babeltrace2::BTSelfComponent::Sink
Public Instance Methods
add_input_port(name, user_data: nil)
click to toggle source
# File lib/babeltrace2/graph/self-component.rb, line 230 def add_input_port(name, user_data: nil) ptr = FFI::MemoryPointer.new(:pointer) res = Babeltrace2.bt_self_component_sink_add_input_port(@handle, name, user_data, ptr) raise Babeltrace2.process_error(res) if res != :BT_SELF_COMPONENT_ADD_PORT_STATUS_OK BTSelfComponentPortInput.new(BTSelfComponentPortInputHandle.new(ptr.read_pointer), retain: false, auto_release: false) end
create_message_iterator(port)
click to toggle source
# File lib/babeltrace2/graph/self-component.rb, line 257 def create_message_iterator(port) BTMessageIterator.create_from_sink_component(self, port) end
get_input_port_by_index(index)
click to toggle source
# File lib/babeltrace2/graph/self-component.rb, line 238 def get_input_port_by_index(index) count = get_input_port_count index += count if index < 0 return nil if index >= count || index < 0 handle = Babeltrace2.bt_self_component_sink_borrow_input_port_by_index(@handle, index) BTSelfComponentPortInput.new(handle, retain: false, auto_release: false) end
get_input_port_by_name(name)
click to toggle source
# File lib/babeltrace2/graph/self-component.rb, line 246 def get_input_port_by_name(name) handle = Babeltrace2.bt_self_component_sink_borrow_input_port_by_name(@handle, name) return nil if handle.null? BTSelfComponentPortInput.new(handle, retain: false, auto_release: false) end
is_interrupted()
click to toggle source
# File lib/babeltrace2/graph/self-component.rb, line 252 def is_interrupted Babeltrace2.bt_self_component_sink_is_interrupted(@handle) != BT_FALSE end
Also aliased as: interrupted?