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)
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)
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)
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
default_interrupter()
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