Sha256: b19ad15d775be9a98ba2e5d8530c3fe622772cf586988ad26663979e9e0c0c70
Contents?: true
Size: 1.84 KB
Versions: 14
Compression:
Stored size: 1.84 KB
Contents
require 'bert'
unless Object.respond_to?(:instance_exec)
class Object
module InstanceExecHelper; end
include InstanceExecHelper
def instance_exec(*args, &block) # !> method redefined; discarding old instance_exec
mname = "__instance_exec_#{Thread.current.object_id.abs}_#{object_id.abs}"
InstanceExecHelper.module_eval{ define_method(mname, &block) }
begin
ret = __send__(mname, *args)
ensure
InstanceExecHelper.module_eval{ undef_method(mname) } rescue nil
end
ret
end
end
end
module ErlangHelpers
def setup
return true if @setup
$erlin = IO.new(3, 'r')
$erlout = IO.new(4, 'w')
$erlin.sync = true
@setup = true
end
def send(obj)
berp = BERT.encode(obj)
$erlout.write [berp.size].pack('N')+berp
$erlout.flush
end
def receive
exit(0) if $erlin.eof?
h = $erlin.read(4)
while h == nil
sleep(0.1)
exit(0) if $erlin.eof?
h = $erlin.read(4)
end
l = h.unpack('N')[0]
exit(0) if $erlin.eof?
BERT.decode($erlin.read(l))
end
def error(*args)
raise InternalError, args
end
extend self
end
class InternalError < RuntimeError
attr_accessor :args
def initialize(args)
@args = args
super
end
end
def Erlang(&block)
ErlangHelpers.setup
loop do
cmd = ErlangHelpers.receive
if cmd == :stop
exit(0)
end
begin
ctx = Object.new
ctx.extend ErlangHelpers
ctx.instance_exec(cmd, &block)
rescue InternalError => e
ErlangHelpers.send BERT::Tuple[:error, BERT::Tuple[*e.args]]
rescue RuntimeError => e
ErlangHelpers.send BERT::Tuple[:error, BERT::Tuple[:runtime, e.class.to_s, e.message, e.backtrace]]
rescue Exception => e
ErlangHelpers.send BERT::Tuple[:error, BERT::Tuple[:system, e.class.to_s, e.message, e.backtrace]]
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems