wornvirtue
/
premiere-libtorrent
forked from premiere/premiere-libtorrent
1
0
Fork 0
Code Pull Requests Activity

some more asserts in utp

This commit is contained in:
Arvid Norberg 2012-06-26 23:52:48 +00:00
parent 5797430b4a
commit 1419b5c14c
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/utp_stream.cpp
View File

@ -1245,6 +1245,8 @@ void utp_socket_impl::send_syn()
TORRENT_ASSERT(!m_outbuf.at(m_seq_nr));
m_outbuf.insert(m_seq_nr, p);
TORRENT_ASSERT(h->seq_nr == m_seq_nr);
TORRENT_ASSERT(p->buf == (uint8_t*)h);
m_seq_nr = (m_seq_nr + 1) & ACK_MASK;
@ -1314,9 +1316,12 @@ void utp_socket_impl::send_fin()
packet* old = (packet*)m_outbuf.insert(m_seq_nr, p);
if (old)
{
TORRENT_ASSERT(((utp_header*)old->buf)->seq_nr == m_seq_nr);
if (!old->need_resend) m_bytes_in_flight -= old->size - old->header_size;
free(old);
}
TORRENT_ASSERT(h->seq_nr == m_seq_nr);
m_seq_nr = (m_seq_nr + 1) & ACK_MASK;
m_fast_resend_seq_nr = m_seq_nr;
@ -1857,9 +1862,11 @@ bool utp_socket_impl::send_pkt(bool ack)
packet* old = (packet*)m_outbuf.insert(m_seq_nr, p);
if (old)
{
TORRENT_ASSERT(((utp_header*)old->buf)->seq_nr == m_seq_nr);
if (!old->need_resend) m_bytes_in_flight -= old->size - old->header_size;
free(old);
}
TORRENT_ASSERT(h->seq_nr == m_seq_nr);
m_seq_nr = (m_seq_nr + 1) & ACK_MASK;
TORRENT_ASSERT(payload_size >= 0);
m_bytes_in_flight += p->size - p->header_size;