// Copyright 2012 The Rust Project Developers. See the COPYRIGHT // file at the top-level directory of this distribution and at // http://rust-lang.org/COPYRIGHT. // // Licensed under the Apache License, Version 2.0 or the MIT license // , at your // option. This file may not be copied, modified, or distributed // except according to those terms. use pipes::send; use pipes::Chan; use pipes::recv; pub fn main() { test00(); } fn test00() { let mut r: int = 0; let mut sum: int = 0; let p = pipes::PortSet(); let c0 = p.chan(); let c1 = p.chan(); let c2 = p.chan(); let c3 = p.chan(); let number_of_messages: int = 1000; let mut i: int = 0; while i < number_of_messages { c0.send(i + 0); c1.send(i + 0); c2.send(i + 0); c3.send(i + 0); i += 1; } i = 0; while i < number_of_messages { r = p.recv(); sum += r; r = p.recv(); sum += r; r = p.recv(); sum += r; r = p.recv(); sum += r; i += 1; } assert (sum == 1998000); // assert (sum == 4 * ((number_of_messages * // (number_of_messages - 1)) / 2)); }