diff options
| author | Michael Bebenita <[email protected]> | 2010-07-19 17:33:50 -0700 |
|---|---|---|
| committer | Michael Bebenita <[email protected]> | 2010-07-19 17:33:50 -0700 |
| commit | c80483d582b995e7890a581e7de03c70c51df137 (patch) | |
| tree | ef174a98cf18cfee3ec63b07a8b3a28554f2de51 /src/test | |
| parent | Added a message passing system based on lock free queues for inter-thread com... (diff) | |
| download | rust-c80483d582b995e7890a581e7de03c70c51df137.tar.xz rust-c80483d582b995e7890a581e7de03c70c51df137.zip | |
Fixed circular buffer resizing bug.
Diffstat (limited to 'src/test')
| -rw-r--r-- | src/test/run-pass/task-comm-4.rs | 26 | ||||
| -rw-r--r-- | src/test/run-pass/task-comm-5.rs | 25 |
2 files changed, 49 insertions, 2 deletions
diff --git a/src/test/run-pass/task-comm-4.rs b/src/test/run-pass/task-comm-4.rs index 42ba6992..b185d425 100644 --- a/src/test/run-pass/task-comm-4.rs +++ b/src/test/run-pass/task-comm-4.rs @@ -3,8 +3,30 @@ io fn main() -> () { } io fn test00() { + let int r = 0; + let int sum = 0; let port[int] p = port(); let chan[int] c = chan(p); - c <| 42; - let int r <- p; + + c <| 1; + c <| 2; + c <| 3; + c <| 4; + + r <- p; sum += r; log (r); + r <- p; sum += r; log (r); + r <- p; sum += r; log (r); + r <- p; sum += r; log (r); + + c <| 5; + c <| 6; + c <| 7; + c <| 8; + + r <- p; sum += r; log (r); + r <- p; sum += r; log (r); + r <- p; sum += r; log (r); + r <- p; sum += r; log (r); + + check (sum == 1 + 2 + 3 + 4 + 5 + 6 + 7 + 8); }
\ No newline at end of file diff --git a/src/test/run-pass/task-comm-5.rs b/src/test/run-pass/task-comm-5.rs new file mode 100644 index 00000000..950f4149 --- /dev/null +++ b/src/test/run-pass/task-comm-5.rs @@ -0,0 +1,25 @@ +io fn main() -> () { + test00(); +} + +io fn test00() { + let int r = 0; + let int sum = 0; + let port[int] p = port(); + let chan[int] c = chan(p); + let int number_of_messages = 1000; + + let int i = 0; + while (i < number_of_messages) { + c <| i; + i += 1; + } + + i = 0; + while (i < number_of_messages) { + r <- p; sum += r; + i += 1; + } + + check (sum == ((number_of_messages * (number_of_messages - 1)) / 2)); +}
\ No newline at end of file |