class Syskit::Models::Port

# File lib/syskit/models/port.rb, line 25
def initialize(component_model, orogen_model, name = orogen_model.name)
    @component_model, @name, @orogen_model =
        component_model, name, orogen_model

    if orogen_model.type.contains_opaques?
        @type = Orocos.default_loader.intermediate_type_for(orogen_model.type)
    else
        @type = orogen_model.type
    end
    @max_sizes = orogen_model.max_sizes.
        merge(Orocos.max_sizes_for(type))
end

# File lib/syskit/models/port.rb, line 51
def ==(other)
    other.kind_of?(self.class) && other.component_model == component_model &&
    other.orogen_model == orogen_model &&
    other.name == name
end

# File lib/syskit/models/port.rb, line 60
def attach(model)
    new_model = dup
    new_model.instance_variable_set(:@component_model, model)
    new_model
end

# File lib/syskit/models/port.rb, line 137
def can_connect_to?(sink_port)
    source_port = self.try_to_component_port
    if source_port == self
        sink_port  = sink_port.try_to_component_port
        output? && sink_port.input? && type == sink_port.type
    else
        source_port.can_connect_to?(sink_port)
    end
end

# File lib/syskit/models/port.rb, line 99
def connect_to(in_port, policy = Hash.new)
    out_port = self.to_component_port
    if out_port == self
        if in_port.respond_to?(:to_component_port)
            in_port = in_port.to_component_port
            if !out_port.output?
                raise WrongPortConnectionDirection.new(self, in_port), "cannot connect #{out_port} to #{in_port}: #{out_port} is not an output port"
            elsif !in_port.input?
                raise WrongPortConnectionDirection.new(self, in_port), "cannot connect #{out_port} to #{in_port}: #{in_port} is not an input port"
            elsif out_port.component_model == in_port.component_model
                raise SelfConnection.new(out_port, in_port), "cannot connect #{out_port} to #{in_port}: they are both ports of the same component"
            elsif out_port.type != in_port.type
                raise WrongPortConnectionTypes.new(self, in_port), "cannot connect #{out_port} to #{in_port}: types mismatch"
            end

            component_model.connect_ports(in_port.component_model, [out_port.name, in_port.name] => policy)
        else
            Syskit.connect self, in_port, policy
        end

    else
        out_port.connect_to(in_port, policy)
    end
end

# File lib/syskit/models/port.rb, line 125
def connected_to?(sink_port)
    source_port = self.try_to_component_port
    if source_port == self
        sink_port = sink_port.try_to_component_port
        component_model.connected?(source_port, sink_port)
    else
        source_port.connected_to?(sink_port)
    end
end

# File lib/syskit/models/port.rb, line 212
def input?; false end

# File lib/syskit/models/port.rb, line 196
def instanciate(plan)
    bind(component_model.instanciate(plan))
end

# File lib/syskit/models/port.rb, line 38
def max_marshalling_size
    OroGen::Spec::OutputPort.compute_max_marshalling_size(type, max_sizes)
end

# File lib/syskit/models/port.rb, line 155
def method_missing(m, *args, &block)
    if !OROGEN_MODEL_EXCLUDED_FORWARDINGS.include?(m) && orogen_model.respond_to?(m)
        orogen_model.public_send(m, *args, &block)
    else super
    end
end

# File lib/syskit/models/port.rb, line 192
def new_sample
    orogen_model.type.new
end

# File lib/syskit/models/port.rb, line 209
def output?; false end

# File lib/syskit/models/port.rb, line 170
def pretty_print(pp)
    pp.text "port '#{name}' of "
    pp.nest(2) do
        pp.breakable
        component_model.pretty_print(pp)
        pp.breakable
        pp.text "Defined with"
        pp.nest(2) do
            pp.breakable
            orogen_model.pretty_print(pp)
        end
    end
end

# File lib/syskit/models/port.rb, line 200
def resolve_data_source(context)
    if context.kind_of?(Roby::Plan)
        context.add(context = component_model.as_plan)
    end
    bind(context).to_data_source
end

# File lib/syskit/models/port.rb, line 147
def respond_to_missing?(m, include_private)
    if !OROGEN_MODEL_EXCLUDED_FORWARDINGS.include?(m) && orogen_model.respond_to?(m)
        true
    else super
    end
end

# File lib/syskit/models/port.rb, line 45
def same_port?(other)
    other.kind_of?(Port) && (other.component_model <=> component_model) &&
        other.orogen_model == orogen_model
end

# File lib/syskit/models/port.rb, line 162
def short_name
    "#{component_model.short_name}.#{name}_port[#{type.name}]"
end

# File lib/syskit/models/port.rb, line 188
def static?
    orogen_model.static?
end

# File lib/syskit/models/port.rb, line 87
def to_component_port
    if component_model.respond_to?(:self_port_to_component_port)
        component_model.self_port_to_component_port(self)
    else raise ArgumentError, "cannot resolve a port of #{component_model.short_name} into a component port"
    end
end

# File lib/syskit/models/port.rb, line 184
def to_orocos_port(component)
    component_model.resolve(component).find_port(name)
end

# File lib/syskit/models/port.rb, line 166
def to_s
    "#{component_model.short_name}.#{name}_port[#{type.name}]"
end

# File lib/syskit/models/port.rb, line 73
def try_to_component_port
    if component_model.respond_to?(:self_port_to_component_port)
        component_model.self_port_to_component_port(self)
    else self
    end
end