gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix typos

Browse Source
This commit is contained in:
Greg Fitzgerald
2018-05-25 23:00:47 -06:00
parent 75659ca042
commit bb53f69016
2 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/packet.rs
View File

@ -173,7 +173,7 @@ impl Packets {
let mut i = 0; let mut i = 0;
//DOCUMENTED SIDE-EFFECT //DOCUMENTED SIDE-EFFECT
//Performance out of the IO without poll //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 // * set the socket to non blocking
// * read until it fails // * read until it fails
// * set it back to blocking before returning // * set it back to blocking before returning
@ -304,7 +304,7 @@ impl Blob {
let mut v = VecDeque::new(); let mut v = VecDeque::new();
//DOCUMENTED SIDE-EFFECT //DOCUMENTED SIDE-EFFECT
//Performance out of the IO without poll //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 // * set the socket to non blocking
// * read until it fails // * read until it fails
// * set it back to blocking before returning // * set it back to blocking before returning

7
src/streamer.rs
View File

@ -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; use crdt::Crdt;
#[cfg(feature = "erasure")] #[cfg(feature = "erasure")]
use erasure; use erasure;
@ -220,11 +221,11 @@ fn recv_window(
); );
if p.get_id().expect("get_id in fn recv_window") == leader_id { if p.get_id().expect("get_id in fn recv_window") == leader_id {
//TODO //TODO
//need to copy the retransmited blob //need to copy the retransmitted blob
//otherwise we get into races with which thread //otherwise we get into races with which thread
//should do the recycling //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 //is dropped via a weakref to the recycler
let nv = recycler.allocate(); let nv = recycler.allocate();
{ {