RetroSearch Browse

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

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

[core] fix m_iLastSchedSeqNo · Haivision/srt@fec9a40 · GitHub

File tree Expand file treeCollapse file tree 2 files changed

+12

-8

lines changed

Filter options

Expand file treeCollapse file tree 2 files changed

+12

-8

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


 @@ -9938,9 +9938,9 @@ int srt::CUDT::processData(CUnit* in_unit)

9938 9938

9939 9939


 if (gi->rcvstate < SRT_GST_RUNNING) // PENDING or IDLE, tho PENDING is unlikely

9940 9940

9941

-
 HLOGC(qrlog.Debug, log << "processData: IN-GROUP rcv state transition "

9942

-
   << srt_log_grp_state[gi->rcvstate]

9943

-
 << " -> RUNNING. NOT checking for loss");

9941

+
 HLOGC(qrlog.Debug,

9942

+
 log << "processData: IN-GROUP rcv state transition " << srt_log_grp_state[gi->rcvstate]

9943

+
  << " -> RUNNING.");

9944 9944


 gi->rcvstate = SRT_GST_RUNNING;

9945 9945

9946 9946


 else

Original file line number Diff line number Diff line change


 @@ -118,7 +118,7 @@ bool CUDTGroup::applyGroupSequences(SRTSOCKET target, int32_t& w_snd_isn, int32_

118 118 119 119


 HLOGC(gmlog.Debug,

120 120


 log << "applyGroupSequences: @" << target << " gets seq from @" << gi->id << " rcv %" << (w_rcv_isn)

121

-
 << " snd %" << (w_rcv_isn) << " as " << update_reason);

121

+
 << " snd %" << (w_snd_isn) << " as " << update_reason);

122 122


 return false;

123 123

124 124


 @@ -1108,7 +1108,8 @@ int CUDTGroup::sendBroadcast(const char* buf, int len, SRT_MSGCTRL& w_mc)

1108 1108


 vector<gli_t> idleLinks;

1109 1109


 vector<SRTSOCKET> pendingSockets; // need sock ids as it will be checked out of lock

1110 1110 1111

-
 int32_t curseq = SRT_SEQNO_NONE;

1111

+
 int32_t curseq = SRT_SEQNO_NONE; // The seqno of the first packet of this message.

1112

+
 int32_t nextseq = SRT_SEQNO_NONE; // The seqno of the first packet of next message.

1112 1113 1113 1114


 int rstat = -1;

1114 1115


 @@ -1247,6 +1248,7 @@ int CUDTGroup::sendBroadcast(const char* buf, int len, SRT_MSGCTRL& w_mc)

1247 1248


 if (stat != -1)

1248 1249

1249 1250


 curseq = w_mc.pktseq;

1251

+
 nextseq = d->ps->core().schedSeqNo();

1250 1252

1251 1253 1252 1254


 const Sendstate cstate = {d->id, &*d, stat, erc};


 @@ -1340,6 +1342,7 @@ int CUDTGroup::sendBroadcast(const char* buf, int len, SRT_MSGCTRL& w_mc)

1340 1342


 // Note: this will override the sequence number

1341 1343


 // for all next iterations in this loop.

1342 1344


 curseq = w_mc.pktseq;

1345

+
 nextseq = d->ps->core().schedSeqNo();

1343 1346


 HLOGC(gslog.Debug,

1344 1347


 log << "@" << d->id << ":... sending SUCCESSFUL %" << curseq << " MEMBER STATUS: RUNNING");

1345 1348


 @@ -1351,10 +1354,11 @@ int CUDTGroup::sendBroadcast(const char* buf, int len, SRT_MSGCTRL& w_mc)

1351 1354


 sendstates.push_back(cstate);

1352 1355

1353 1356 1354

-
 if (curseq != SRT_SEQNO_NONE)

1357

+
 if (nextseq != SRT_SEQNO_NONE)

1355 1358

1356

-
 HLOGC(gslog.Debug, log << "grp/sendBroadcast: updating current scheduling sequence %" << curseq);

1357

-
 m_iLastSchedSeqNo = curseq;

1359

+
 HLOGC(gslog.Debug,

1360

+
 log << "grp/sendBroadcast: $" << id() << ": updating current scheduling sequence %" << nextseq);

1361

+
 m_iLastSchedSeqNo = nextseq;

1358 1362

1359 1363 1360 1364


 // }

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