Skip to content

Commit

Permalink
[core] Fixed rcvDropTooLateUpTo calls.
Browse files Browse the repository at this point in the history
Broken after merging #2218
  • Loading branch information
maxsharabayko committed Feb 7, 2022
1 parent 8f68f61 commit 650dbe6
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions srtcore/group.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -2267,7 +2267,7 @@ int CUDTGroup::recv(char* buf, int len, SRT_MSGCTRL& w_mc)
if (m_RcvBaseSeqNo != SRT_SEQNO_NONE)
{
// Drop here to make sure the getFirstReadablePacketInfo() below return fresher packet.
int cnt = ps->core().dropTooLateUpTo(CSeqNo::incseq(m_RcvBaseSeqNo));
int cnt = ps->core().rcvDropTooLateUpTo(CSeqNo::incseq(m_RcvBaseSeqNo));
if (cnt > 0)
{
HLOGC(grlog.Debug,
Expand Down Expand Up @@ -2359,7 +2359,7 @@ int CUDTGroup::recv(char* buf, int len, SRT_MSGCTRL& w_mc)
ScopedLock lg(ps->core().m_RcvBufferLock);
if (m_RcvBaseSeqNo != SRT_SEQNO_NONE)
{
int cnt = ps->core().dropTooLateUpTo(CSeqNo::incseq(m_RcvBaseSeqNo));
int cnt = ps->core().rcvDropTooLateUpTo(CSeqNo::incseq(m_RcvBaseSeqNo));
if (cnt > 0)
{
HLOGC(grlog.Debug,
Expand Down

0 comments on commit 650dbe6

Please sign in to comment.