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
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
|
#! /usr/bin/env ruby
# -*- coding: UTF-8 -*-
require 'evendoors'
#
class InputDoor < EvenDoors::Door
#
def start!
puts " * start #{self.class.name} #{@path}" if EvenDoors::Twirl.debug_routing
@lines = [ "#{name} says : hello", "world ( from #{path} )" ]
p = require_p EvenDoors::Particle
p.set_dst! EvenDoors::ACT_GET, path
send_p p
end
#
# def stop!
# puts " * stop #{self.class.name} #{@path}" if EvenDoors::Twirl.debug_routing
# end
#
def receive_p p
puts " * #{self.class.name} receive_p : #{p.action}" if EvenDoors::Twirl.debug_routing
if p.action==EvenDoors::ACT_GET
p.reset!
p.set_data 'line', @lines.shift
p.set_data 'f0', 'v0'
p.set_data 'f1', 'v1'
p.set_data 'f2', 'v2'
send_p p
if @lines.length>0
p = require_p EvenDoors::Particle
p.set_dst! EvenDoors::ACT_GET, name
send_p p
end
else
# we can release it or let the Door do it
release_p p
end
end
#
end
#
class ConcatBoard < EvenDoors::Board
#
def receive_p p
puts " * #{self.class.name} receive_p : #{p.action}" if EvenDoors::Twirl.debug_routing
if p.action==EvenDoors::ACT_ERROR
#
else
# MANUALLY
# p2 = p.merged_shift
# p.set_data 'line', (p.data('line')+' '+p2.data('line'))
# release_p p2
#
# Or let the system do it
p.set_data 'line', (p.data('line')+' '+p.merged(0).data('line'))
send_p p
end
end
#
end
#
class OutputDoor < EvenDoors::Door
#
# def start!
# puts " * start #{self.class.name} #{@path}" if EvenDoors::Twirl.debug_routing
# end
#
# def stop!
# puts " * stop #{self.class.name} #{@path}" if EvenDoors::Twirl.debug_routing
# end
#
def receive_p p
if EvenDoors::Twirl.debug_routing
puts " * #{self.class.name} receive_p : #{@path} : DATA #{p.get_data('line')}"
else
puts p.get_data 'line'
end
# we do nothing EvenDoors::Twirl.process will detect it and release it
end
#
end
#
space = EvenDoors::Space.new 'space', :debug_routing=>false, :debug_errors=>true
#
room0 = EvenDoors::Room.new 'room0', space
room1 = space.add_spot EvenDoors::Room.new 'room1'
#
input0 = room0.add_spot InputDoor.new 'input0'
output0 = room0.add_spot OutputDoor.new 'output0'
#
input1 = InputDoor.new 'input1'
output1 = OutputDoor.new 'output1'
room1.add_spot input1
room1.add_spot output1
room1.add_spot ConcatBoard.new 'concat1'
#
room0.add_link EvenDoors::Link.new('input0', 'output0', nil, nil, nil)
#
p0 = EvenDoors::Twirl.require_p EvenDoors::Particle
p0.set_data EvenDoors::LNK_SRC, 'input1'
p0.set_data EvenDoors::LNK_DSTS, 'concat1?follow,output1'
p0.set_data EvenDoors::LNK_FIELDS, 'f0,f2'
p0.set_data EvenDoors::LNK_CONDF, 'f0,f1,f2'
p0.set_data EvenDoors::LNK_CONDV, 'v0v1v2'
p0.set_dst! EvenDoors::SYS_ACT_ADD_LINK, room1.path
room1.send_sys_p p0 # send_sys_p -> room0 -> space -> room1 -> input1
#
space.twirl!
#
#
# EOF
|
