From acac88cf773ad51d0a47cd401ce6044f538fcde7 Mon Sep 17 00:00:00 2001 From: Adam Ierymenko Date: Sun, 23 Nov 2014 14:00:27 -0800 Subject: [PATCH] A few more tweaks to MC algo... --- node/Multicaster.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/node/Multicaster.cpp b/node/Multicaster.cpp index 2785fcc49..5583b65b0 100644 --- a/node/Multicaster.cpp +++ b/node/Multicaster.cpp @@ -192,7 +192,7 @@ void Multicaster::send( nwid, com, limit, - 2, // we'll still gather a little from peers to keep multicast list fresh + 1, // we'll still gather a little from peers to keep multicast list fresh src, mg, etherType, @@ -214,7 +214,7 @@ void Multicaster::send( } unsigned long idx = 0; - while (count < limit) { + while (count < limit) { // limit <= gs.members.size() so idx will never overflow here const MulticastGroupMember &m = gs.members[indexes[idx++]]; { // TODO / LEGACY: don't send new multicast frame to old peers (if we know their version) @@ -246,7 +246,7 @@ void Multicaster::send( outp.armor(sn->key(),true); sn->send(RR,outp.data(),outp.size(),now); } - gatherLimit = 0; // don't need to gather from peers this time since we consulted the core + gatherLimit = 1; // we still gather a bit from peers as well } gs.txQueue.push_back(OutboundMulticast());