Skip to content

Commit daac213

Browse files
committed
---
yaml --- r: 101643 b: refs/heads/master c: 49ac48d h: refs/heads/master i: 101641: 53bd278 101639: d714dee v: v3
1 parent df41040 commit daac213

File tree

2 files changed

+19
-3
lines changed

2 files changed

+19
-3
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: 337e62e4d65e24682ba323b65283a59715a0c8af
2+
refs/heads/master: 49ac48db3fe2666751908668ba8e5ab16e2fb07a
33
refs/heads/snap-stage1: e33de59e47c5076a89eadeb38f4934f58a3618a6
44
refs/heads/snap-stage3: 6e7f170fedd3c526a643c0b2d13863acd982be02
55
refs/heads/try: a97642026c18a624ff6ea01075dd9550f8ed07ff

trunk/src/libstd/io/mem.rs

Lines changed: 18 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -177,7 +177,11 @@ impl Seek for MemReader {
177177

178178
impl Buffer for MemReader {
179179
fn fill<'a>(&'a mut self) -> IoResult<&'a [u8]> {
180-
Ok(self.buf.slice_from(self.pos))
180+
if self.pos < self.buf.len() {
181+
Ok(self.buf.slice_from(self.pos))
182+
} else {
183+
Err(io::standard_error(io::EndOfFile))
184+
}
181185
}
182186
fn consume(&mut self, amt: uint) { self.pos += amt; }
183187
}
@@ -308,7 +312,11 @@ impl<'a> Seek for BufReader<'a> {
308312

309313
impl<'a> Buffer for BufReader<'a> {
310314
fn fill<'a>(&'a mut self) -> IoResult<&'a [u8]> {
311-
Ok(self.buf.slice_from(self.pos))
315+
if self.pos < self.buf.len() {
316+
Ok(self.buf.slice_from(self.pos))
317+
} else {
318+
Err(io::standard_error(io::EndOfFile))
319+
}
312320
}
313321
fn consume(&mut self, amt: uint) { self.pos += amt; }
314322
}
@@ -421,6 +429,10 @@ mod test {
421429
assert_eq!(reader.read(buf), Ok(3));
422430
assert_eq!(buf.slice(0, 3), [5, 6, 7]);
423431
assert!(reader.read(buf).is_err());
432+
let mut reader = MemReader::new(~[0, 1, 2, 3, 4, 5, 6, 7]);
433+
assert_eq!(reader.read_until(3).unwrap(), ~[0, 1, 2, 3]);
434+
assert_eq!(reader.read_until(3).unwrap(), ~[4, 5, 6, 7]);
435+
assert!(reader.read(buf).is_err());
424436
}
425437

426438
#[test]
@@ -441,6 +453,10 @@ mod test {
441453
assert_eq!(reader.read(buf), Ok(3));
442454
assert_eq!(buf.slice(0, 3), [5, 6, 7]);
443455
assert!(reader.read(buf).is_err());
456+
let mut reader = BufReader::new(in_buf);
457+
assert_eq!(reader.read_until(3).unwrap(), ~[0, 1, 2, 3]);
458+
assert_eq!(reader.read_until(3).unwrap(), ~[4, 5, 6, 7]);
459+
assert!(reader.read(buf).is_err());
444460
}
445461

446462
#[test]

0 commit comments

Comments
 (0)