Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- else if ((pRecvPacket->isReliablePacket()) && (pRecvPacket->isSequencedPacket())) {
- // This is a reliable sequenced packet
- uint32 ui32SequenceNum = pRecvPacket->getSequenceNum();
- PacketWrapper *pWrapper = new PacketWrapper (pRecvPacket, _i64LastRecvTime);
- if (_reliableSequencedPacketQueue.insert (pWrapper)) {
- checkAndLogMsg ("Receiver::run", Logger::L_MediumDetailDebug,
- "enqueued reliable sequenced packet with sequence number %lu into reliable sequenced packet queue\n", ui32SequenceNum);
- _pMocket->getACKManager()->receivedReliableSequencedPacket (ui32SequenceNum);
- _pPacketProcessor->packetArrived();
- }
- else {
- decrementQueuedDataSize (pRecvPacket->getPacketSize());
- delete pWrapper;
- delete pRecvPacket;
- pRecvPacket = NULL;
- _pMocket->getStatistics()->_ui32DuplicatedDiscardedPackets++;
- _pMocket->getTransmitter()->requestSAckTransmission();
- checkAndLogMsg ("Receiver::run", Logger::L_MediumDetailDebug,
- "dropped reliable sequenced packet with sequence number %lu\n", ui32SequenceNum);
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement