Sha256: 8dde54e648d99879e22f4bbfd14a52f129ef23ac1a8f3e987c7edc13335d3cd8
Contents?: true
Size: 1.95 KB
Versions: 51
Compression:
Stored size: 1.95 KB
Contents
# Copyright (c) 2012 National ICT Australia Limited (NICTA).
# This software may be used and distributed solely under the terms of the MIT license (License).
# You should find a copy of the License in LICENSE.TXT or at http://opensource.org/licenses/MIT.
# By downloading or using this software you accept the terms and the liability disclaimer in the License.
# OMF_VERSIONS = 6.0
def create_engine(garage)
garage.create(:engine, { sn: 10001 }) do |reply_msg|
if reply_msg.success?
engine = reply_msg.resource
engine.on_subscribed do
info ">>> Connected to newly created resource #{reply_msg[:res_id]} with serial number #{reply_msg[:sn]}"
on_engine_created(engine)
end
after(2) do
info ">>> RELEASE engine"
garage.release(engine) do |reply_msg|
info reply_msg
end
end
else
error ">>> Resource creation failed - #{reply_msg[:reason]}"
end
end
end
def on_engine_created(engine)
info ">>> SENDING REQUEST"
# We can ask for some information about the engine
engine.request([:rpm, :max_rpm, :max_power, :provider])
# Now we will apply 50% throttle to the engine
info ">>> SENDING CONFIGURE throttle 50%"
engine.configure(throttle: 50)
# Some time later, we want to reduce the throttle to 0, to avoid blowing up the engine
after(5) do
info ">>> SENDING CONFIGURE throttle 0%"
engine.configure(throttle: 0)
end
every(1) do
engine.request([:rpm])
end
# Monitor all status information from the engine
engine.on_inform do |msg|
case msg.itype
when 'STATUS'
msg.each_property do |name, value|
info "#{name}: #{value}"
end
when 'ERROR'
error msg[:reason]
when 'WARN'
warn msg[:reason]
end
end
end
OmfCommon.comm.subscribe('garage') do |garage|
unless garage.error?
create_engine(garage)
else
error garage.inspect
end
after(20) { info 'Disconnecting ...'; OmfCommon.comm.disconnect }
end
Version data entries
51 entries across 51 versions & 1 rubygems