squiid/rust
1
0
Fork 0
Code Issues Pull requests Projects Activity

Updating sio tests.

Browse source
This commit is contained in:
Eric Holk 2011-08-16 09:45:55 -07:00
parent cf2def46c1
commit 88a47020cf
4 changed files with 21 additions and 16 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
src/lib/aio.rs
View file

@ -130,7 +130,6 @@ fn request_task(c: _chan[ctx]) {
let req: request;
while (true) {
req = p.recv();
log_err req;
alt req {
quit. {
log "got quit message";

13
src/test/run-pass/sio-read.rs
View file

@ -1,13 +1,13 @@
// xfail-stage1
// xfail-stage2
// xfail-stage3
use std;
import std::sio;
import std::task;
import std::str;
import std::net;
fn connectTask(cx: sio::ctx, ip: str, portnum: int) {
fn connectTask(cx: sio::ctx, ip: net::ip_addr, portnum: int) {
let client: sio::client;
client = sio::connect_to(cx, ip, portnum);
let data = sio::read(client);
@ -16,11 +16,14 @@ fn connectTask(cx: sio::ctx, ip: str, portnum: int) {
fn main() {
let cx: sio::ctx = sio::new();
let srv: sio::server = sio::create_server(cx, "0.0.0.0", 9090);
let child: task = spawn connectTask(cx, "127.0.0.1", 9090);
let srv: sio::server = sio::create_server(cx,
net::parse_addr("0.0.0.0"), 9090);
let child = task::_spawn(bind connectTask(cx,
net::parse_addr("127.0.0.1"),
9090));
let client: sio::client = sio::accept_from(srv);
sio::write_data(client, str::bytes("hello, world\n"));
task::join(child);
task::join_id(child);
sio::close_client(client);
sio::close_server(srv);
sio::destroy(cx);

11
src/test/run-pass/sio-srv.rs
View file

@ -1,13 +1,14 @@
xfail-stage1
xfail-stage2
xfail-stage3
// xfail-stage1
// xfail-stage2
// xfail-stage3
use std;
import std::sio;
import std::net;
fn main() {
let cx: sio::ctx = sio::new();
let srv: sio::server = sio::create_server(cx, "127.0.0.1", 9090);
let srv: sio::server = sio::create_server(cx, net::parse_addr("127.0.0.1"),
9090);
sio::close_server(srv);
sio::destroy(cx);
}

12
src/test/run-pass/sio-write.rs
View file

@ -1,13 +1,13 @@
// xfail-stage1
// xfail-stage2
// xfail-stage3
use std;
import std::sio;
import std::task;
import std::str;
import std::net;
fn connectTask(cx: sio::ctx, ip: str, portnum: int) {
fn connectTask(cx: sio::ctx, ip: net::ip_addr, portnum: int) {
let client: sio::client;
client = sio::connect_to(cx, ip, portnum);
sio::close_client(client);
@ -15,11 +15,13 @@ fn connectTask(cx: sio::ctx, ip: str, portnum: int) {
fn main() {
let cx: sio::ctx = sio::new();
let srv: sio::server = sio::create_server(cx, "0.0.0.0", 9090);
let child: task = spawn connectTask(cx, "127.0.0.1", 9090);
let srv: sio::server = sio::create_server(cx, net::parse_addr("0.0.0.0"),
9090);
let child = task::_spawn(bind connectTask(cx, net::parse_addr("127.0.0.1"),
9090));
let client: sio::client = sio::accept_from(srv);
sio::write_data(client, str::bytes("hello, world\n"));
task::join(child);
task::join_id(child);
sio::close_client(client);
sio::close_server(srv);
sio::destroy(cx);