Skip to content

Commit c661d48

Browse files
committed
---
yaml --- r: 22941 b: refs/heads/master c: 1d04b0e h: refs/heads/master i: 22939: 1315d18 v: v3
1 parent 5ee1287 commit c661d48

File tree

3 files changed

+16
-18
lines changed

3 files changed

+16
-18
lines changed

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
---
2-
refs/heads/master: 1f2178e2d3e274d29146a3380a8ae09a4f9beb27
2+
refs/heads/master: 1d04b0ed5ac829594a412298cb9f9455d1a4d843
33
refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
44
refs/heads/snap-stage3: cd6f24f9d14ac90d167386a56e7a6ac1f0318195
55
refs/heads/try: ffbe0e0e00374358b789b0037bcb3a577cd218be

trunk/src/compiletest/compiletest.rs

Lines changed: 0 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,11 +8,6 @@ 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-
1611
import common::config;
1712
import common::mode_run_pass;
1813
import common::mode_run_fail;

trunk/src/compiletest/procsrv.rs

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

5+
import pipes::chan;
6+
57
export run;
68

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

5961

6062
writeclose(pipe_in.out, input);
61-
let p = comm::port();
62-
let ch = comm::chan(p);
63+
let p = pipes::port_set();
64+
let ch = p.chan();
6365
do task::spawn_sched(task::single_threaded) {
6466
let errput = readclose(pipe_err.in);
65-
comm::send(ch, (2, errput));
67+
ch.send((2, errput));
6668
}
69+
let ch = p.chan();
6770
do task::spawn_sched(task::single_threaded) {
6871
let output = readclose(pipe_out.in);
69-
comm::send(ch, (1, output));
72+
ch.send((1, output));
7073
}
7174
let status = run::waitpid(pid);
7275
let mut errs = ~"";
7376
let mut outs = ~"";
7477
let mut count = 2;
7578
while count > 0 {
76-
let stream = comm::recv(p);
77-
alt check stream {
78-
(1, s) {
79-
outs = s;
80-
}
81-
(2, s) {
82-
errs = s;
83-
}
79+
alt p.recv() {
80+
(1, s) {
81+
outs = s;
82+
}
83+
(2, s) {
84+
errs = s;
85+
}
86+
_ { fail }
8487
};
8588
count -= 1;
8689
};

0 commit comments

Comments
 (0)