Project: OpenWFEru
Revision: 1649
Author: jmettraux
Date: 07 Apr 2008 20:49:36
Changes:added cancel tests for 'listen'
Files:modified: /trunk/openwfe-ruby/CREDITS.txt (
try)
modified: /trunk/openwfe-ruby/test/ft_38b_tag.rb (
try)
modified: /trunk/openwfe-ruby/test/ft_54c_listen.rb (
try)
modified: /trunk/openwfe-ruby/lib/openwfe/expool/yamlexpstorage.rb (
try)
modified: /trunk/openwfe-ruby/test/ft_8_forget.rb (
try)
modified: /trunk/openwfe-ruby/test/ft_55_ptimeout.rb (
try)
Diff:
| ... | ...@@ -20,4 +20,5 @@ |
| 20 | 20 | ------------ |
| 21 | 21 | |
| 22 | Maarten Oelering - bug reports and test cases |
| 22 | 23 | Nick Petrella - socket listener issues and Python interactivity, dollar patch |
| 23 | 24 | Sakaguchi Masa - japanese website and articles in Japanese magazines |
| ... | ...@@ -40,5 +41,4 @@ |
| 40 | 41 | -------- |
| 41 | 42 | |
| 42 | | Maarten Oelering - bug reports and test cases |
| 43 | 43 | Aye Thu - missing 'atom-tools' dependency |
| 44 | 44 | Machiel Groeneveld - missing 'rufus-mnemo' dependency |
| ... | ...@@ -69,4 +69,5 @@ |
| 69 | 69 | |
| 70 | 70 | @engine.wait_for fei |
| 71 | |
| 71 | 72 | dotest TestTag4, "peekin\npeekout" |
| 72 | 73 | end |
| ... | ...@@ -33,5 +33,5 @@ |
| 33 | 33 | |
| 34 | 34 | sequence do |
| 35 | | _sleep "500" |
| 35 | _sleep "300" |
| 36 | 36 | participant :ref => "channel_z" |
| 37 | 37 | channel_z |
| ... | ...@@ -61,5 +61,5 @@ |
| 61 | 61 | end |
| 62 | 62 | sequence do |
| 63 | | _sleep "400" |
| 63 | _sleep "300" |
| 64 | 64 | channel9 |
| 65 | 65 | end |
| ... | ...@@ -69,4 +69,6 @@ |
| 69 | 69 | def test_1 |
| 70 | 70 | |
| 71 | log_level_to_debug |
| 72 | |
| 71 | 73 | @engine.register_participant "channel9", OpenWFE::NullParticipant |
| 72 | 74 | @engine.register_participant "listen9", OpenWFE::NullParticipant |
| ... | ...@@ -79,4 +81,6 @@ |
| 79 | 81 | assert_equal 8, @engine.get_expression_storage.size |
| 80 | 82 | |
| 83 | #puts @engine.get_expression_storage |
| 84 | |
| 81 | 85 | @engine.cancel_process fei |
| 82 | 86 | |
| ... | ...@@ -88,10 +88,13 @@ |
| 88 | 88 | each_object_path do |path| |
| 89 | 89 | |
| 90 | | unless path.match /\/engine_environment.yaml$/ |
| 90 | unless path[-23..-1] == 'engine_environment.yaml' |
| 91 | |
| 91 | 92 | a = self.class.split_file_path path |
| 93 | |
| 92 | 94 | next unless a |
| 93 | 95 | # not an expression file |
| 94 | 96 | |
| 95 | 97 | wfid = a[0] |
| 98 | |
| 96 | 99 | next if wfid_regex and (not wfid_regex.match(wfid)) |
| 97 | 100 | end |
| ... | ...@@ -38,7 +38,5 @@ |
| 38 | 38 | </sequence> |
| 39 | 39 | </process-definition>''', |
| 40 | | "a\nc", |
| 41 | | true, |
| 42 | | false) |
| 40 | "a\nc") |
| 43 | 41 | end |
| 44 | 42 | |
| ... | ...@@ -45,5 +45,5 @@ |
| 45 | 45 | #log_level_to_debug |
| 46 | 46 | |
| 47 | | @engine.register_participant :channel_z, NullParticipant |
| 47 | @engine.register_participant :channel_z, OpenWFE::NullParticipant |
| 48 | 48 | |
| 49 | 49 | #require 'pp'; pp(scheduler.pending_jobs) |
To list