module Syskit::Coordination::Models::TaskExtension

data_monitoring_arguments() click to toggle source

Mapping from data monitoring arguments to coordination context variables

# File lib/syskit/coordination/models/task_extension.rb, line 12
def data_monitoring_arguments
    @data_monitoring_arguments ||= Hash.new
end

data_monitoring_table() click to toggle source

Returns the data monitoring table that should be added to all instances of this task

# File lib/syskit/coordination/models/task_extension.rb, line 7
def data_monitoring_table
    @data_monitoring_table ||= Syskit::Coordination::DataMonitoringTable.new_submodel(:root => model)
end

monitor(name, *data_streams) click to toggle source

Add a data monitor on this particular coordination task

It will be added to all the instances of this task

# File lib/syskit/coordination/models/task_extension.rb, line 19
def monitor(name, *data_streams)
    if data_streams.last.kind_of?(Hash)
        options = Kernel.normalize_options data_streams.pop
        options.each do |key, value|
            if key.respond_to?(:to_sym) && value.kind_of?(Roby::Coordination::Models::Variable)
                data_monitoring_arguments[value.name] = key
                data_monitoring_table.argument key
            end
        end
    end

    data_monitoring_table.monitor(name, *data_streams)
end

setup_instanciated_task(coordination_context, task, arguments = Hash.new) click to toggle source

Calls superclass method

# File lib/syskit/coordination/models/task_extension.rb, line 33
def setup_instanciated_task(coordination_context, task, arguments = Hash.new)
    table_arguments = Hash.new
    arguments.each do |key, value|
        if var = data_monitoring_arguments[key]
            table_arguments[var] = value
        end
    end
    data_monitoring_table.new(
        task, table_arguments,
        on_replace: :copy,
        parent: coordination_context)
    super
end