From 557801a09ef31c243add5f6d6de7a5f67af53ed2 Mon Sep 17 00:00:00 2001 From: Adam Ierymenko Date: Wed, 24 Sep 2014 09:04:09 -0700 Subject: Rename PacketDecoder to much more descriptive IncomingPacket --- node/Switch.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) (limited to 'node/Switch.cpp') diff --git a/node/Switch.cpp b/node/Switch.cpp index 22b698bf..4e8cf4d8 100644 --- a/node/Switch.cpp +++ b/node/Switch.cpp @@ -547,7 +547,7 @@ unsigned long Switch::doTimerTasks() { Mutex::Lock _l(_rxQueue_m); - for(std::list< SharedPtr >::iterator i(_rxQueue.begin());i!=_rxQueue.end();) { + for(std::list< SharedPtr >::iterator i(_rxQueue.begin());i!=_rxQueue.end();) { if ((now - (*i)->receiveTime()) > ZT_RECEIVE_QUEUE_TIMEOUT) { TRACE("RX %s -> %s timed out",(*i)->source().toString().c_str(),(*i)->destination().toString().c_str()); _rxQueue.erase(i++); @@ -664,7 +664,7 @@ void Switch::doAnythingWaitingForPeer(const SharedPtr &peer) { // finish processing any packets waiting on peer's public key / identity Mutex::Lock _l(_rxQueue_m); - for(std::list< SharedPtr >::iterator rxi(_rxQueue.begin());rxi!=_rxQueue.end();) { + for(std::list< SharedPtr >::iterator rxi(_rxQueue.begin());rxi!=_rxQueue.end();) { if ((*rxi)->tryDecode(_r)) _rxQueue.erase(rxi++); else ++rxi; @@ -755,7 +755,7 @@ void Switch::_handleRemotePacketFragment(const SharedPtr &fromSock,const // We have all fragments -- assemble and process full Packet //TRACE("packet %.16llx is complete, assembling and processing...",pid); - SharedPtr packet(dqe->second.frag0); + SharedPtr packet(dqe->second.frag0); for(unsigned int f=1;fappend(dqe->second.frags[f - 1].payload(),dqe->second.frags[f - 1].payloadLength()); _defragQueue.erase(dqe); @@ -772,7 +772,7 @@ void Switch::_handleRemotePacketFragment(const SharedPtr &fromSock,const void Switch::_handleRemotePacketHead(const SharedPtr &fromSock,const InetAddress &fromAddr,const Buffer<4096> &data) { - SharedPtr packet(new PacketDecoder(data,fromSock,fromAddr)); + SharedPtr packet(new IncomingPacket(data,fromSock,fromAddr)); Address source(packet->source()); Address destination(packet->destination()); -- cgit v1.2.3