buffered.rs 34 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105
  1. // Copyright 2013 The Rust Project Developers. See the COPYRIGHT
  2. // file at the top-level directory of this distribution and at
  3. // http://rust-lang.org/COPYRIGHT.
  4. //
  5. // Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
  6. // http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
  7. // <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
  8. // option. This file may not be copied, modified, or distributed
  9. // except according to those terms.
  10. //! Buffering wrappers for I/O traits
  11. use core::prelude::v1::*;
  12. use io::prelude::*;
  13. use core::cmp;
  14. use core::fmt;
  15. use io::{self, DEFAULT_BUF_SIZE, Error, ErrorKind, SeekFrom};
  16. use io::memchr;
  17. /// The `BufReader` struct adds buffering to any reader.
  18. ///
  19. /// It can be excessively inefficient to work directly with a `Read` instance.
  20. /// For example, every call to `read` on `TcpStream` results in a system call.
  21. /// A `BufReader` performs large, infrequent reads on the underlying `Read`
  22. /// and maintains an in-memory buffer of the results.
  23. ///
  24. /// # Examples
  25. ///
  26. /// ```
  27. /// use std::io::prelude::*;
  28. /// use std::io::BufReader;
  29. /// use std::fs::File;
  30. ///
  31. /// # fn foo() -> std::io::Result<()> {
  32. /// let mut f = try!(File::open("log.txt"));
  33. /// let mut reader = BufReader::new(f);
  34. ///
  35. /// let mut line = String::new();
  36. /// let len = try!(reader.read_line(&mut line));
  37. /// println!("First line is {} bytes long", len);
  38. /// # Ok(())
  39. /// # }
  40. /// ```
  41. pub struct BufReader<R> {
  42. inner: R,
  43. buf: Box<[u8]>,
  44. pos: usize,
  45. cap: usize,
  46. }
  47. impl<R: Read> BufReader<R> {
  48. /// Creates a new `BufReader` with a default buffer capacity.
  49. ///
  50. /// # Examples
  51. ///
  52. /// ```
  53. /// use std::io::BufReader;
  54. /// use std::fs::File;
  55. ///
  56. /// # fn foo() -> std::io::Result<()> {
  57. /// let mut f = try!(File::open("log.txt"));
  58. /// let mut reader = BufReader::new(f);
  59. /// # Ok(())
  60. /// # }
  61. /// ```
  62. pub fn new(inner: R) -> BufReader<R> {
  63. BufReader::with_capacity(DEFAULT_BUF_SIZE, inner)
  64. }
  65. /// Creates a new `BufReader` with the specified buffer capacity.
  66. ///
  67. /// # Examples
  68. ///
  69. /// Creating a buffer with ten bytes of capacity:
  70. ///
  71. /// ```
  72. /// use std::io::BufReader;
  73. /// use std::fs::File;
  74. ///
  75. /// # fn foo() -> std::io::Result<()> {
  76. /// let mut f = try!(File::open("log.txt"));
  77. /// let mut reader = BufReader::with_capacity(10, f);
  78. /// # Ok(())
  79. /// # }
  80. /// ```
  81. pub fn with_capacity(cap: usize, inner: R) -> BufReader<R> {
  82. BufReader {
  83. inner: inner,
  84. buf: vec![0; cap].into_boxed_slice(),
  85. pos: 0,
  86. cap: 0,
  87. }
  88. }
  89. /// Gets a reference to the underlying reader.
  90. ///
  91. /// It is inadvisable to directly read from the underlying reader.
  92. ///
  93. /// # Examples
  94. ///
  95. /// ```
  96. /// use std::io::BufReader;
  97. /// use std::fs::File;
  98. ///
  99. /// # fn foo() -> std::io::Result<()> {
  100. /// let mut f1 = try!(File::open("log.txt"));
  101. /// let mut reader = BufReader::new(f1);
  102. ///
  103. /// let f2 = reader.get_ref();
  104. /// # Ok(())
  105. /// # }
  106. /// ```
  107. pub fn get_ref(&self) -> &R { &self.inner }
  108. /// Gets a mutable reference to the underlying reader.
  109. ///
  110. /// It is inadvisable to directly read from the underlying reader.
  111. ///
  112. /// # Examples
  113. ///
  114. /// ```
  115. /// use std::io::BufReader;
  116. /// use std::fs::File;
  117. ///
  118. /// # fn foo() -> std::io::Result<()> {
  119. /// let mut f1 = try!(File::open("log.txt"));
  120. /// let mut reader = BufReader::new(f1);
  121. ///
  122. /// let f2 = reader.get_mut();
  123. /// # Ok(())
  124. /// # }
  125. /// ```
  126. pub fn get_mut(&mut self) -> &mut R { &mut self.inner }
  127. /// Unwraps this `BufReader`, returning the underlying reader.
  128. ///
  129. /// Note that any leftover data in the internal buffer is lost.
  130. ///
  131. /// # Examples
  132. ///
  133. /// ```
  134. /// use std::io::BufReader;
  135. /// use std::fs::File;
  136. ///
  137. /// # fn foo() -> std::io::Result<()> {
  138. /// let mut f1 = try!(File::open("log.txt"));
  139. /// let mut reader = BufReader::new(f1);
  140. ///
  141. /// let f2 = reader.into_inner();
  142. /// # Ok(())
  143. /// # }
  144. /// ```
  145. pub fn into_inner(self) -> R { self.inner }
  146. }
  147. impl<R: Read> Read for BufReader<R> {
  148. fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
  149. // If we don't have any buffered data and we're doing a massive read
  150. // (larger than our internal buffer), bypass our internal buffer
  151. // entirely.
  152. if self.pos == self.cap && buf.len() >= self.buf.len() {
  153. return self.inner.read(buf);
  154. }
  155. let nread = {
  156. let mut rem = self.fill_buf()?;
  157. rem.read(buf)?
  158. };
  159. self.consume(nread);
  160. Ok(nread)
  161. }
  162. }
  163. impl<R: Read> BufRead for BufReader<R> {
  164. fn fill_buf(&mut self) -> io::Result<&[u8]> {
  165. // If we've reached the end of our internal buffer then we need to fetch
  166. // some more data from the underlying reader.
  167. if self.pos == self.cap {
  168. self.cap = self.inner.read(&mut self.buf)?;
  169. self.pos = 0;
  170. }
  171. Ok(&self.buf[self.pos..self.cap])
  172. }
  173. fn consume(&mut self, amt: usize) {
  174. self.pos = cmp::min(self.pos + amt, self.cap);
  175. }
  176. }
  177. impl<R> fmt::Debug for BufReader<R> where R: fmt::Debug {
  178. fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
  179. fmt.debug_struct("BufReader")
  180. .field("reader", &self.inner)
  181. .field("buffer", &format_args!("{}/{}", self.cap - self.pos, self.buf.len()))
  182. .finish()
  183. }
  184. }
  185. impl<R: Seek> Seek for BufReader<R> {
  186. /// Seek to an offset, in bytes, in the underlying reader.
  187. ///
  188. /// The position used for seeking with `SeekFrom::Current(_)` is the
  189. /// position the underlying reader would be at if the `BufReader` had no
  190. /// internal buffer.
  191. ///
  192. /// Seeking always discards the internal buffer, even if the seek position
  193. /// would otherwise fall within it. This guarantees that calling
  194. /// `.into_inner()` immediately after a seek yields the underlying reader
  195. /// at the same position.
  196. ///
  197. /// See `std::io::Seek` for more details.
  198. ///
  199. /// Note: In the edge case where you're seeking with `SeekFrom::Current(n)`
  200. /// where `n` minus the internal buffer length underflows an `i64`, two
  201. /// seeks will be performed instead of one. If the second seek returns
  202. /// `Err`, the underlying reader will be left at the same position it would
  203. /// have if you seeked to `SeekFrom::Current(0)`.
  204. fn seek(&mut self, pos: SeekFrom) -> io::Result<u64> {
  205. let result: u64;
  206. if let SeekFrom::Current(n) = pos {
  207. let remainder = (self.cap - self.pos) as i64;
  208. // it should be safe to assume that remainder fits within an i64 as the alternative
  209. // means we managed to allocate 8 ebibytes and that's absurd.
  210. // But it's not out of the realm of possibility for some weird underlying reader to
  211. // support seeking by i64::min_value() so we need to handle underflow when subtracting
  212. // remainder.
  213. if let Some(offset) = n.checked_sub(remainder) {
  214. result = self.inner.seek(SeekFrom::Current(offset))?;
  215. } else {
  216. // seek backwards by our remainder, and then by the offset
  217. self.inner.seek(SeekFrom::Current(-remainder))?;
  218. self.pos = self.cap; // empty the buffer
  219. result = self.inner.seek(SeekFrom::Current(n))?;
  220. }
  221. } else {
  222. // Seeking with Start/End doesn't care about our buffer length.
  223. result = self.inner.seek(pos)?;
  224. }
  225. self.pos = self.cap; // empty the buffer
  226. Ok(result)
  227. }
  228. }
  229. /// Wraps a writer and buffers its output.
  230. ///
  231. /// It can be excessively inefficient to work directly with something that
  232. /// implements `Write`. For example, every call to `write` on `TcpStream`
  233. /// results in a system call. A `BufWriter` keeps an in-memory buffer of data
  234. /// and writes it to an underlying writer in large, infrequent batches.
  235. ///
  236. /// The buffer will be written out when the writer is dropped.
  237. ///
  238. /// # Examples
  239. ///
  240. /// Let's write the numbers one through ten to a `TcpStream`:
  241. ///
  242. /// ```no_run
  243. /// use std::io::prelude::*;
  244. /// use std::net::TcpStream;
  245. ///
  246. /// let mut stream = TcpStream::connect("127.0.0.1:34254").unwrap();
  247. ///
  248. /// for i in 1..10 {
  249. /// stream.write(&[i]).unwrap();
  250. /// }
  251. /// ```
  252. ///
  253. /// Because we're not buffering, we write each one in turn, incurring the
  254. /// overhead of a system call per byte written. We can fix this with a
  255. /// `BufWriter`:
  256. ///
  257. /// ```no_run
  258. /// use std::io::prelude::*;
  259. /// use std::io::BufWriter;
  260. /// use std::net::TcpStream;
  261. ///
  262. /// let mut stream = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
  263. ///
  264. /// for i in 1..10 {
  265. /// stream.write(&[i]).unwrap();
  266. /// }
  267. /// ```
  268. ///
  269. /// By wrapping the stream with a `BufWriter`, these ten writes are all grouped
  270. /// together by the buffer, and will all be written out in one system call when
  271. /// the `stream` is dropped.
  272. pub struct BufWriter<W: Write> {
  273. inner: Option<W>,
  274. buf: Vec<u8>,
  275. // #30888: If the inner writer panics in a call to write, we don't want to
  276. // write the buffered data a second time in BufWriter's destructor. This
  277. // flag tells the Drop impl if it should skip the flush.
  278. panicked: bool,
  279. }
  280. /// An error returned by `into_inner` which combines an error that
  281. /// happened while writing out the buffer, and the buffered writer object
  282. /// which may be used to recover from the condition.
  283. ///
  284. /// # Examples
  285. ///
  286. /// ```no_run
  287. /// use std::io::BufWriter;
  288. /// use std::net::TcpStream;
  289. ///
  290. /// let mut stream = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
  291. ///
  292. /// // do stuff with the stream
  293. ///
  294. /// // we want to get our `TcpStream` back, so let's try:
  295. ///
  296. /// let stream = match stream.into_inner() {
  297. /// Ok(s) => s,
  298. /// Err(e) => {
  299. /// // Here, e is an IntoInnerError
  300. /// panic!("An error occurred");
  301. /// }
  302. /// };
  303. /// ```
  304. #[derive(Debug)]
  305. pub struct IntoInnerError<W>(W, Error);
  306. impl<W: Write> BufWriter<W> {
  307. /// Creates a new `BufWriter` with a default buffer capacity.
  308. ///
  309. /// # Examples
  310. ///
  311. /// ```no_run
  312. /// use std::io::BufWriter;
  313. /// use std::net::TcpStream;
  314. ///
  315. /// let mut buffer = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
  316. /// ```
  317. pub fn new(inner: W) -> BufWriter<W> {
  318. BufWriter::with_capacity(DEFAULT_BUF_SIZE, inner)
  319. }
  320. /// Creates a new `BufWriter` with the specified buffer capacity.
  321. ///
  322. /// # Examples
  323. ///
  324. /// Creating a buffer with a buffer of a hundred bytes.
  325. ///
  326. /// ```no_run
  327. /// use std::io::BufWriter;
  328. /// use std::net::TcpStream;
  329. ///
  330. /// let stream = TcpStream::connect("127.0.0.1:34254").unwrap();
  331. /// let mut buffer = BufWriter::with_capacity(100, stream);
  332. /// ```
  333. pub fn with_capacity(cap: usize, inner: W) -> BufWriter<W> {
  334. BufWriter {
  335. inner: Some(inner),
  336. buf: Vec::with_capacity(cap),
  337. panicked: false,
  338. }
  339. }
  340. fn flush_buf(&mut self) -> io::Result<()> {
  341. let mut written = 0;
  342. let len = self.buf.len();
  343. let mut ret = Ok(());
  344. while written < len {
  345. self.panicked = true;
  346. let r = self.inner.as_mut().unwrap().write(&self.buf[written..]);
  347. self.panicked = false;
  348. match r {
  349. Ok(0) => {
  350. ret = Err(Error::new(ErrorKind::WriteZero,
  351. "failed to write the buffered data"));
  352. break;
  353. }
  354. Ok(n) => written += n,
  355. Err(ref e) if e.kind() == io::ErrorKind::Interrupted => {}
  356. Err(e) => { ret = Err(e); break }
  357. }
  358. }
  359. if written > 0 {
  360. self.buf.drain(..written);
  361. }
  362. ret
  363. }
  364. /// Gets a reference to the underlying writer.
  365. ///
  366. /// # Examples
  367. ///
  368. /// ```no_run
  369. /// use std::io::BufWriter;
  370. /// use std::net::TcpStream;
  371. ///
  372. /// let mut buffer = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
  373. ///
  374. /// // we can use reference just like buffer
  375. /// let reference = buffer.get_ref();
  376. /// ```
  377. pub fn get_ref(&self) -> &W { self.inner.as_ref().unwrap() }
  378. /// Gets a mutable reference to the underlying writer.
  379. ///
  380. /// It is inadvisable to directly write to the underlying writer.
  381. ///
  382. /// # Examples
  383. ///
  384. /// ```no_run
  385. /// use std::io::BufWriter;
  386. /// use std::net::TcpStream;
  387. ///
  388. /// let mut buffer = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
  389. ///
  390. /// // we can use reference just like buffer
  391. /// let reference = buffer.get_mut();
  392. /// ```
  393. pub fn get_mut(&mut self) -> &mut W { self.inner.as_mut().unwrap() }
  394. /// Unwraps this `BufWriter`, returning the underlying writer.
  395. ///
  396. /// The buffer is written out before returning the writer.
  397. ///
  398. /// # Examples
  399. ///
  400. /// ```no_run
  401. /// use std::io::BufWriter;
  402. /// use std::net::TcpStream;
  403. ///
  404. /// let mut buffer = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
  405. ///
  406. /// // unwrap the TcpStream and flush the buffer
  407. /// let stream = buffer.into_inner().unwrap();
  408. /// ```
  409. pub fn into_inner(mut self) -> Result<W, IntoInnerError<BufWriter<W>>> {
  410. match self.flush_buf() {
  411. Err(e) => Err(IntoInnerError(self, e)),
  412. Ok(()) => Ok(self.inner.take().unwrap())
  413. }
  414. }
  415. }
  416. impl<W: Write> Write for BufWriter<W> {
  417. fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
  418. if self.buf.len() + buf.len() > self.buf.capacity() {
  419. self.flush_buf()?;
  420. }
  421. if buf.len() >= self.buf.capacity() {
  422. self.panicked = true;
  423. let r = self.inner.as_mut().unwrap().write(buf);
  424. self.panicked = false;
  425. r
  426. } else {
  427. Write::write(&mut self.buf, buf)
  428. }
  429. }
  430. fn flush(&mut self) -> io::Result<()> {
  431. self.flush_buf().and_then(|()| self.get_mut().flush())
  432. }
  433. }
  434. impl<W: Write> fmt::Debug for BufWriter<W> where W: fmt::Debug {
  435. fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
  436. fmt.debug_struct("BufWriter")
  437. .field("writer", &self.inner.as_ref().unwrap())
  438. .field("buffer", &format_args!("{}/{}", self.buf.len(), self.buf.capacity()))
  439. .finish()
  440. }
  441. }
  442. impl<W: Write + Seek> Seek for BufWriter<W> {
  443. /// Seek to the offset, in bytes, in the underlying writer.
  444. ///
  445. /// Seeking always writes out the internal buffer before seeking.
  446. fn seek(&mut self, pos: SeekFrom) -> io::Result<u64> {
  447. self.flush_buf().and_then(|_| self.get_mut().seek(pos))
  448. }
  449. }
  450. impl<W: Write> Drop for BufWriter<W> {
  451. fn drop(&mut self) {
  452. if self.inner.is_some() && !self.panicked {
  453. // dtors should not panic, so we ignore a failed flush
  454. let _r = self.flush_buf();
  455. }
  456. }
  457. }
  458. impl<W> IntoInnerError<W> {
  459. /// Returns the error which caused the call to `into_inner()` to fail.
  460. ///
  461. /// This error was returned when attempting to write the internal buffer.
  462. ///
  463. /// # Examples
  464. ///
  465. /// ```no_run
  466. /// use std::io::BufWriter;
  467. /// use std::net::TcpStream;
  468. ///
  469. /// let mut stream = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
  470. ///
  471. /// // do stuff with the stream
  472. ///
  473. /// // we want to get our `TcpStream` back, so let's try:
  474. ///
  475. /// let stream = match stream.into_inner() {
  476. /// Ok(s) => s,
  477. /// Err(e) => {
  478. /// // Here, e is an IntoInnerError, let's log the inner error.
  479. /// //
  480. /// // We'll just 'log' to stdout for this example.
  481. /// println!("{}", e.error());
  482. ///
  483. /// panic!("An unexpected error occurred.");
  484. /// }
  485. /// };
  486. /// ```
  487. pub fn error(&self) -> &Error { &self.1 }
  488. /// Returns the buffered writer instance which generated the error.
  489. ///
  490. /// The returned object can be used for error recovery, such as
  491. /// re-inspecting the buffer.
  492. ///
  493. /// # Examples
  494. ///
  495. /// ```no_run
  496. /// use std::io::BufWriter;
  497. /// use std::net::TcpStream;
  498. ///
  499. /// let mut stream = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
  500. ///
  501. /// // do stuff with the stream
  502. ///
  503. /// // we want to get our `TcpStream` back, so let's try:
  504. ///
  505. /// let stream = match stream.into_inner() {
  506. /// Ok(s) => s,
  507. /// Err(e) => {
  508. /// // Here, e is an IntoInnerError, let's re-examine the buffer:
  509. /// let buffer = e.into_inner();
  510. ///
  511. /// // do stuff to try to recover
  512. ///
  513. /// // afterwards, let's just return the stream
  514. /// buffer.into_inner().unwrap()
  515. /// }
  516. /// };
  517. /// ```
  518. pub fn into_inner(self) -> W { self.0 }
  519. }
  520. impl<W> From<IntoInnerError<W>> for Error {
  521. fn from(iie: IntoInnerError<W>) -> Error { iie.1 }
  522. }
  523. impl<W> fmt::Display for IntoInnerError<W> {
  524. fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
  525. self.error().fmt(f)
  526. }
  527. }
  528. /// Wraps a writer and buffers output to it, flushing whenever a newline
  529. /// (`0x0a`, `'\n'`) is detected.
  530. ///
  531. /// The [`BufWriter`][bufwriter] struct wraps a writer and buffers its output.
  532. /// But it only does this batched write when it goes out of scope, or when the
  533. /// internal buffer is full. Sometimes, you'd prefer to write each line as it's
  534. /// completed, rather than the entire buffer at once. Enter `LineWriter`. It
  535. /// does exactly that.
  536. ///
  537. /// [bufwriter]: struct.BufWriter.html
  538. ///
  539. /// If there's still a partial line in the buffer when the `LineWriter` is
  540. /// dropped, it will flush those contents.
  541. ///
  542. /// # Examples
  543. ///
  544. /// We can use `LineWriter` to write one line at a time, significantly
  545. /// reducing the number of actual writes to the file.
  546. ///
  547. /// ```
  548. /// use std::fs::File;
  549. /// use std::io::prelude::*;
  550. /// use std::io::LineWriter;
  551. ///
  552. /// # fn foo() -> std::io::Result<()> {
  553. /// let road_not_taken = b"I shall be telling this with a sigh
  554. /// Somewhere ages and ages hence:
  555. /// Two roads diverged in a wood, and I -
  556. /// I took the one less traveled by,
  557. /// And that has made all the difference.";
  558. ///
  559. /// let file = try!(File::create("poem.txt"));
  560. /// let mut file = LineWriter::new(file);
  561. ///
  562. /// for &byte in road_not_taken.iter() {
  563. /// file.write(&[byte]).unwrap();
  564. /// }
  565. ///
  566. /// // let's check we did the right thing.
  567. /// let mut file = try!(File::open("poem.txt"));
  568. /// let mut contents = String::new();
  569. ///
  570. /// try!(file.read_to_string(&mut contents));
  571. ///
  572. /// assert_eq!(contents.as_bytes(), &road_not_taken[..]);
  573. /// # Ok(())
  574. /// # }
  575. /// ```
  576. pub struct LineWriter<W: Write> {
  577. inner: BufWriter<W>,
  578. }
  579. impl<W: Write> LineWriter<W> {
  580. /// Creates a new `LineWriter`.
  581. ///
  582. /// # Examples
  583. ///
  584. /// ```
  585. /// use std::fs::File;
  586. /// use std::io::LineWriter;
  587. ///
  588. /// # fn foo() -> std::io::Result<()> {
  589. /// let file = try!(File::create("poem.txt"));
  590. /// let file = LineWriter::new(file);
  591. /// # Ok(())
  592. /// # }
  593. /// ```
  594. pub fn new(inner: W) -> LineWriter<W> {
  595. // Lines typically aren't that long, don't use a giant buffer
  596. LineWriter::with_capacity(1024, inner)
  597. }
  598. /// Creates a new `LineWriter` with a specified capacity for the internal
  599. /// buffer.
  600. ///
  601. /// # Examples
  602. ///
  603. /// ```
  604. /// use std::fs::File;
  605. /// use std::io::LineWriter;
  606. ///
  607. /// # fn foo() -> std::io::Result<()> {
  608. /// let file = try!(File::create("poem.txt"));
  609. /// let file = LineWriter::with_capacity(100, file);
  610. /// # Ok(())
  611. /// # }
  612. /// ```
  613. pub fn with_capacity(cap: usize, inner: W) -> LineWriter<W> {
  614. LineWriter { inner: BufWriter::with_capacity(cap, inner) }
  615. }
  616. /// Gets a reference to the underlying writer.
  617. ///
  618. /// # Examples
  619. ///
  620. /// ```
  621. /// use std::fs::File;
  622. /// use std::io::LineWriter;
  623. ///
  624. /// # fn foo() -> std::io::Result<()> {
  625. /// let file = try!(File::create("poem.txt"));
  626. /// let file = LineWriter::new(file);
  627. ///
  628. /// let reference = file.get_ref();
  629. /// # Ok(())
  630. /// # }
  631. /// ```
  632. pub fn get_ref(&self) -> &W { self.inner.get_ref() }
  633. /// Gets a mutable reference to the underlying writer.
  634. ///
  635. /// Caution must be taken when calling methods on the mutable reference
  636. /// returned as extra writes could corrupt the output stream.
  637. ///
  638. /// # Examples
  639. ///
  640. /// ```
  641. /// use std::fs::File;
  642. /// use std::io::LineWriter;
  643. ///
  644. /// # fn foo() -> std::io::Result<()> {
  645. /// let file = try!(File::create("poem.txt"));
  646. /// let mut file = LineWriter::new(file);
  647. ///
  648. /// // we can use reference just like file
  649. /// let reference = file.get_mut();
  650. /// # Ok(())
  651. /// # }
  652. /// ```
  653. pub fn get_mut(&mut self) -> &mut W { self.inner.get_mut() }
  654. /// Unwraps this `LineWriter`, returning the underlying writer.
  655. ///
  656. /// The internal buffer is written out before returning the writer.
  657. ///
  658. /// # Examples
  659. ///
  660. /// ```
  661. /// use std::fs::File;
  662. /// use std::io::LineWriter;
  663. ///
  664. /// # fn foo() -> std::io::Result<()> {
  665. /// let file = try!(File::create("poem.txt"));
  666. ///
  667. /// let writer: LineWriter<File> = LineWriter::new(file);
  668. ///
  669. /// let file: File = try!(writer.into_inner());
  670. /// # Ok(())
  671. /// # }
  672. /// ```
  673. pub fn into_inner(self) -> Result<W, IntoInnerError<LineWriter<W>>> {
  674. self.inner.into_inner().map_err(|IntoInnerError(buf, e)| {
  675. IntoInnerError(LineWriter { inner: buf }, e)
  676. })
  677. }
  678. }
  679. impl<W: Write> Write for LineWriter<W> {
  680. fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
  681. match memchr::memrchr(b'\n', buf) {
  682. Some(i) => {
  683. let n = self.inner.write(&buf[..i + 1])?;
  684. if n != i + 1 || self.inner.flush().is_err() {
  685. // Do not return errors on partial writes.
  686. return Ok(n);
  687. }
  688. self.inner.write(&buf[i + 1..]).map(|i| n + i)
  689. }
  690. None => self.inner.write(buf),
  691. }
  692. }
  693. fn flush(&mut self) -> io::Result<()> { self.inner.flush() }
  694. }
  695. impl<W: Write> fmt::Debug for LineWriter<W> where W: fmt::Debug {
  696. fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result {
  697. fmt.debug_struct("LineWriter")
  698. .field("writer", &self.inner.inner)
  699. .field("buffer",
  700. &format_args!("{}/{}", self.inner.buf.len(), self.inner.buf.capacity()))
  701. .finish()
  702. }
  703. }
  704. #[cfg(test)]
  705. mod tests {
  706. use io::prelude::*;
  707. use io::{self, BufReader, BufWriter, LineWriter, SeekFrom};
  708. use sync::atomic::{AtomicUsize, Ordering};
  709. use thread;
  710. use test;
  711. /// A dummy reader intended at testing short-reads propagation.
  712. pub struct ShortReader {
  713. lengths: Vec<usize>,
  714. }
  715. impl Read for ShortReader {
  716. fn read(&mut self, _: &mut [u8]) -> io::Result<usize> {
  717. if self.lengths.is_empty() {
  718. Ok(0)
  719. } else {
  720. Ok(self.lengths.remove(0))
  721. }
  722. }
  723. }
  724. #[test]
  725. fn test_buffered_reader() {
  726. let inner: &[u8] = &[5, 6, 7, 0, 1, 2, 3, 4];
  727. let mut reader = BufReader::with_capacity(2, inner);
  728. let mut buf = [0, 0, 0];
  729. let nread = reader.read(&mut buf);
  730. assert_eq!(nread.unwrap(), 3);
  731. let b: &[_] = &[5, 6, 7];
  732. assert_eq!(buf, b);
  733. let mut buf = [0, 0];
  734. let nread = reader.read(&mut buf);
  735. assert_eq!(nread.unwrap(), 2);
  736. let b: &[_] = &[0, 1];
  737. assert_eq!(buf, b);
  738. let mut buf = [0];
  739. let nread = reader.read(&mut buf);
  740. assert_eq!(nread.unwrap(), 1);
  741. let b: &[_] = &[2];
  742. assert_eq!(buf, b);
  743. let mut buf = [0, 0, 0];
  744. let nread = reader.read(&mut buf);
  745. assert_eq!(nread.unwrap(), 1);
  746. let b: &[_] = &[3, 0, 0];
  747. assert_eq!(buf, b);
  748. let nread = reader.read(&mut buf);
  749. assert_eq!(nread.unwrap(), 1);
  750. let b: &[_] = &[4, 0, 0];
  751. assert_eq!(buf, b);
  752. assert_eq!(reader.read(&mut buf).unwrap(), 0);
  753. }
  754. #[test]
  755. fn test_buffered_reader_seek() {
  756. let inner: &[u8] = &[5, 6, 7, 0, 1, 2, 3, 4];
  757. let mut reader = BufReader::with_capacity(2, io::Cursor::new(inner));
  758. assert_eq!(reader.seek(SeekFrom::Start(3)).ok(), Some(3));
  759. assert_eq!(reader.fill_buf().ok(), Some(&[0, 1][..]));
  760. assert_eq!(reader.seek(SeekFrom::Current(0)).ok(), Some(3));
  761. assert_eq!(reader.fill_buf().ok(), Some(&[0, 1][..]));
  762. assert_eq!(reader.seek(SeekFrom::Current(1)).ok(), Some(4));
  763. assert_eq!(reader.fill_buf().ok(), Some(&[1, 2][..]));
  764. reader.consume(1);
  765. assert_eq!(reader.seek(SeekFrom::Current(-2)).ok(), Some(3));
  766. }
  767. #[test]
  768. fn test_buffered_reader_seek_underflow() {
  769. // gimmick reader that yields its position modulo 256 for each byte
  770. struct PositionReader {
  771. pos: u64
  772. }
  773. impl Read for PositionReader {
  774. fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> {
  775. let len = buf.len();
  776. for x in buf {
  777. *x = self.pos as u8;
  778. self.pos = self.pos.wrapping_add(1);
  779. }
  780. Ok(len)
  781. }
  782. }
  783. impl Seek for PositionReader {
  784. fn seek(&mut self, pos: SeekFrom) -> io::Result<u64> {
  785. match pos {
  786. SeekFrom::Start(n) => {
  787. self.pos = n;
  788. }
  789. SeekFrom::Current(n) => {
  790. self.pos = self.pos.wrapping_add(n as u64);
  791. }
  792. SeekFrom::End(n) => {
  793. self.pos = u64::max_value().wrapping_add(n as u64);
  794. }
  795. }
  796. Ok(self.pos)
  797. }
  798. }
  799. let mut reader = BufReader::with_capacity(5, PositionReader { pos: 0 });
  800. assert_eq!(reader.fill_buf().ok(), Some(&[0, 1, 2, 3, 4][..]));
  801. assert_eq!(reader.seek(SeekFrom::End(-5)).ok(), Some(u64::max_value()-5));
  802. assert_eq!(reader.fill_buf().ok().map(|s| s.len()), Some(5));
  803. // the following seek will require two underlying seeks
  804. let expected = 9223372036854775802;
  805. assert_eq!(reader.seek(SeekFrom::Current(i64::min_value())).ok(), Some(expected));
  806. assert_eq!(reader.fill_buf().ok().map(|s| s.len()), Some(5));
  807. // seeking to 0 should empty the buffer.
  808. assert_eq!(reader.seek(SeekFrom::Current(0)).ok(), Some(expected));
  809. assert_eq!(reader.get_ref().pos, expected);
  810. }
  811. #[test]
  812. fn test_buffered_writer() {
  813. let inner = Vec::new();
  814. let mut writer = BufWriter::with_capacity(2, inner);
  815. writer.write(&[0, 1]).unwrap();
  816. assert_eq!(*writer.get_ref(), [0, 1]);
  817. writer.write(&[2]).unwrap();
  818. assert_eq!(*writer.get_ref(), [0, 1]);
  819. writer.write(&[3]).unwrap();
  820. assert_eq!(*writer.get_ref(), [0, 1]);
  821. writer.flush().unwrap();
  822. assert_eq!(*writer.get_ref(), [0, 1, 2, 3]);
  823. writer.write(&[4]).unwrap();
  824. writer.write(&[5]).unwrap();
  825. assert_eq!(*writer.get_ref(), [0, 1, 2, 3]);
  826. writer.write(&[6]).unwrap();
  827. assert_eq!(*writer.get_ref(), [0, 1, 2, 3, 4, 5]);
  828. writer.write(&[7, 8]).unwrap();
  829. assert_eq!(*writer.get_ref(), [0, 1, 2, 3, 4, 5, 6, 7, 8]);
  830. writer.write(&[9, 10, 11]).unwrap();
  831. assert_eq!(*writer.get_ref(), [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]);
  832. writer.flush().unwrap();
  833. assert_eq!(*writer.get_ref(), [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]);
  834. }
  835. #[test]
  836. fn test_buffered_writer_inner_flushes() {
  837. let mut w = BufWriter::with_capacity(3, Vec::new());
  838. w.write(&[0, 1]).unwrap();
  839. assert_eq!(*w.get_ref(), []);
  840. let w = w.into_inner().unwrap();
  841. assert_eq!(w, [0, 1]);
  842. }
  843. #[test]
  844. fn test_buffered_writer_seek() {
  845. let mut w = BufWriter::with_capacity(3, io::Cursor::new(Vec::new()));
  846. w.write_all(&[0, 1, 2, 3, 4, 5]).unwrap();
  847. w.write_all(&[6, 7]).unwrap();
  848. assert_eq!(w.seek(SeekFrom::Current(0)).ok(), Some(8));
  849. assert_eq!(&w.get_ref().get_ref()[..], &[0, 1, 2, 3, 4, 5, 6, 7][..]);
  850. assert_eq!(w.seek(SeekFrom::Start(2)).ok(), Some(2));
  851. w.write_all(&[8, 9]).unwrap();
  852. assert_eq!(&w.into_inner().unwrap().into_inner()[..], &[0, 1, 8, 9, 4, 5, 6, 7]);
  853. }
  854. #[test]
  855. fn test_read_until() {
  856. let inner: &[u8] = &[0, 1, 2, 1, 0];
  857. let mut reader = BufReader::with_capacity(2, inner);
  858. let mut v = Vec::new();
  859. reader.read_until(0, &mut v).unwrap();
  860. assert_eq!(v, [0]);
  861. v.truncate(0);
  862. reader.read_until(2, &mut v).unwrap();
  863. assert_eq!(v, [1, 2]);
  864. v.truncate(0);
  865. reader.read_until(1, &mut v).unwrap();
  866. assert_eq!(v, [1]);
  867. v.truncate(0);
  868. reader.read_until(8, &mut v).unwrap();
  869. assert_eq!(v, [0]);
  870. v.truncate(0);
  871. reader.read_until(9, &mut v).unwrap();
  872. assert_eq!(v, []);
  873. }
  874. #[test]
  875. fn test_line_buffer_fail_flush() {
  876. // Issue #32085
  877. struct FailFlushWriter<'a>(&'a mut Vec<u8>);
  878. impl<'a> Write for FailFlushWriter<'a> {
  879. fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
  880. self.0.extend_from_slice(buf);
  881. Ok(buf.len())
  882. }
  883. fn flush(&mut self) -> io::Result<()> {
  884. Err(io::Error::new(io::ErrorKind::Other, "flush failed"))
  885. }
  886. }
  887. let mut buf = Vec::new();
  888. {
  889. let mut writer = LineWriter::new(FailFlushWriter(&mut buf));
  890. let to_write = b"abc\ndef";
  891. if let Ok(written) = writer.write(to_write) {
  892. assert!(written < to_write.len(), "didn't flush on new line");
  893. // PASS
  894. return;
  895. }
  896. }
  897. assert!(buf.is_empty(), "write returned an error but wrote data");
  898. }
  899. #[test]
  900. fn test_line_buffer() {
  901. let mut writer = LineWriter::new(Vec::new());
  902. writer.write(&[0]).unwrap();
  903. assert_eq!(*writer.get_ref(), []);
  904. writer.write(&[1]).unwrap();
  905. assert_eq!(*writer.get_ref(), []);
  906. writer.flush().unwrap();
  907. assert_eq!(*writer.get_ref(), [0, 1]);
  908. writer.write(&[0, b'\n', 1, b'\n', 2]).unwrap();
  909. assert_eq!(*writer.get_ref(), [0, 1, 0, b'\n', 1, b'\n']);
  910. writer.flush().unwrap();
  911. assert_eq!(*writer.get_ref(), [0, 1, 0, b'\n', 1, b'\n', 2]);
  912. writer.write(&[3, b'\n']).unwrap();
  913. assert_eq!(*writer.get_ref(), [0, 1, 0, b'\n', 1, b'\n', 2, 3, b'\n']);
  914. }
  915. #[test]
  916. fn test_read_line() {
  917. let in_buf: &[u8] = b"a\nb\nc";
  918. let mut reader = BufReader::with_capacity(2, in_buf);
  919. let mut s = String::new();
  920. reader.read_line(&mut s).unwrap();
  921. assert_eq!(s, "a\n");
  922. s.truncate(0);
  923. reader.read_line(&mut s).unwrap();
  924. assert_eq!(s, "b\n");
  925. s.truncate(0);
  926. reader.read_line(&mut s).unwrap();
  927. assert_eq!(s, "c");
  928. s.truncate(0);
  929. reader.read_line(&mut s).unwrap();
  930. assert_eq!(s, "");
  931. }
  932. #[test]
  933. fn test_lines() {
  934. let in_buf: &[u8] = b"a\nb\nc";
  935. let reader = BufReader::with_capacity(2, in_buf);
  936. let mut it = reader.lines();
  937. assert_eq!(it.next().unwrap().unwrap(), "a".to_string());
  938. assert_eq!(it.next().unwrap().unwrap(), "b".to_string());
  939. assert_eq!(it.next().unwrap().unwrap(), "c".to_string());
  940. assert!(it.next().is_none());
  941. }
  942. #[test]
  943. fn test_short_reads() {
  944. let inner = ShortReader{lengths: vec![0, 1, 2, 0, 1, 0]};
  945. let mut reader = BufReader::new(inner);
  946. let mut buf = [0, 0];
  947. assert_eq!(reader.read(&mut buf).unwrap(), 0);
  948. assert_eq!(reader.read(&mut buf).unwrap(), 1);
  949. assert_eq!(reader.read(&mut buf).unwrap(), 2);
  950. assert_eq!(reader.read(&mut buf).unwrap(), 0);
  951. assert_eq!(reader.read(&mut buf).unwrap(), 1);
  952. assert_eq!(reader.read(&mut buf).unwrap(), 0);
  953. assert_eq!(reader.read(&mut buf).unwrap(), 0);
  954. }
  955. #[test]
  956. fn read_char_buffered() {
  957. let buf = [195, 159];
  958. let reader = BufReader::with_capacity(1, &buf[..]);
  959. assert_eq!(reader.chars().next().unwrap().unwrap(), 'ß');
  960. }
  961. #[test]
  962. fn test_chars() {
  963. let buf = [195, 159, b'a'];
  964. let reader = BufReader::with_capacity(1, &buf[..]);
  965. let mut it = reader.chars();
  966. assert_eq!(it.next().unwrap().unwrap(), 'ß');
  967. assert_eq!(it.next().unwrap().unwrap(), 'a');
  968. assert!(it.next().is_none());
  969. }
  970. #[test]
  971. #[should_panic]
  972. fn dont_panic_in_drop_on_panicked_flush() {
  973. struct FailFlushWriter;
  974. impl Write for FailFlushWriter {
  975. fn write(&mut self, buf: &[u8]) -> io::Result<usize> { Ok(buf.len()) }
  976. fn flush(&mut self) -> io::Result<()> {
  977. Err(io::Error::last_os_error())
  978. }
  979. }
  980. let writer = FailFlushWriter;
  981. let _writer = BufWriter::new(writer);
  982. // If writer panics *again* due to the flush error then the process will
  983. // abort.
  984. panic!();
  985. }
  986. #[test]
  987. #[cfg_attr(target_os = "emscripten", ignore)]
  988. fn panic_in_write_doesnt_flush_in_drop() {
  989. static WRITES: AtomicUsize = AtomicUsize::new(0);
  990. struct PanicWriter;
  991. impl Write for PanicWriter {
  992. fn write(&mut self, _: &[u8]) -> io::Result<usize> {
  993. WRITES.fetch_add(1, Ordering::SeqCst);
  994. panic!();
  995. }
  996. fn flush(&mut self) -> io::Result<()> { Ok(()) }
  997. }
  998. thread::spawn(|| {
  999. let mut writer = BufWriter::new(PanicWriter);
  1000. let _ = writer.write(b"hello world");
  1001. let _ = writer.flush();
  1002. }).join().unwrap_err();
  1003. assert_eq!(WRITES.load(Ordering::SeqCst), 1);
  1004. }
  1005. #[bench]
  1006. fn bench_buffered_reader(b: &mut test::Bencher) {
  1007. b.iter(|| {
  1008. BufReader::new(io::empty())
  1009. });
  1010. }
  1011. #[bench]
  1012. fn bench_buffered_writer(b: &mut test::Bencher) {
  1013. b.iter(|| {
  1014. BufWriter::new(io::sink())
  1015. });
  1016. }
  1017. }