dark/zerotiertspu
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Apply multicast rate limits to my own multicasts. Will run locally and on a variety of system types to test the result of this.

Browse source
This commit is contained in:
Adam Ierymenko 2013-09-07 15:49:38 -04:00
parent cdb96726df
commit a40b8c07f4
4 changed files with 18 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

9
node/Switch.cpp
View file

@ -100,13 +100,18 @@ void Switch::onLocalEthernet(const SharedPtr<Network> &network,const MAC &from,c
MulticastGroup mg(to,0);
if (to.isBroadcast()) {
// Handle broadcast special cases
// Cram IPv4 IP into ADI field to make IPv4 ARP broadcast channel specific and scalable
if ((etherType == ZT_ETHERTYPE_ARP)&&(data.size() == 28)&&(data[2] == 0x08)&&(data[3] == 0x00)&&(data[4] == 6)&&(data[5] == 4)&&(data[7] == 0x01))
mg = MulticastGroup::deriveMulticastGroupForAddressResolution(InetAddress(data.field(24,4),4,0));
}
// Check our own multicasts against the global rate for this network
// just to be polite.
if (!network->updateAndCheckMulticastBalance(_r->identity.address(),mg,data.size())) {
LOG("didn't send local multicast %u byte multicast packet to network %.16llx: not within budget for multicast group %s",(unsigned int)data.size(),(unsigned long long)network->id(),mg.toString().c_str());
return;
}
Multicaster::MulticastBloomFilter bloom;
SharedPtr<Peer> propPeers[ZT_MULTICAST_PROPAGATION_BREADTH];
unsigned int np = _r->multicaster->pickSocialPropagationPeers(