class Orocos::Async::Log::TaskContext

# File lib/orocos/async/log/task_context.rb, line 19
def initialize(log_task,options=Hash.new)
    @options ||= Kernel.validate_options options,:raise => false,:event_loop => Orocos::Async.event_loop,:period => default_period
    super(log_task.name,@options[:event_loop])
    if log_task.has_port? "state"
        log_task.port("state").on_data do |sample|
            emit_state_change log_task.state
        end
    end
    # do not queue reachable event no listeners are registered so far
    disable_emitting do 
        reachable!(log_task)
    end
    log_task.on_port_reachable do |name|
        emit_port_reachable name
    end
    log_task.on_property_reachable do |name|
        emit_property_reachable name
    end
    log_task.on_state_change do |val|
        emit_state_change val
    end
end

# File lib/orocos/async/log/task_context.rb, line 92
def attribute(name,options={},&block)
    if block
        orig_attribute(name) do |attr|
            block.call Attribute.new(self,attr)
        end
    else
        Attribute.new(self,orig_attribute(name))
    end
end

# File lib/orocos/async/log/task_context.rb, line 152
def each_attribute(&block)
    if !block_given?
        return enum_for(:each_attribute)
    end

    names = attribute_names
    names.each do |name|
        yield(attribute(name))
    end
end

# File lib/orocos/async/log/task_context.rb, line 168
def each_port(&block)
    if !block_given?
        return enum_for(:each_port)
    end

    port_names.each do |name|
        yield(port(name))
    end
    self
end

# File lib/orocos/async/log/task_context.rb, line 136
def each_property(&block)
    if !block_given?
        return enum_for(:each_property)
    end
    names = property_names
    puts names
    names.each do |name|
        yield(property(name))
    end
end

# File lib/orocos/async/log/task_context.rb, line 112
def port(name, verify = true,options=Hash.new,&block)
    if block
        orig_port(name,verify) do |port|
            block.call OutputPort.new(self,port)
        end
    else
        OutputPort.new(self,orig_port(name))
    end
end

# File lib/orocos/async/log/task_context.rb, line 102
def property(name,options={},&block)
    if block
        orig_property(name) do |prop|
            block.call Property.new(self,prop)
        end
    else
        Property.new(self,orig_property(name))
    end
end

# File lib/orocos/async/log/task_context.rb, line 61
def really_add_listener(listener)
    return super unless listener.use_last_value?

    # call new listeners with the current value
    # to prevent different behaviors depending on
    # the calling order
    if listener.event == :state_change
        state = @delegator_obj.current_state
        event_loop.once{listener.call state} if state
    elsif listener.event == :port_reachable
        event_loop.once do
            port_names.each do |name|
                listener.call name if @delegator_obj.port(name).used?
            end
        end
    elsif listener.event == :property_reachable
        event_loop.once do
            property_names.each do |name|
                listener.call name if @delegator_obj.property(name).used?
            end
        end
    elsif listener.event == :attribute_reachable
        event_loop.once do
            attribute_names.each do |name|
                listener.call name if @delegator_obj.attribute(name).used?
            end
        end
    end
    super
end

# File lib/orocos/async/log/task_context.rb, line 57
def ruby_task_context?
    !!@ruby_task_context
end

# File lib/orocos/async/log/task_context.rb, line 122
def to_async(options=Hash.new)
    self
end

# File lib/orocos/async/log/task_context.rb, line 126
def to_proxy(options=Hash.new)
    options[:use] ||= self
    Orocos::Async.proxy(name,options).wait
end

# File lib/orocos/async/log/task_context.rb, line 49
def to_ruby
    @ruby_task_context ||= TaskContextBase.to_ruby(self)
end