A RetroSearch Logo

Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Search Query:

Showing content from https://github.com/Haivision/srt/commit/64846cc7b408bb1fdd79bf28b8f79bd3cb0686e3 below:

[core] Fixed build with the old receiver buffer. · Haivision/srt@64846cc · GitHub

File tree Expand file treeCollapse file tree 1 file changed

+28

-28

lines changed

Filter options

Expand file treeCollapse file tree 1 file changed

+28

-28

lines changed Original file line number Diff line number Diff line change

@@ -5323,34 +5323,6 @@ void * srt::CUDT::tsbpd(void* param)

 5323 5323

return NULL;

 5324 5324

}

 5325 5325 5326 -

void srt::CUDT::setInitialRcvSeq(int32_t isn)

 5327 -

{

 5328 -

m_iRcvLastAck = isn;

 5329 -

#ifdef ENABLE_LOGGING

 5330 -

m_iDebugPrevLastAck = m_iRcvLastAck;

 5331 -

#endif

 5332 -

m_iRcvLastSkipAck = m_iRcvLastAck;

 5333 -

m_iRcvLastAckAck = isn;

 5334 -

m_iRcvCurrSeqNo = CSeqNo::decseq(isn);

 5335 - 5336 -

#if ENABLE_NEW_RCVBUFFER

 5337 -

sync::ScopedLock rb(m_RcvBufferLock);

 5338 -

if (m_pRcvBuffer)

 5339 -

{

 5340 -

if (!m_pRcvBuffer->empty())

 5341 -

{

 5342 -

LOGC(cnlog.Error, log << "IPE: setInitialRcvSeq expected empty RCV buffer. Dropping all.");

 5343 -

const int iDropCnt = m_pRcvBuffer->dropAll();

 5344 -

const uint64_t avgpayloadsz = m_pRcvBuffer->getRcvAvgPayloadSize();

 5345 -

sync::ScopedLock sl(m_StatsLock);

 5346 -

m_stats.rcvr.dropped.count(stats::BytesPackets(iDropCnt * avgpayloadsz, (size_t)iDropCnt));

 5347 -

}

 5348 - 5349 -

m_pRcvBuffer->setStartSeqNo(m_iRcvLastSkipAck);

 5350 -

}

 5351 -

#endif

 5352 -

}

 5353 - 5354 5326

int srt::CUDT::rcvDropTooLateUpTo(int seqno)

 5355 5327

{

 5356 5328

// Make sure that it would not drop over m_iRcvCurrSeqNo, which may break senders.

@@ -5598,6 +5570,34 @@ void * srt::CUDT::tsbpd(void *param)

 5598 5570

}

 5599 5571

#endif // ENABLE_NEW_RCVBUFFER

 5600 5572 5573 +

void srt::CUDT::setInitialRcvSeq(int32_t isn)

 5574 +

{

 5575 +

m_iRcvLastAck = isn;

 5576 +

#ifdef ENABLE_LOGGING

 5577 +

m_iDebugPrevLastAck = m_iRcvLastAck;

 5578 +

#endif

 5579 +

m_iRcvLastSkipAck = m_iRcvLastAck;

 5580 +

m_iRcvLastAckAck = isn;

 5581 +

m_iRcvCurrSeqNo = CSeqNo::decseq(isn);

 5582 + 5583 +

#if ENABLE_NEW_RCVBUFFER

 5584 +

sync::ScopedLock rb(m_RcvBufferLock);

 5585 +

if (m_pRcvBuffer)

 5586 +

{

 5587 +

if (!m_pRcvBuffer->empty())

 5588 +

{

 5589 +

LOGC(cnlog.Error, log << "IPE: setInitialRcvSeq expected empty RCV buffer. Dropping all.");

 5590 +

const int iDropCnt = m_pRcvBuffer->dropAll();

 5591 +

const uint64_t avgpayloadsz = m_pRcvBuffer->getRcvAvgPayloadSize();

 5592 +

sync::ScopedLock sl(m_StatsLock);

 5593 +

m_stats.rcvr.dropped.count(stats::BytesPackets(iDropCnt * avgpayloadsz, (size_t)iDropCnt));

 5594 +

}

 5595 + 5596 +

m_pRcvBuffer->setStartSeqNo(m_iRcvLastSkipAck);

 5597 +

}

 5598 +

#endif

 5599 +

}

 5600 + 5601 5601

void srt::CUDT::updateForgotten(int seqlen, int32_t lastack, int32_t skiptoseqno)

 5602 5602

{

 5603 5603

enterCS(m_StatsLock);

You can’t perform that action at this time.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4