test_net1.sh

发布/订阅系统中间件

event{ x=2 y=3 z=4 }
senp{ from="$siena1" method="PUB" ref=$ref to="$client/3" }
event{ x=2 y=3 z=4 }
senp{ from="$siena2" method="PUB" ref=$ref to="$client/6" }
event{ x=2 y=3 z=4 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/8" }
event{ x=2 y=3 z=4 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/9" }
event{ x=2 y=3 z=4 }
EOF
#
# @0 12 <-- {a any}
#
incref
send <<EOF
senp{ to="$siena0" method="SUB" ref=$ref subscriber="$client/12"}
filter{a any}
EOF
#
# @0 {x=2 a="A"} --> 1, 12
#
incref
send <<EOF
senp{ to="$siena0" method="PUB" ref=$ref}
event{x=2 a="A"}
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/1" }
event{ a="A" x=2 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/12" }
event{ a="A" x=2 }
EOF
#
# @0 {x=2 y=5 a="A"} --> 1, 2, 9, 12
#
incref
send <<EOF
senp{ to="$siena0" method="PUB" ref=$ref}
event{x=2 y=5 a="A"}
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/1" }
event{ a="A" x=2 y=5 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/12" }
event{ a="A" x=2 y=5 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/2" }
event{ a="A" x=2 y=5 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/9" }
event{ a="A" x=2 y=5 }
EOF
#
# @0 1 -X- {x any} (in fact exactly x any)
#
incref
send <<EOF
senp{ to="$siena0" method="UNS" ref=$ref subscriber="$client/1"}
filter{x any}
EOF
#
#
# @1 {x=2 z=7 a="X"} --> 3, 6, 12
#
incref
send <<EOF
senp{ to="$siena1" method="PUB" ref=$ref}
event{x=2 z=7 a="X"}
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/12" }
event{ a="X" x=2 z=7 }
senp{ from="$siena1" method="PUB" ref=$ref to="$client/3" }
event{ a="X" x=2 z=7 }
senp{ from="$siena2" method="PUB" ref=$ref to="$client/6" }
event{ a="X" x=2 z=7 }
EOF
#
# @0 13 <-- {z any}
#
incref
send <<EOF
senp{ to="$siena0" method="SUB" ref=$ref subscriber="$client/13"}
filter{z any}
EOF
#
# @2 {x=2 z=7 a="X"} --> 3, 6, 12, 13
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{x=2 z=7 a="X"}
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/12" }
event{ a="X" x=2 z=7 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/13" }
event{ a="X" x=2 z=7 }
senp{ from="$siena1" method="PUB" ref=$ref to="$client/3" }
event{ a="X" x=2 z=7 }
senp{ from="$siena2" method="PUB" ref=$ref to="$client/6" }
event{ a="X" x=2 z=7 }
EOF
#
# @1 {x=2 z=7 a="X"} --> 3, 6, 12, 13
#
incref
send <<EOF
senp{ to="$siena1" method="PUB" ref=$ref}
event{x=2 z=7 a="X"}
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/12" }
event{ a="X" x=2 z=7 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/13" }
event{ a="X" x=2 z=7 }
senp{ from="$siena1" method="PUB" ref=$ref to="$client/3" }
event{ a="X" x=2 z=7 }
senp{ from="$siena2" method="PUB" ref=$ref to="$client/6" }
event{ a="X" x=2 z=7 }
EOF
#
# @0 14 <-- {z any}
#
incref
send <<EOF
senp{ to="$siena0" method="SUB" ref=$ref subscriber="$client/14"}
filter{z any}
EOF
#
# @1 {z=7} --> 3, 13, 14
#
incref
send <<EOF
senp{ to="$siena1" method="PUB" ref=$ref}
event{ z=7 }
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/13" }
event{ z=7 }
senp{ from="$siena1" method="PUB" ref=$ref to="$client/3" }
event{ z=7 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/14" }
event{ z=7 }
EOF
#
# @0 {z=7} --> 3, 13, 14
#
incref
send <<EOF
senp{ to="$siena0" method="PUB" ref=$ref}
event{ z=7 }
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/13" }
event{ z=7 }
senp{ from="$siena1" method="PUB" ref=$ref to="$client/3" }
event{ z=7 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/14" }
event{ z=7 }
EOF
#
# @1 3 -X- {z any}
#
incref
send <<EOF
senp{ to="$siena1" method="UNS" ref=$ref subscriber="$client/3"}
filter{z any}
EOF
#
# @1 {z=7} --> 13, 14
#
incref
send <<EOF
senp{ to="$siena1" method="PUB" ref=$ref}
event{ z=7 }
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/13" }
event{ z=7 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/14" }
event{ z=7 }
EOF
#
#
# @2 {z=7} --> 13, 14
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{ z=7 }
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/13" }
event{ z=7 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/14" }
event{ z=7 }
EOF
#
# @0 13 -X- {z any}
#
incref
send <<EOF
senp{ to="$siena0" method="UNS" ref=$ref subscriber="$client/13"}
filter{z any}
EOF
#
# @2 {z=7} --> 14
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{ z=7 }
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/14" }
event{ z=7 }
EOF
#
# @0 14 -X- {z any}
#
incref
send <<EOF
senp{ to="$siena0" method="UNS" ref=$ref subscriber="$client/14"}
filter{z any}
EOF
#
# @2 {z=8} --> 
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{ z=8 }
EOF
#
# @1 {x=2 z=7 a="Y"} --> 6, 12
#
incref
send <<EOF
senp{ to="$siena1" method="PUB" ref=$ref}
event{x=2 z=7 a="Y"}
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/12" }
event{ a="Y" x=2 z=7 }
senp{ from="$siena2" method="PUB" ref=$ref to="$client/6" }
event{ a="Y" x=2 z=7 }
EOF
#
# @2 6 -X-
#
incref
send<<EOF
senp{ to="$siena2" method="BYE" ref=$ref subscriber="$client/6" }
EOF
#
# @1 {x=2 z=7 a="Y"} --> 12
#
incref
send <<EOF
senp{ to="$siena1" method="PUB" ref=$ref}
event{x=2 z=7 a="Y"}
EOF
expect <<EOF
senp{ from="$siena0" method="PUB" ref=$ref to="$client/12" }
event{ a="Y" x=2 z=7 }
EOF
#
# @1 15 <-- { x>0 y>0 }
#
incref
send<<EOF
senp{ to="$siena1" method="SUB" ref=$ref subscriber="$client/15" }
filter{ x>0 y>0 }
EOF
#
# @2 {x=2 y=17} --> 15, 2, 9 
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{x=2 y=17}
EOF
expect <<EOF
senp{ from="$siena1" method="PUB" ref=$ref to="$client/15" }
event{ x=2 y=17 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/2" }
event{ x=2 y=17 }
senp{ from="$siena0" method="PUB" ref=$ref to="$client/9" }
event{ x=2 y=17 }
EOF
#
# @0 2 -X-
#
incref
send<<EOF
senp{ to="$siena0" method="BYE" ref=$ref subscriber="$client/2" }
EOF
#
# @0 9 -X-
#
incref
send<<EOF
senp{ to="$siena0" method="BYE" ref=$ref subscriber="$client/9" }
EOF
#
# @2 {x=2 y=18} --> 15 
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{x=2 y=18}
EOF
expect <<EOF
senp{ from="$siena1" method="PUB" ref=$ref to="$client/15" }
event{ x=2 y=18 }
EOF
#
# @1 {x=2 y=18 z=1 a="A"} --> 15, 10, 8, 12
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{x=2 y=18 z=1 a="A"}
EOF
expect <<EOF
senp{ from="$siena1" method="PUB" ref=$ref to="$client/15" }
event{x=2 y=18 z=1 a="A"}
senp{ from="$siena0" method="PUB" ref=$ref to="$client/10" }
event{x=2 y=18 z=1 a="A"}
senp{ from="$siena0" method="PUB" ref=$ref to="$client/12" }
event{x=2 y=18 z=1 a="A"}
senp{ from="$siena0" method="PUB" ref=$ref to="$client/8" }
event{x=2 y=18 z=1 a="A"}
EOF
#
# @0 10 -X- {x > 0} (actually {x>0 y>0 z>0 a="A"})
#
incref
send<<EOF
senp{to="$siena0" method="UNS" ref=$ref subscriber="$client/10"}
filter{x>0}
EOF
#
# @0 12 -X-
#
incref
send<<EOF
senp{to="$siena0" method="BYE" ref=$ref subscriber="$client/12"}
EOF
#
# @2 {x=2 y=20 z=1 a="A"} --> 15, 8
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{x=2 y=20 z=1 a="A"}
EOF
expect <<EOF
senp{ from="$siena1" method="PUB" ref=$ref to="$client/15" }
event{x=2 y=20 z=1 a="A"}
senp{ from="$siena0" method="PUB" ref=$ref to="$client/8" }
event{x=2 y=20 z=1 a="A"}
EOF
#
# @0 8 -X-
#
incref
send<<EOF
senp{to="$siena0" method="BYE" ref=$ref subscriber="$client/8"}
EOF
#
# @0 11 -X-
#
incref
send<<EOF
senp{to="$siena0" method="BYE" ref=$ref subscriber="$client/11"}
EOF
#
# @2 {x=2 y=20 z=1 a="A"} --> 15
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{x=2 y=20 z=1 a="A"}
EOF
expect <<EOF
senp{ from="$siena1" method="PUB" ref=$ref to="$client/15" }
event{x=2 y=20 z=1 a="A"}
EOF
#
# @1 {x=2 y=21 z=1 a="A"} --> 15
#
incref
send <<EOF
senp{ to="$siena1" method="PUB" ref=$ref}
event{x=2 y=21 z=1 a="A"}
EOF
expect <<EOF
senp{ from="$siena1" method="PUB" ref=$ref to="$client/15" }
event{x=2 y=21 z=1 a="A"}
EOF
#
# @2 15 -X-
#
incref
send<<EOF
senp{to="$siena1" method="BYE" ref=$ref subscriber="$client/15"}
EOF
#
# @2 {x=2 y=20 z=1 a="A"} --> 15
#
incref
send <<EOF
senp{ to="$siena2" method="PUB" ref=$ref}
event{x=2 y=20 z=1 a="A"}
EOF
#
#
# -------------------- TEST ENDS HERE ---------------------
#
closetest $*