1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
|
// xfail-pretty
use std;
import std::timer::sleep;
import std::uv;
import pipes::{recv, select};
proto! oneshot {
waiting:send {
signal -> signaled
}
signaled:send { }
}
proto! stream {
stream:send<T:send> {
send(T) -> stream<T>
}
}
fn main() {
import oneshot::client::*;
import stream::client::*;
let iotask = uv::global_loop::get();
#macro[
[#recv[chan],
chan.recv()(chan)]
];
let c = pipes::spawn_service(stream::init, |p| {
#error("waiting for pipes");
let stream::send(x, p) = option::unwrap(recv(p));
#error("got pipes");
let (left, right) : (oneshot::server::waiting,
oneshot::server::waiting)
= x;
#error("selecting");
let (i, _, _) = select(~[left, right]);
#error("selected");
assert i == 0;
#error("waiting for pipes");
let stream::send(x, _) = option::unwrap(recv(p));
#error("got pipes");
let (left, right) : (oneshot::server::waiting,
oneshot::server::waiting)
= x;
#error("selecting");
let (i, _, _) = select(~[left, right]);
#error("selected");
assert i == 1;
});
let (c1, p1) = oneshot::init();
let (c2, p2) = oneshot::init();
let c = send(c, (p1, p2));
sleep(iotask, 1000);
signal(c1);
let (c1, p1) = oneshot::init();
let (c2, p2) = oneshot::init();
send(c, (p1, p2));
sleep(iotask, 1000);
signal(c2);
}
|
