65 lines
1.5 KiB
Rust
65 lines
1.5 KiB
Rust
// xfail-fast
|
|
|
|
// 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 <LICENSE-APACHE or
|
|
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
|
|
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
|
|
// option. This file may not be copied, modified, or distributed
|
|
// except according to those terms.
|
|
|
|
// An example to make sure the protocol parsing syntax extension works.
|
|
|
|
use core::cell::Cell;
|
|
use core::option;
|
|
|
|
proto! pingpong (
|
|
ping:send {
|
|
ping -> pong
|
|
}
|
|
|
|
pong:recv {
|
|
pong -> ping
|
|
}
|
|
)
|
|
|
|
mod test {
|
|
use core::pipes::recv;
|
|
use pingpong::{ping, pong};
|
|
|
|
pub fn client(chan: ::pingpong::client::ping) {
|
|
use pingpong::client;
|
|
|
|
let chan = client::ping(chan);
|
|
error!(~"Sent ping");
|
|
let pong(_chan) = recv(chan);
|
|
error!(~"Received pong");
|
|
}
|
|
|
|
pub fn server(chan: ::pingpong::server::ping) {
|
|
use pingpong::server;
|
|
|
|
let ping(chan) = recv(chan);
|
|
error!(~"Received ping");
|
|
let _chan = server::pong(chan);
|
|
error!(~"Sent pong");
|
|
}
|
|
}
|
|
|
|
pub fn main() {
|
|
let (client_, server_) = pingpong::init();
|
|
let client_ = Cell(client_);
|
|
let server_ = Cell(server_);
|
|
|
|
do task::spawn {
|
|
let client__ = client_.take();
|
|
test::client(client__);
|
|
};
|
|
do task::spawn {
|
|
let server__ = server_.take();
|
|
test::server(server__);
|
|
};
|
|
}
|