github-repos/kcp
1
0
Fork 0
mirror of https://github.com/skywind3000/kcp.git synced 2025-03-22 07:22:59 +08:00
Code Issues Projects Releases Wiki Activity

Move code to match the comments

Browse Source
This commit is contained in:
Chinsyo 2020-11-05 19:14:03 +08:00
parent c5a17fb8b5
commit db53bfba08
1 changed files with 22 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

44
ikcp.c
View File

@ -540,6 +540,28 @@ int ikcp_send(ikcpcb *kcp, const char *buffer, int len)
//--------------------------------------------------------------------- //---------------------------------------------------------------------
// parse ack // parse ack
//--------------------------------------------------------------------- //---------------------------------------------------------------------
static void ikcp_parse_ack(ikcpcb *kcp, IUINT32 sn)
{
struct IQUEUEHEAD *p, *next;
if (_itimediff(sn, kcp->snd_una) < 0 || _itimediff(sn, kcp->snd_nxt) >= 0)
return;
for (p = kcp->snd_buf.next; p != &kcp->snd_buf; p = next) {
IKCPSEG *seg = iqueue_entry(p, IKCPSEG, node);
next = p->next;
if (sn == seg->sn) {
iqueue_del(p);
ikcp_segment_delete(kcp, seg);
kcp->nsnd_buf--;
break;
}
if (_itimediff(sn, seg->sn) < 0) {
break;
}
}
}
static void ikcp_update_ack(ikcpcb *kcp, IINT32 rtt) static void ikcp_update_ack(ikcpcb *kcp, IINT32 rtt)
{ {
IINT32 rto = 0; IINT32 rto = 0;
@ -568,28 +590,6 @@ static void ikcp_shrink_buf(ikcpcb *kcp)
} }
} }
static void ikcp_parse_ack(ikcpcb *kcp, IUINT32 sn)
{
struct IQUEUEHEAD *p, *next;
if (_itimediff(sn, kcp->snd_una) < 0 || _itimediff(sn, kcp->snd_nxt) >= 0)
return;
for (p = kcp->snd_buf.next; p != &kcp->snd_buf; p = next) {
IKCPSEG *seg = iqueue_entry(p, IKCPSEG, node);
next = p->next;
if (sn == seg->sn) {
iqueue_del(p);
ikcp_segment_delete(kcp, seg);
kcp->nsnd_buf--;
break;
}
if (_itimediff(sn, seg->sn) < 0) {
break;
}
}
}
static void ikcp_parse_una(ikcpcb *kcp, IUINT32 una) static void ikcp_parse_una(ikcpcb *kcp, IUINT32 una)
{ {
struct IQUEUEHEAD *p, *next; struct IQUEUEHEAD *p, *next;