Skip to content

Commit 15f39d3

Browse files
committed
---
yaml --- r: 20869 b: refs/heads/snap-stage3 c: 618d311 h: refs/heads/master i: 20867: 7cdf198 v: v3
1 parent e18bf66 commit 15f39d3

File tree

3 files changed

+18
-16
lines changed

3 files changed

+18
-16
lines changed

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,7 +1,7 @@
11
---
22
refs/heads/master: e430a699f2c60890d9b86069fd0c68a70ece7120
33
refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
4-
refs/heads/snap-stage3: 5012abde8f05b00a71b1e0546c687c8cd4bc7318
4+
refs/heads/snap-stage3: 618d311c3d9a1790c8063a0ee853b3786954cc61
55
refs/heads/try: ffbe0e0e00374358b789b0037bcb3a577cd218be
66
refs/tags/release-0.1: 1f5c5126e96c79d22cb7862f75304136e204f105
77
refs/heads/ndm: f3868061cd7988080c30d6d5bf352a5a5fe2460b

branches/snap-stage3/src/compiletest/compiletest.rs

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,11 @@ import task;
88
import core::result;
99
import result::{ok, err};
1010

11+
import comm::port;
12+
import comm::chan;
13+
import comm::send;
14+
import comm::recv;
15+
1116
import common::config;
1217
import common::mode_run_pass;
1318
import common::mode_run_fail;

branches/snap-stage3/src/compiletest/procsrv.rs

Lines changed: 12 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -2,8 +2,6 @@ import run::spawn_process;
22
import io::{writer_util, reader_util};
33
import libc::{c_int, pid_t};
44

5-
import pipes::chan;
6-
75
export run;
86

97
#[cfg(target_os = "win32")]
@@ -60,30 +58,29 @@ fn run(lib_path: ~str,
6058

6159

6260
writeclose(pipe_in.out, input);
63-
let p = pipes::port_set();
64-
let ch = p.chan();
61+
let p = comm::port();
62+
let ch = comm::chan(p);
6563
do task::spawn_sched(task::single_threaded) {
6664
let errput = readclose(pipe_err.in);
67-
ch.send((2, errput));
65+
comm::send(ch, (2, errput));
6866
}
69-
let ch = p.chan();
7067
do task::spawn_sched(task::single_threaded) {
7168
let output = readclose(pipe_out.in);
72-
ch.send((1, output));
69+
comm::send(ch, (1, output));
7370
}
7471
let status = run::waitpid(pid);
7572
let mut errs = ~"";
7673
let mut outs = ~"";
7774
let mut count = 2;
7875
while count > 0 {
79-
alt p.recv() {
80-
(1, s) {
81-
outs = s;
82-
}
83-
(2, s) {
84-
errs = s;
85-
}
86-
_ { fail }
76+
let stream = comm::recv(p);
77+
alt check stream {
78+
(1, s) {
79+
outs = s;
80+
}
81+
(2, s) {
82+
errs = s;
83+
}
8784
};
8885
count -= 1;
8986
};

0 commit comments

Comments
 (0)