| 1775 | } |
| 1776 | |
| 1777 | void srt::CRcvQueue::removeConnector(const SRTSOCKET& id) |
| 1778 | { |
| 1779 | HLOGC(cnlog.Debug, log << "removeConnector: removing @" << id); |
| 1780 | m_pRendezvousQueue->remove(id); |
| 1781 | |
| 1782 | ScopedLock bufferlock(m_BufferLock); |
| 1783 | |
| 1784 | map<int32_t, std::queue<CPacket*> >::iterator i = m_mBuffer.find(id); |
| 1785 | if (i != m_mBuffer.end()) |
| 1786 | { |
| 1787 | HLOGC(cnlog.Debug, |
| 1788 | log << "removeConnector: ... and its packet queue with " << i->second.size() << " packets collected"); |
| 1789 | while (!i->second.empty()) |
| 1790 | { |
| 1791 | delete i->second.front(); |
| 1792 | i->second.pop(); |
| 1793 | } |
| 1794 | m_mBuffer.erase(i); |
| 1795 | } |
| 1796 | } |
| 1797 | |
| 1798 | void srt::CRcvQueue::setNewEntry(CUDT* u) |
| 1799 | { |