diff options
author | Adam Ierymenko <adam.ierymenko@gmail.com> | 2014-11-23 14:00:27 -0800 |
---|---|---|
committer | Adam Ierymenko <adam.ierymenko@gmail.com> | 2014-11-23 14:00:27 -0800 |
commit | acac88cf773ad51d0a47cd401ce6044f538fcde7 (patch) | |
tree | 5beeda28332ccf10a1ddbec7f791931e56ca7ff4 /node | |
parent | 0bcac1fd79d8822d651bf196fd31e1b9ec499623 (diff) | |
download | infinitytier-acac88cf773ad51d0a47cd401ce6044f538fcde7.tar.gz infinitytier-acac88cf773ad51d0a47cd401ce6044f538fcde7.zip |
A few more tweaks to MC algo...
Diffstat (limited to 'node')
-rw-r--r-- | node/Multicaster.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/node/Multicaster.cpp b/node/Multicaster.cpp index 2785fcc4..5583b65b 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()); |