From 002b023b29ec706f724d30ebd3c5528400844e81 Mon Sep 17 00:00:00 2001 From: orignal Date: Mon, 14 Apr 2014 16:24:57 -0400 Subject: [PATCH] increment outgoing sequence number --- Streaming.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/Streaming.cpp b/Streaming.cpp index cb0cc285..1baffd46 100644 --- a/Streaming.cpp +++ b/Streaming.cpp @@ -160,7 +160,7 @@ namespace stream size += 4; // sendStreamID *(uint32_t *)(packet + size) = htobe32 (m_RecvStreamID); size += 4; // receiveStreamID - *(uint32_t *)(packet + size) = htobe32 (m_SequenceNumber); + *(uint32_t *)(packet + size) = htobe32 (m_SequenceNumber++); size += 4; // sequenceNum *(uint32_t *)(packet + size) = 0; // TODO size += 4; // ack Through @@ -224,7 +224,7 @@ namespace stream size += 4; // sendStreamID *(uint32_t *)(packet + size) = htobe32 (m_RecvStreamID); size += 4; // receiveStreamID - *(uint32_t *)(packet + size) = htobe32 (m_SequenceNumber); + *(uint32_t *)(packet + size) = htobe32 (m_SequenceNumber++); size += 4; // sequenceNum *(uint32_t *)(packet + size) = htobe32 (m_LastReceivedSequenceNumber); size += 4; // ack Through @@ -286,7 +286,7 @@ namespace stream } I2NPMessage * msg = i2p::garlic::routing.WrapMessage (m_RemoteLeaseSet, CreateDataMessage (this, buf, len), leaseSet); - if (!m_OutboundTunnel) + if (!m_OutboundTunnel || m_OutboundTunnel->IsFailed ()) m_OutboundTunnel = m_LocalDestination->GetTunnelPool ()->GetNextOutboundTunnel (); if (m_OutboundTunnel) {