| 4108 | } |
| 4109 | |
| 4110 | std::optional<std::pair<CNetMessage, bool>> CNode::PollMessage() |
| 4111 | { |
| 4112 | LOCK(m_msg_process_queue_mutex); |
| 4113 | if (m_msg_process_queue.empty()) return std::nullopt; |
| 4114 | |
| 4115 | std::list<CNetMessage> msgs; |
| 4116 | // Just take one message |
| 4117 | msgs.splice(msgs.begin(), m_msg_process_queue, m_msg_process_queue.begin()); |
| 4118 | m_msg_process_queue_size -= msgs.front().GetMemoryUsage(); |
| 4119 | fPauseRecv = m_msg_process_queue_size > m_recv_flood_size; |
| 4120 | |
| 4121 | return std::make_pair(std::move(msgs.front()), !m_msg_process_queue.empty()); |
| 4122 | } |
| 4123 | |
| 4124 | bool CConnman::NodeFullyConnected(const CNode* pnode) |
| 4125 | { |
no test coverage detected