| 1196 | } |
| 1197 | |
| 1198 | void PeerManagerImpl::InitializeNode(const CNode *pnode) |
| 1199 | { |
| 1200 | NodeId nodeid = pnode->GetId(); |
| 1201 | { |
| 1202 | LOCK(cs_main); |
| 1203 | mapNodeState.emplace_hint(mapNodeState.end(), std::piecewise_construct, std::forward_as_tuple(nodeid), std::forward_as_tuple(pnode->IsInboundConn())); |
| 1204 | assert(m_txrequest.Count(nodeid) == 0); |
| 1205 | } |
| 1206 | { |
| 1207 | PeerRef peer = std::make_shared<Peer>(nodeid); |
| 1208 | LOCK(m_peer_mutex); |
| 1209 | m_peer_map.emplace_hint(m_peer_map.end(), nodeid, std::move(peer)); |
| 1210 | } |
| 1211 | } |
| 1212 | |
| 1213 | void PeerManagerImpl::ReattemptInitialBroadcast(CScheduler& scheduler) |
| 1214 | { |