Browse Source

Thread-safe cap initiliazation.

cl-refactor
subtly 10 years ago
parent
commit
d203bf6d58
  1. 7
      libp2p/Host.cpp

7
libp2p/Host.cpp

@ -219,8 +219,8 @@ void Host::startPeerSession(Public const& _id, RLP const& _rlp, RLPXFrameIO* _io
ps->disconnect(DuplicatePeer);
return;
}
m_sessions[_id] = ps;
}
// todo: mutex Session::m_capabilities and move for(:caps) out of mutex.
unsigned o = (unsigned)UserPacket;
for (auto const& i: caps)
if (haveCapability(i))
@ -229,6 +229,9 @@ void Host::startPeerSession(Public const& _id, RLP const& _rlp, RLPXFrameIO* _io
o += m_capabilities[i]->messageCount();
}
ps->start();
m_sessions[_id] = ps;
}
clog(NetNote) << "p2p.host.peer.register" << _id.abridged();
StructuredLogger::p2pConnected(_id.abridged(), ps->m_peer->peerEndpoint(), ps->m_peer->m_lastConnected, clientVersion, peerCount());
}

Loading…
Cancel
Save