+7
-6
lines changedFilter options
+7
-6
lines changed Original file line number Diff line number Diff line change
@@ -280,7 +280,10 @@ void srt::CSndUList::update(const CUDT* u, EReschedule reschedule, sync::steady_
280
280
281
281
if (n->m_iHeapLoc >= 0)
282
282
{
283
-
if (!reschedule) // EReschedule to bool conversion, predicted.
283
+
if (reschedule == DONT_RESCHEDULE)
284
+
return;
285
+
286
+
if (n->m_tsTimeStamp <= ts)
284
287
return;
285
288
286
289
if (n->m_iHeapLoc == 0)
@@ -644,11 +647,9 @@ void* srt::CSndQueue::worker(void* param)
644
647
}
645
648
646
649
const sockaddr_any addr = u->m_PeerAddr;
647
-
// Insert a new entry, send_time is the next processing time.
648
-
// TODO: maybe reschedule by taking the smaller time?
649
-
const steady_clock::time_point send_time = res_time.second;
650
-
if (!is_zero(send_time))
651
-
self->m_pSndUList->update(u, CSndUList::DONT_RESCHEDULE, send_time);
650
+
const steady_clock::time_point next_send_time = res_time.second;
651
+
if (!is_zero(next_send_time))
652
+
self->m_pSndUList->update(u, CSndUList::DO_RESCHEDULE, next_send_time);
652
653
653
654
HLOGC(qslog.Debug, log << self->CONID() << "chn:SENDING: " << pkt.Info());
654
655
self->m_pChannel->sendto(addr, pkt);
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