sim_process.rb

require 'hlmodel'
require 'tcpn'

class ProcessToken < RBSim::HLModel::Process
  include TCPN::TokenMethods
end

class CPU
  attr_accessor :node, :performance
  def initialize(node, performance)
    @node, @performance = node, performance
  end
end

class CPUToken < CPU
  include TCPN::TokenMethods
end

class Handler
  def call(*)
    2345
  end
end

def doproc(&block)
  return block
end

model = TCPN.read 'lib/tcpn/model/application.rb'

process = ProcessToken.new(:node01)
process.on_event :data do |process, args|
  handler = proc do |cpu|
    4000 * args[:volume]/cpu.performance
  end
  process.register_event :cpu, block: handler
  process.register_event :delay_for, time: 300
  if args[:volume] > 10
    process.register_event :data, volume: args[:volume]/10
  else
    constructor = proc do |process, args|
      puts "===> FORKED <=="
      process.register_event :delay_for, time: args
      process.register_event :send_data, volume: args, type: :HTTP_REQUEST
    end
    process.register_event :new_process, program: :curl, constructor: constructor, constructor_args: 5000
  end
  process.register_event :send_data, volume: args[:volume], type: :response
end


#handler = Handler.new
handler = Proc.new { |cpu| 1000/cpu.performance } # java error if handler is set to Proc or lambda...
#handler = Proc.new { |cpu| 1000 } # java error if handler is set to Proc or lambda...
#handler = doproc do |cpu|
#  1000/cpu.performance
#end
process.register_event(:cpu, block: handler )
process.register_event(:cpu, block: handler )
process.register_event(:data, volume: 1000)
#process.register_event(:delay_for, time: 100)
model.add_marking_for 'process', process

cpu = CPUToken.new(:node01, 10)
model.add_marking_for 'CPU', cpu

sim = TCPN.sim model

sim.cb_for :transition, :after do |t, e|
  puts "==> FIRING: #{e.transition} #{e.binding.map { |k, v| "#{k}: #{v}"}.join ',' }"
  #puts model.marking
end

sim.cb_for :clock, :after do |t, e|
  puts e.clock #if (tick += 1) % 100 == 0
end

sim.run

puts model.marking

process = sim.model.marking_for 'process'
p process