|
|
@ -239,8 +239,9 @@ namespace transport |
|
|
|
try |
|
|
|
try |
|
|
|
{ |
|
|
|
{ |
|
|
|
auto r = netdb.FindRouter (ident); |
|
|
|
auto r = netdb.FindRouter (ident); |
|
|
|
it = m_Peers.insert (std::pair<i2p::data::IdentHash, Peer>(ident, { 0, r, {}, |
|
|
|
it = m_Peers.insert(std::make_pair( |
|
|
|
i2p::util::GetSecondsSinceEpoch () })).first; |
|
|
|
ident, Peer{ 0, r, {}, i2p::util::GetSecondsSinceEpoch (), {} } |
|
|
|
|
|
|
|
)).first; |
|
|
|
connected = ConnectToPeer (ident, it->second); |
|
|
|
connected = ConnectToPeer (ident, it->second); |
|
|
|
} |
|
|
|
} |
|
|
|
catch (std::exception& ex) |
|
|
|
catch (std::exception& ex) |
|
|
@ -436,7 +437,9 @@ namespace transport |
|
|
|
it->second.delayedMessages.clear (); |
|
|
|
it->second.delayedMessages.clear (); |
|
|
|
} |
|
|
|
} |
|
|
|
else // incoming connection
|
|
|
|
else // incoming connection
|
|
|
|
m_Peers.insert (std::make_pair (ident, Peer{ 0, nullptr, { session }, i2p::util::GetSecondsSinceEpoch () })); |
|
|
|
m_Peers.insert(std::make_pair( |
|
|
|
|
|
|
|
ident, Peer{ 0, nullptr, { session }, i2p::util::GetSecondsSinceEpoch (), {} } |
|
|
|
|
|
|
|
)); |
|
|
|
}); |
|
|
|
}); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|