From bb53f690169867af1db04aca34ffbcfd86ba3f71 Mon Sep 17 00:00:00 2001 From: Greg Fitzgerald Date: Fri, 25 May 2018 23:00:47 -0600 Subject: [PATCH] Fix typos --- src/packet.rs | 4 ++-- src/streamer.rs | 7 ++++--- 2 files changed, 6 insertions(+), 5 deletions(-) diff --git a/src/packet.rs b/src/packet.rs index 064f65d4e0..610ac38aff 100644 --- a/src/packet.rs +++ b/src/packet.rs @@ -173,7 +173,7 @@ impl Packets { let mut i = 0; //DOCUMENTED SIDE-EFFECT //Performance out of the IO without poll - // * block on the socket until its readable + // * block on the socket until it's readable // * set the socket to non blocking // * read until it fails // * set it back to blocking before returning @@ -304,7 +304,7 @@ impl Blob { let mut v = VecDeque::new(); //DOCUMENTED SIDE-EFFECT //Performance out of the IO without poll - // * block on the socket until its readable + // * block on the socket until it's readable // * set the socket to non blocking // * read until it fails // * set it back to blocking before returning diff --git a/src/streamer.rs b/src/streamer.rs index 88fd820b11..6fdd0ca84c 100644 --- a/src/streamer.rs +++ b/src/streamer.rs @@ -1,4 +1,5 @@ -//! The `streamer` module defines a set of services for effecently pulling data from udp sockets. +//! The `streamer` module defines a set of services for efficiently pulling data from UDP sockets. +//! use crdt::Crdt; #[cfg(feature = "erasure")] use erasure; @@ -220,11 +221,11 @@ fn recv_window( ); if p.get_id().expect("get_id in fn recv_window") == leader_id { //TODO - //need to copy the retransmited blob + //need to copy the retransmitted blob //otherwise we get into races with which thread //should do the recycling // - //a better absraction would be to recycle when the blob + //a better abstraction would be to recycle when the blob //is dropped via a weakref to the recycler let nv = recycler.allocate(); {