diff options
| author | Adam Ierymenko <adam.ierymenko@gmail.com> | 2014-10-09 18:32:05 -0700 |
|---|---|---|
| committer | Adam Ierymenko <adam.ierymenko@gmail.com> | 2014-10-09 18:32:05 -0700 |
| commit | 56f8f8aa242d288c9a9670a163106ba1469b14ba (patch) | |
| tree | 2555c49d63b2f890b113b18736fcfd4036db435a /node/OutboundMulticast.cpp | |
| parent | 4941c8a1f393c50259ae2cc0f1e8b79068d44af3 (diff) | |
| download | infinitytier-56f8f8aa242d288c9a9670a163106ba1469b14ba.tar.gz infinitytier-56f8f8aa242d288c9a9670a163106ba1469b14ba.zip | |
Return self in GATHER requests if self is a member of multicast group, and reinstate legacy support.
Diffstat (limited to 'node/OutboundMulticast.cpp')
| -rw-r--r-- | node/OutboundMulticast.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/node/OutboundMulticast.cpp b/node/OutboundMulticast.cpp index 26072a8a..0be15990 100644 --- a/node/OutboundMulticast.cpp +++ b/node/OutboundMulticast.cpp @@ -58,6 +58,7 @@ void OutboundMulticast::init( if (gatherLimit) flags |= 0x02; if (src) flags |= 0x04; + /* TRACE(">>MC %.16llx INIT %.16llx/%s limit %u gatherLimit %u from %s to %s length %u com==%d", (unsigned long long)this, nwid, @@ -68,6 +69,7 @@ void OutboundMulticast::init( dest.toString().c_str(), len, (com) ? 1 : 0); + */ _packetNoCom.setSource(RR->identity.address()); _packetNoCom.setVerb(Packet::VERB_MULTICAST_FRAME); @@ -107,12 +109,12 @@ void OutboundMulticast::sendOnly(const RuntimeEnvironment *RR,const Address &toA if (network->peerNeedsOurMembershipCertificate(toAddr,Utils::now())) { _packetWithCom.newInitializationVector(); _packetWithCom.setDestination(toAddr); - TRACE(">>MC %.16llx -> %s (with COM)",(unsigned long long)this,toAddr.toString().c_str()); + //TRACE(">>MC %.16llx -> %s (with COM)",(unsigned long long)this,toAddr.toString().c_str()); RR->sw->send(_packetWithCom,true); return; } } - TRACE(">>MC %.16llx -> %s (without COM)",(unsigned long long)this,toAddr.toString().c_str()); + //TRACE(">>MC %.16llx -> %s (without COM)",(unsigned long long)this,toAddr.toString().c_str()); _packetNoCom.newInitializationVector(); _packetNoCom.setDestination(toAddr); RR->sw->send(_packetNoCom,true); |