Class: Orocos::Async::CORBA::Port

Inherits:
ObjectBase show all
Extended by:
Utilrb::EventLoop::Forwardable
Defined in:
lib/orocos/async/ports.rb

Direct Known Subclasses

InputPort, OutputPort

Instance Attribute Summary collapse

Attributes inherited from ObjectBase

#emitting, #event_loop, #name, #pending_adds

Instance Method Summary collapse

Methods inherited from ObjectBase

#add_listener, define_event, define_events, #disable_emitting, #event, event_names, #event_names, #invalidate_delegator!, #listener?, #listeners, #number_of_listeners, #on_event, #proxy_event, #really_add_listener, #remove_all_listeners, #remove_listener, #remove_proxy_event, #valid_delegator?, valid_event?, #valid_event?, validate_event, #validate_event, #wait

Instance Attribute Details

#options ⇒ Object

Returns the value of attribute options



180
181
182
 
# File 'lib/orocos/async/ports.rb', line 180

def options
  @options
end

Instance Method Details

#reachable!(port, options = Hash.new) ⇒ Object 



186
187
188
189
190
 
# File 'lib/orocos/async/ports.rb', line 186

def reachable!(port,options = Hash.new)
    @mutex.synchronize do
        super
    end
end

#reachable? ⇒ Boolean

Returns:

  • (Boolean) 


198
199
200
 
# File 'lib/orocos/async/ports.rb', line 198

def reachable?
    super && @task.reachable?
end

#task ⇒ Object 



182
183
184
 
# File 'lib/orocos/async/ports.rb', line 182

def task
    @task
end

#to_async(options = Hash.new) ⇒ Object 



202
203
204
 
# File 'lib/orocos/async/ports.rb', line 202

def to_async(options=Hash.new)
    self
end

#to_proxy(options = Hash.new) ⇒ Object 



206
207
208
 
# File 'lib/orocos/async/ports.rb', line 206

def to_proxy(options=Hash.new)
    task.to_proxy(options).port(name)
end

#unreachable!(options = Hash.new) ⇒ Object 



192
193
194
195
196
 
# File 'lib/orocos/async/ports.rb', line 192

def unreachable!(options = Hash.new)
    @mutex.synchronize do
        super
    end
end