|
|
@ -27,8 +27,6 @@ namespace tunnel |
|
|
|
|
|
|
|
|
|
|
|
TransitTunnelParticipant::~TransitTunnelParticipant () |
|
|
|
TransitTunnelParticipant::~TransitTunnelParticipant () |
|
|
|
{ |
|
|
|
{ |
|
|
|
for (auto it: m_TunnelDataMsgs) |
|
|
|
|
|
|
|
i2p::DeleteI2NPMessage (it); |
|
|
|
|
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
void TransitTunnelParticipant::HandleTunnelDataMsg (i2p::I2NPMessage * tunnelMsg) |
|
|
|
void TransitTunnelParticipant::HandleTunnelDataMsg (i2p::I2NPMessage * tunnelMsg) |
|
|
@ -38,7 +36,7 @@ namespace tunnel |
|
|
|
m_NumTransmittedBytes += tunnelMsg->GetLength (); |
|
|
|
m_NumTransmittedBytes += tunnelMsg->GetLength (); |
|
|
|
htobe32buf (tunnelMsg->GetPayload (), GetNextTunnelID ()); |
|
|
|
htobe32buf (tunnelMsg->GetPayload (), GetNextTunnelID ()); |
|
|
|
FillI2NPMessageHeader (tunnelMsg, eI2NPTunnelData); |
|
|
|
FillI2NPMessageHeader (tunnelMsg, eI2NPTunnelData); |
|
|
|
m_TunnelDataMsgs.push_back (tunnelMsg); |
|
|
|
m_TunnelDataMsgs.push_back (ToSharedI2NPMessage (tunnelMsg)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
void TransitTunnelParticipant::FlushTunnelDataMsgs () |
|
|
|
void TransitTunnelParticipant::FlushTunnelDataMsgs () |
|
|
|