From ec3569aa3912987360ded99717160ae74be80030 Mon Sep 17 00:00:00 2001 From: Stephen Akridge Date: Mon, 4 Jun 2018 14:29:14 -0700 Subject: [PATCH] Move receive_index to correct place --- src/crdt.rs | 2 -- src/streamer.rs | 2 ++ 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/crdt.rs b/src/crdt.rs index 34bba79b85..e8fcb30cfd 100644 --- a/src/crdt.rs +++ b/src/crdt.rs @@ -249,8 +249,6 @@ impl Crdt { .expect("set_index in pub fn broadcast"); } - *receive_index += blobs.len() as u64; - Ok(()) } diff --git a/src/streamer.rs b/src/streamer.rs index 32f2b9eb22..fb6df26895 100644 --- a/src/streamer.rs +++ b/src/streamer.rs @@ -457,6 +457,8 @@ fn broadcast( } } + *receive_index += blobs_len as u64; + // Send blobs out from the window Crdt::broadcast(crdt, &window, &sock, transmit_index)?; Ok(())