class Orocos::Async::CORBA::TaskContext

Public Class Methods

new(ior,options=Hash.new) click to toggle source

If not specified the default option settings are:

:event_loop => Async.event_loop
:raise => false
:watchdog => true
:period => 1.0

@param [String,#ior] ior The ior of the task or a task context. @param [Hash] options The options. @option options [String] :name The name of the task. @option options [Utilrb::EventLoop] :event_loop The event loop. @option options [String] :ior The IOR @option options [Boolean] :raise Raises an Orocos::NotFound error if the remote task is

unreachable or went offline. Otherwise tries to reconnect and silently ignores method calls on
the remote task object as long as the task is unreachable.

@option options [Boolean] :watchdog Checks the state of the tasks and if it is reachable. @option options [Float] :period The period of the watchdog in seconds. @option options [Orocos::TaskContext] :use Use the given task as designated object. After this any other other code

path is not allowed to use the given task otherwise there might be multi threading problems. Furthermore
it is assumed that the given task is reachable.

@overload initialize(options) @overload initialize(task,options)

@option options [#ior,#name] :task a task context.

Calls superclass method Orocos::Async::TaskContextBase.new

# File lib/orocos/async/task_context.rb, line 28
def initialize(ior,options=Hash.new)
    if ior.respond_to?(:ior)
        ior = ior.ior
    end
    ior,options = if ior.is_a? Hash
                      [nil,ior]
                  else
                      [ior,options]
                  end
    ior ||= if options.has_key? :ior
                options[:ior]
            elsif options.has_key? :use
                options[:use].ior
            end
    name = options[:name] || ior
    super(name,options.merge(:ior => ior))
    @ior = ior.to_str
end

Public Instance Methods

configure_delegation(options = Hash.new) click to toggle source

(see Orocos::Async::TaskContextBase#configure_delegation)

@option options [String] name the task name @option options [String] ior the task IOR

# File lib/orocos/async/task_context.rb, line 71
def configure_delegation(options = Hash.new)
    options = Kernel.validate_options options,
        :name=> nil,
        :ior => nil

    ior = options[:ior]
    @ior,@name = if valid_delegator?
                     [@delegator_obj.ior,@delegator_obj.name]
                 elsif ior.respond_to?(:ior)
                     [ior.ior, ior.name]
                 else
                     [ior, @name]
                 end

    if !@ior
        raise ArgumentError, "no IOR or task has been given"
    end
end

ior() click to toggle source

# File lib/orocos/async/task_context.rb, line 61
def ior
    @mutex.synchronize do
        @ior.dup if @ior
    end
end

method_missing(m,*args) click to toggle source

Calls superclass method

# File lib/orocos/async/task_context.rb, line 94
def method_missing(m,*args)
    if respond_to_missing?(m)
        event_loop.sync(@delegator_obj,args) do |args|
            @delegator_obj.method(m).call(*args)
        end
    else
        super
    end
end

really_add_listener(listener) click to toggle source

Calls superclass method Orocos::Async::TaskContextBase#really_add_listener

# File lib/orocos/async/task_context.rb, line 47
def really_add_listener(listener)
    super

    # call new listeners with the current value
    # to prevent different behaviors depending on
    # the calling order
    if listener.use_last_value? && listener.event == :state_change
        state = @mutex.synchronize do
            @delegator_obj.current_state if valid_delegator?
        end
        event_loop.once{listener.call state} if state
    end
end

respond_to_missing?(method_name, include_private = false) click to toggle source

Calls superclass method

# File lib/orocos/async/task_context.rb, line 90
def respond_to_missing?(method_name, include_private = false)
    (reachable? && @delegator_obj.respond_to?(method_name)) || super
end