blob: 5608f46b699f6a3c42b6cab41c506ff438ba6f26 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
|
#! /usr/bin/env ruby
# -*- coding: UTF-8 -*-
#
module EvenDoors
#
class Spin < Room
#
@pool = {} # per particle class free list
@sys_fifo = [] # system particles fifo list
@app_fifo = [] # application particles fifo list
#
@spin = nil
@run = false
@debug_routing = false
@debug_errors = false
#
class << self
#
attr_accessor :spin, :run, :debug_routing, :debug_errors
#
def release_p p
# hope there is no circular loop
while p2=p.merged_shift
release_p p2
end
( @pool[p.class] ||= [] ) << p
end
#
def require_p p_kls
l = @pool[p_kls]
return p_kls.new if l.nil?
p = l.pop
return p_kls.new if p.nil?
p.reset!
p
end
#
def send_p p
@app_fifo << p
end
#
def send_sys_p p
@sys_fifo << p
end
#
def spin!
while @run and (@sys_fifo.length>0 or @app_fifo.length>0)
while @run and @sys_fifo.length>0
p = @sys_fifo.shift
p.dst.process_sys_p p
end
while @run and @app_fifo.length>0
p = @app_fifo.shift
p.dst.process_p p
break
end
end
end
#
def clear!
@spin= nil
@pool.clear
@sys_fifo.clear
@app_fifo.clear
end
#
end
#
def initialize n, args={}
super n, nil
raise EvenDoors::Exception.new "do not try to initialize more than one spin" if not self.class.spin.nil?
self.class.spin = self
self.class.debug_errors = args[:debug_errors] || false
self.class.debug_routing = args[:debug_routing] || false
end
#
def spin!
@spots.values.each do |spot| spot.start! end
self.class.run = true
self.class.spin!
@spots.values.each do |spot| spot.stop! end
end
#
end
#
end
#
# EOF
|
