Skip to content

Commit

Permalink
Merged and fixed
Browse files Browse the repository at this point in the history
  • Loading branch information
Mikołaj Małecki committed Sep 14, 2023
1 parent de62802 commit 6830c3a
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
4 changes: 2 additions & 2 deletions srtcore/core.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -10221,8 +10221,8 @@ int srt::CUDT::handleSocketPacketReception(const vector<CUnit*>& incoming, bool&

const steady_clock::time_point tnow = steady_clock::now();
ScopedLock lg(m_StatsLock);
m_stats.rcvr.dropped.count(stats::BytesPackets(iDropCnt* rpkt.getLength(), iDropCnt));
m_stats.rcvr.undecrypted.count(stats::BytesPackets(rpkt.getLength(), 1));
m_stats.rcvr.dropped.count(stats::BytesPacketsCount(iDropCnt* rpkt.getLength(), iDropCnt));
m_stats.rcvr.undecrypted.count(stats::BytesPacketsCount(rpkt.getLength(), 1));
string why;
if (frequentLogAllowed(FREQLOGFA_ENCRYPTION_FAILURE, tnow, (why)))
{
Expand Down
2 changes: 1 addition & 1 deletion srtcore/queue.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -1762,7 +1762,7 @@ srt::CUDT* srt::CRcvQueue::getNewEntry()
return u;
}

void srt::CRcvQueue::storePkt(SRTSOCKET id, const CPacket& pkt)
void srt::CRcvQueue::storePktClone(SRTSOCKET id, const CPacket& pkt)
{
CUniqueSync passcond(m_BufferLock, m_BufferCond);

Expand Down
2 changes: 1 addition & 1 deletion srtcore/queue.h
Original file line number Diff line number Diff line change
Expand Up @@ -556,7 +556,7 @@ class CRcvQueue
bool ifNewEntry();
CUDT* getNewEntry();

void storePkt(SRTSOCKET id, const CPacket& pkt);
void storePktClone(SRTSOCKET id, const CPacket& pkt);

private:
sync::Mutex m_LSLock;
Expand Down

0 comments on commit 6830c3a

Please sign in to comment.