Skip to content

Commit e82535e

Browse files
ericktgraydon
authored andcommitted
---
yaml --- r: 4735 b: refs/heads/master c: f764f9a h: refs/heads/master i: 4733: 90ca6ff 4731: 25f879b 4727: e6805d1 4719: 03827ba 4703: 0c01df6 4671: 4350ee3 4607: 90c3a45 v: v3
1 parent 76ffffc commit e82535e

20 files changed

+145
-145
lines changed

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,2 @@
11
---
2-
refs/heads/master: 8043788e3a71a951892577cbcb623ac94b908677
2+
refs/heads/master: f764f9a8cf52e686ba6e54b594e6bbbdd5bc7b32

trunk/src/lib/aio.rs

Lines changed: 24 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@ native "rust" mod rustrt {
1515
fn aio_init();
1616
fn aio_run();
1717
fn aio_stop();
18-
fn aio_connect(host: *u8, port: int, connected: &_chan[socket]);
19-
fn aio_serve(host: *u8, port: int, acceptChan: &_chan[socket]) -> server;
20-
fn aio_writedata(s: socket, buf: *u8, size: uint, status: &_chan[bool]);
21-
fn aio_read(s: socket, reader: &_chan[[u8]]);
22-
fn aio_close_server(s: server, status: &_chan[bool]);
18+
fn aio_connect(host: *u8, port: int, connected: &_chan<socket>);
19+
fn aio_serve(host: *u8, port: int, acceptChan: &_chan<socket>) -> server;
20+
fn aio_writedata(s: socket, buf: *u8, size: uint, status: &_chan<bool>);
21+
fn aio_read(s: socket, reader: &_chan<[u8]>);
22+
fn aio_close_server(s: server, status: &_chan<bool>);
2323
fn aio_close_socket(s: socket);
2424
fn aio_is_null_client(s: socket) -> bool;
2525
}
@@ -40,36 +40,36 @@ tag socket_event {
4040
}
4141

4242
tag server_event {
43-
pending(_chan[_chan[socket_event]]);
43+
pending(_chan<_chan<socket_event>>);
4444
}
4545

4646
tag request {
4747
quit;
48-
connect(pending_connection,_chan[socket_event]);
49-
serve(net::ip_addr,int,_chan[server_event],_chan[server]);
50-
write(client,[u8],_chan[bool]);
51-
close_server(server, _chan[bool]);
48+
connect(pending_connection,_chan<socket_event>);
49+
serve(net::ip_addr,int,_chan<server_event>,_chan<server>);
50+
write(client,[u8],_chan<bool>);
51+
close_server(server, _chan<bool>);
5252
close_client(client);
5353
}
5454

55-
type ctx = _chan[request];
55+
type ctx = _chan<request>;
5656

5757
fn ip_to_sbuf(ip: net::ip_addr) -> *u8 {
5858
vec::to_ptr(str::bytes(net::format_addr(ip)))
5959
}
6060

61-
fn connect_task(ip: net::ip_addr, portnum: int, evt: _chan[socket_event]) {
62-
let connecter: _port[client] = mk_port();
61+
fn connect_task(ip: net::ip_addr, portnum: int, evt: _chan<socket_event>) {
62+
let connecter: _port<client> = mk_port();
6363
rustrt::aio_connect(ip_to_sbuf(ip), portnum, connecter.mk_chan());
6464
let client = connecter.recv();
6565
new_client(client, evt);
6666
}
6767

68-
fn new_client(client: client, evt: _chan[socket_event]) {
68+
fn new_client(client: client, evt: _chan<socket_event>) {
6969
// Start the read before notifying about the connect. This avoids a race
7070
// condition where the receiver can close the socket before we start
7171
// reading.
72-
let reader: _port[[u8]] = mk_port();
72+
let reader: _port<[u8]> = mk_port();
7373
rustrt::aio_read(client, reader.mk_chan());
7474

7575
send(evt, connected(client));
@@ -92,18 +92,18 @@ fn new_client(client: client, evt: _chan[socket_event]) {
9292
log "close message sent";
9393
}
9494

95-
fn accept_task(client: client, events: _chan[server_event]) {
95+
fn accept_task(client: client, events: _chan<server_event>) {
9696
log "accept task was spawned";
97-
let p: _port[_chan[socket_event]] = mk_port();
97+
let p: _port<_chan<socket_event>> = mk_port();
9898
send(events, pending(p.mk_chan()));
9999
let evt = p.recv();
100100
new_client(client, evt);
101101
log "done accepting";
102102
}
103103

104-
fn server_task(ip: net::ip_addr, portnum: int, events: _chan[server_event],
105-
server: _chan[server]) {
106-
let accepter: _port[client] = mk_port();
104+
fn server_task(ip: net::ip_addr, portnum: int, events: _chan<server_event>,
105+
server: _chan<server>) {
106+
let accepter: _port<client> = mk_port();
107107
send(server, rustrt::aio_serve(ip_to_sbuf(ip), portnum,
108108
accepter.mk_chan()));
109109

@@ -120,9 +120,9 @@ fn server_task(ip: net::ip_addr, portnum: int, events: _chan[server_event],
120120
}
121121
}
122122

123-
fn request_task(c: _chan[ctx]) {
123+
fn request_task(c: _chan<ctx>) {
124124
// Create a port to accept IO requests on
125-
let p: _port[request] = mk_port();
125+
let p: _port<request> = mk_port();
126126
// Hand of its channel to our spawner
127127
send(c, p.mk_chan());
128128
log "uv run task spawned";
@@ -160,7 +160,7 @@ fn request_task(c: _chan[ctx]) {
160160
}
161161
}
162162

163-
fn iotask(c: _chan[ctx]) {
163+
fn iotask(c: _chan<ctx>) {
164164
log "io task spawned";
165165
// Initialize before accepting requests
166166
rustrt::aio_init();
@@ -178,7 +178,7 @@ fn iotask(c: _chan[ctx]) {
178178
}
179179

180180
fn new() -> ctx {
181-
let p: _port[ctx] = mk_port();
181+
let p: _port<ctx> = mk_port();
182182
task::_spawn(bind iotask(p.mk_chan()));
183183
ret p.recv();
184184
}

trunk/src/lib/comm.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ obj _port[~T](raw_port : @port_ptr) {
5959
}
6060
}
6161

62-
fn mk_port[~T]() -> _port[T] {
62+
fn mk_port[~T]() -> _port<T> {
6363
_port(@port_ptr(rustrt::new_port(sys::size_of[T]())))
6464
}
6565

trunk/src/lib/deque.rs

Lines changed: 13 additions & 13 deletions
Original file line numberDiff line numberDiff line change
@@ -16,8 +16,8 @@ type t[T] =
1616
fn get(int) -> T ;
1717
};
1818

19-
fn create[@T]() -> t[T] {
20-
type cell[T] = option::t[T];
19+
fn create[@T]() -> t<T> {
20+
type cell[T] = option::t<T>;
2121

2222
let initial_capacity: uint = 32u; // 2^5
2323
/**
@@ -26,8 +26,8 @@ fn create[@T]() -> t[T] {
2626
*/
2727

2828

29-
fn grow[@T](nelts: uint, lo: uint, elts: &[mutable cell[T]]) ->
30-
[mutable cell[T]] {
29+
fn grow[@T](nelts: uint, lo: uint, elts: &[mutable cell<T>]) ->
30+
[mutable cell<T>] {
3131
assert (nelts == vec::len(elts));
3232
let rv = ~[mutable];
3333

@@ -42,22 +42,22 @@ fn create[@T]() -> t[T] {
4242

4343
ret rv;
4444
}
45-
fn get[@T](elts: &[mutable cell[T]], i: uint) -> T {
45+
fn get[@T](elts: &[mutable cell<T>], i: uint) -> T {
4646
ret alt elts.(i) { option::some(t) { t } _ { fail } };
4747
}
4848
obj deque[@T](mutable nelts: uint,
4949
mutable lo: uint,
5050
mutable hi: uint,
51-
mutable elts: [mutable cell[T]]) {
51+
mutable elts: [mutable cell<T>]) {
5252
fn size() -> uint { ret nelts; }
5353
fn add_front(t: &T) {
5454
let oldlo: uint = lo;
5555
if lo == 0u {
56-
lo = vec::len[cell[T]](elts) - 1u;
56+
lo = vec::len[cell<T>](elts) - 1u;
5757
} else { lo -= 1u; }
5858
if lo == hi {
5959
elts = grow[T](nelts, oldlo, elts);
60-
lo = vec::len[cell[T]](elts) - 1u;
60+
lo = vec::len[cell<T>](elts) - 1u;
6161
hi = nelts;
6262
}
6363
elts.(lo) = option::some[T](t);
@@ -70,7 +70,7 @@ fn create[@T]() -> t[T] {
7070
hi = nelts;
7171
}
7272
elts.(hi) = option::some[T](t);
73-
hi = (hi + 1u) % vec::len[cell[T]](elts);
73+
hi = (hi + 1u) % vec::len[cell<T>](elts);
7474
nelts += 1u;
7575
}
7676

@@ -81,13 +81,13 @@ fn create[@T]() -> t[T] {
8181
fn pop_front() -> T {
8282
let t: T = get[T](elts, lo);
8383
elts.(lo) = option::none[T];
84-
lo = (lo + 1u) % vec::len[cell[T]](elts);
84+
lo = (lo + 1u) % vec::len[cell<T>](elts);
8585
nelts -= 1u;
8686
ret t;
8787
}
8888
fn pop_back() -> T {
8989
if hi == 0u {
90-
hi = vec::len[cell[T]](elts) - 1u;
90+
hi = vec::len[cell<T>](elts) - 1u;
9191
} else { hi -= 1u; }
9292
let t: T = get[T](elts, hi);
9393
elts.(hi) = option::none[T];
@@ -97,11 +97,11 @@ fn create[@T]() -> t[T] {
9797
fn peek_front() -> T { ret get[T](elts, lo); }
9898
fn peek_back() -> T { ret get[T](elts, hi - 1u); }
9999
fn get(i: int) -> T {
100-
let idx: uint = (lo + (i as uint)) % vec::len[cell[T]](elts);
100+
let idx: uint = (lo + (i as uint)) % vec::len[cell<T>](elts);
101101
ret get[T](elts, idx);
102102
}
103103
}
104-
let v: [mutable cell[T]] =
104+
let v: [mutable cell<T>] =
105105
vec::init_elt_mut(option::none, initial_capacity);
106106
ret deque[T](0u, 0u, 0u, v);
107107
}

trunk/src/lib/ebml.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ fn doc_at(data: &@[u8], start: uint) -> doc {
5050
ret {data: data, start: elt_size.next, end: end};
5151
}
5252

53-
fn maybe_get_doc(d: doc, tg: uint) -> option::t[doc] {
53+
fn maybe_get_doc(d: doc, tg: uint) -> option::t<doc> {
5454
let pos = d.start;
5555
while pos < d.end {
5656
let elt_tag = vint_at(*d.data, pos);

trunk/src/lib/either.rs

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -6,30 +6,30 @@ import option::none;
66
tag t[T, U] { left(T); right(U); }
77

88
fn either[T, U, V](f_left: &block(&T) -> V, f_right: &block(&U) -> V,
9-
value: &t[T, U]) -> V {
9+
value: &t<T, U>) -> V {
1010
alt value { left(l) { f_left(l) } right(r) { f_right(r) } }
1111
}
1212

13-
fn lefts[T, U](eithers: &[t[T, U]]) -> [T] {
13+
fn lefts[T, U](eithers: &[t<T, U>]) -> [T] {
1414
let result: [T] = ~[];
15-
for elt: t[T, U] in eithers {
15+
for elt: t<T, U> in eithers {
1616
alt elt { left(l) { result += ~[l] } _ {/* fallthrough */ } }
1717
}
1818
ret result;
1919
}
2020

21-
fn rights[T, U](eithers: &[t[T, U]]) -> [U] {
21+
fn rights[T, U](eithers: &[t<T, U>]) -> [U] {
2222
let result: [U] = ~[];
23-
for elt: t[T, U] in eithers {
23+
for elt: t<T, U> in eithers {
2424
alt elt { right(r) { result += ~[r] } _ {/* fallthrough */ } }
2525
}
2626
ret result;
2727
}
2828

29-
fn partition[T, U](eithers: &[t[T, U]]) -> {lefts: [T], rights: [U]} {
29+
fn partition[T, U](eithers: &[t<T, U>]) -> {lefts: [T], rights: [U]} {
3030
let lefts: [T] = ~[];
3131
let rights: [U] = ~[];
32-
for elt: t[T, U] in eithers {
32+
for elt: t<T, U> in eithers {
3333
alt elt { left(l) { lefts += ~[l] } right(r) { rights += ~[r] } }
3434
}
3535
ret {lefts: lefts, rights: rights};

trunk/src/lib/extfmt.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ mod ct {
6060

6161
// A formatted conversion from an expression to a string
6262
type conv =
63-
{param: option::t[int],
63+
{param: option::t<int>,
6464
flags: [flag],
6565
width: count,
6666
precision: count,
@@ -105,7 +105,7 @@ mod ct {
105105
ret pieces;
106106
}
107107
fn peek_num(s: str, i: uint, lim: uint) ->
108-
option::t[{num: uint, next: uint}] {
108+
option::t<{num: uint, next: uint}> {
109109
if i >= lim { ret none; }
110110
let c = s.(i);
111111
if !('0' as u8 <= c && c <= '9' as u8) { ret option::none; }
@@ -135,7 +135,7 @@ mod ct {
135135
next: ty.next};
136136
}
137137
fn parse_parameter(s: str, i: uint, lim: uint) ->
138-
{param: option::t[int], next: uint} {
138+
{param: option::t<int>, next: uint} {
139139
if i >= lim { ret {param: none, next: i}; }
140140
let num = peek_num(s, i, lim);
141141
ret alt num {

trunk/src/lib/generic_os.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3,7 +3,7 @@ import str::sbuf;
33

44
#[cfg(target_os = "linux")]
55
#[cfg(target_os = "macos")]
6-
fn getenv(n: str) -> option::t[str] {
6+
fn getenv(n: str) -> option::t<str> {
77
let s = os::libc::getenv(str::buf(n));
88
ret if s as int == 0 {
99
option::none[str]
@@ -19,7 +19,7 @@ fn setenv(n: str, v: str) {
1919
}
2020

2121
#[cfg(target_os = "win32")]
22-
fn getenv(n: str) -> option::t[str] {
22+
fn getenv(n: str) -> option::t<str> {
2323
let nbuf = str::buf(n);
2424
let nsize = 256u;
2525
while true {

trunk/src/lib/getopts.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -75,7 +75,7 @@ fn name_str(nm: name) -> str {
7575
ret alt nm { short(ch) { str::from_char(ch) } long(s) { s } };
7676
}
7777

78-
fn find_opt(opts: &[opt], nm: name) -> option::t[uint] {
78+
fn find_opt(opts: &[opt], nm: name) -> option::t<uint> {
7979
let i = 0u;
8080
let l = vec::len[opt](opts);
8181
while i < l { if opts.(i).name == nm { ret some[uint](i); } i += 1u; }
@@ -224,7 +224,7 @@ fn opt_strs(m: &match, nm: str) -> [str] {
224224
ret acc;
225225
}
226226

227-
fn opt_maybe_str(m: &match, nm: str) -> option::t[str] {
227+
fn opt_maybe_str(m: &match, nm: str) -> option::t<str> {
228228
let vals = opt_vals(m, nm);
229229
if vec::len[optval](vals) == 0u { ret none[str]; }
230230
ret alt vals.(0) { val(s) { some[str](s) } _ { none[str] } };
@@ -234,7 +234,7 @@ fn opt_maybe_str(m: &match, nm: str) -> option::t[str] {
234234
/// Returns none if the option was not present, `def` if the option was
235235
/// present but no argument was provided, and the argument if the option was
236236
/// present and an argument was provided.
237-
fn opt_default(m: &match, nm: str, def: str) -> option::t[str] {
237+
fn opt_default(m: &match, nm: str, def: str) -> option::t<str> {
238238
let vals = opt_vals(m, nm);
239239
if vec::len[optval](vals) == 0u { ret none[str]; }
240240
ret alt vals.(0) { val(s) { some[str](s) } _ { some[str](def) } }

trunk/src/lib/io.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -59,7 +59,7 @@ resource FILE_res(f: os::libc::FILE) {
5959
os::libc::fclose(f);
6060
}
6161

62-
obj FILE_buf_reader(f: os::libc::FILE, res: option::t[@FILE_res]) {
62+
obj FILE_buf_reader(f: os::libc::FILE, res: option::t<@FILE_res>) {
6363
fn read(len: uint) -> [u8] {
6464
let buf = ~[];
6565
vec::reserve[u8](buf, len);
@@ -243,7 +243,7 @@ type buf_writer =
243243
fn tell() -> uint ;
244244
};
245245

246-
obj FILE_writer(f: os::libc::FILE, res: option::t[@FILE_res]) {
246+
obj FILE_writer(f: os::libc::FILE, res: option::t<@FILE_res>) {
247247
fn write(v: &[u8]) {
248248
let len = vec::len[u8](v);
249249
let vbuf = vec::to_ptr[u8](v);
@@ -262,7 +262,7 @@ resource fd_res(fd: int) {
262262
os::libc::close(fd);
263263
}
264264

265-
obj fd_buf_writer(fd: int, res: option::t[@fd_res]) {
265+
obj fd_buf_writer(fd: int, res: option::t<@fd_res>) {
266266
fn write(v: &[u8]) {
267267
let len = vec::len[u8](v);
268268
let count = 0u;

0 commit comments

Comments
 (0)