| /mOS-networking-stack/core/src/ |
| H A D | timer.c | 172 cur_stream->sndvar->ts_rto = cur_ts + cur_stream->sndvar->rto; in UpdateRetransmissionTimer()
188 cur_stream->id, cur_stream->sndvar->rto, TS_TO_MSEC(cur_stream->sndvar->rto), in HandleRTO()
194 cur_stream->sndvar->nrtx++; in HandleRTO()
215 if (cur_stream->sndvar->nrtx > cur_stream->sndvar->max_nrtx) { in HandleRTO()
216 cur_stream->sndvar->max_nrtx = cur_stream->sndvar->nrtx; in HandleRTO()
225 cur_stream->sndvar->rto = in HandleRTO()
242 cur_stream->sndvar->ssthresh = MIN(cur_stream->sndvar->cwnd, cur_stream->sndvar->peer_wnd) / 2; in HandleRTO()
243 if (cur_stream->sndvar->ssthresh < (2 * cur_stream->sndvar->mss)) { in HandleRTO()
244 cur_stream->sndvar->ssthresh = cur_stream->sndvar->mss * 2; in HandleRTO()
246 cur_stream->sndvar->cwnd = cur_stream->sndvar->mss; in HandleRTO()
[all …]
|
| H A D | tcp_out.c | 370 cur_stream->sndvar->ts_rto = cur_ts + cur_stream->sndvar->rto; in SendTCPPacket()
373 cur_ts, cur_stream->sndvar->rto, cur_stream->sndvar->ts_rto); in SendTCPPacket()
417 struct tcp_send_vars *sndvar = cur_stream->sndvar; in FlushTCPSendingBuffer() local
441 window = MIN(sndvar->cwnd, sndvar->peer_wnd); in FlushTCPSendingBuffer()
454 buffered_len = sndvar->sndbuf->head_seq + sndvar->sndbuf->len - seq; in FlushTCPSendingBuffer()
485 if (seq - sndvar->snd_una + len > sndvar->peer_wnd) { in FlushTCPSendingBuffer()
488 sndvar->peer_wnd, seq - sndvar->snd_una); in FlushTCPSendingBuffer()
517 struct tcp_send_vars *sndvar = cur_stream->sndvar; in SendControlPacket() local
538 if (sndvar->on_send_list || sndvar->on_ack_list) in SendControlPacket()
555 if (sndvar->on_send_list || sndvar->on_ack_list) in SendControlPacket()
[all …]
|
| H A D | tcp_in.c | 418 sndvar->ssthresh = MIN(sndvar->cwnd, sndvar->peer_wnd) / 2; in ProcessACK()
420 sndvar->ssthresh = 2 * sndvar->mss; in ProcessACK()
422 sndvar->cwnd = sndvar->ssthresh + 3 * sndvar->mss; in ProcessACK()
424 sndvar->cwnd, sndvar->ssthresh); in ProcessACK()
437 if ((uint32_t)(sndvar->cwnd + sndvar->mss) > sndvar->cwnd) { in ProcessACK()
438 sndvar->cwnd += sndvar->mss; in ProcessACK()
440 sndvar->cwnd, sndvar->ssthresh); in ProcessACK()
497 if ((sndvar->cwnd + sndvar->mss) > sndvar->cwnd) { in ProcessACK()
501 sndvar->cwnd, sndvar->ssthresh); in ProcessACK()
523 sndvar->snd_wnd = sndvar->sndbuf->size - sndvar->sndbuf->len; in ProcessACK()
[all …]
|
| H A D | tcp_stream.c | 529 stream->sndvar->snd_una = stream->sndvar->iss;
899 struct tcp_send_vars *sndvar = stream->sndvar; local
939 sndvar->on_ack_list, sndvar->is_wack, sndvar->ack_cnt,
942 sndvar->on_sendq, sndvar->on_ackq,
944 sndvar->on_resetq, sndvar->on_resetq_int,
952 sndvar->ip_id, sndvar->mss, sndvar->eff_mss,
953 sndvar->wscale_mine, sndvar->wscale_peer, sndvar->nif_out);
957 stream->snd_nxt, sndvar->snd_una, sndvar->iss, sndvar->fss,
958 sndvar->snd_wnd, sndvar->peer_wnd, sndvar->cwnd, sndvar->ssthresh);
965 sndvar->sndbuf->len, sndvar->sndbuf->cum_len, sndvar->sndbuf->size);
[all …]
|
| H A D | api.c | 1126 cur_stream->sndvar->ssthresh = cur_stream->sndvar->mss * 10; in mtcp_connect()
1730 struct tcp_send_vars *sndvar = cur_stream->sndvar; in CopyFromUser() local
1741 if (!sndvar->sndbuf) { in CopyFromUser()
1742 sndvar->sndbuf = SBInit(mtcp->rbm_snd, sndvar->iss + 1); in CopyFromUser()
1743 if (!sndvar->sndbuf) { in CopyFromUser()
1753 sndvar->snd_wnd = sndvar->sndbuf->size - sndvar->sndbuf->len; in CopyFromUser()
1824 sndvar = cur_stream->sndvar; in mtcp_write()
1831 if (ret > 0 && !(sndvar->on_sendq || sndvar->on_send_list)) { in mtcp_write()
1833 sndvar->on_sendq = TRUE; in mtcp_write()
1898 sndvar = cur_stream->sndvar; in mtcp_writev()
[all …]
|
| H A D | tcp_util.c | 36 cur_stream->sndvar->mss = *(tcpopt + i++) << 8; in ParseTCPOptions()
37 cur_stream->sndvar->mss += *(tcpopt + i++); in ParseTCPOptions()
38 cur_stream->sndvar->eff_mss = cur_stream->sndvar->mss; in ParseTCPOptions()
40 cur_stream->sndvar->eff_mss -= (TCP_OPT_TIMESTAMP_LEN + 2); in ParseTCPOptions()
43 cur_stream->sndvar->wscale_peer = *(tcpopt + i++); in ParseTCPOptions()
|
| H A D | core.c | 595 struct tcp_send_vars *sndvar = stream->sndvar; in HandleApplicationCalls() local
596 sndvar->on_closeq = FALSE; in HandleApplicationCalls()
598 if (sndvar->sndbuf) { in HandleApplicationCalls()
599 sndvar->fss = sndvar->sndbuf->head_seq + sndvar->sndbuf->len; in HandleApplicationCalls()
620 sndvar->on_closeq_int = TRUE; in HandleApplicationCalls()
623 if (sndvar->on_control_list) in HandleApplicationCalls()
625 if (sndvar->on_send_list) in HandleApplicationCalls()
627 if (sndvar->on_ack_list) in HandleApplicationCalls()
630 } else if (sndvar->on_send_list || sndvar->on_ack_list) { in HandleApplicationCalls()
712 stream->sndvar->on_send_list || stream->sndvar->on_ack_list) { in HandleApplicationCalls()
[all …]
|
| H A D | ip_out.c | 190 if (stream->sndvar->nif_out >= 0) { in IPOutput()
191 nif = stream->sndvar->nif_out; in IPOutput()
194 stream->sndvar->nif_out = nif; in IPOutput()
204 RequestARP(mtcp, stream->daddr, stream->sndvar->nif_out, mtcp->cur_ts); in IPOutput()
214 stream->sndvar->nif_out, haddr, tcplen + IP_HEADER_LEN, cur_ts); in IPOutput()
223 iph->id = htons(stream->sndvar->ip_id++); in IPOutput()
|
| H A D | tcp.c | 102 cur_stream->sndvar->peer_wnd = pctx->p.window; in CreateServerStream()
104 cur_stream->sndvar->cwnd = 1; in CreateServerStream()
128 stream->sndvar->peer_wnd = pctx->p.window; in CreateMonitorStream()
130 stream->sndvar->cwnd = 1; in CreateMonitorStream()
332 recvside_stream->sndvar->peer_wnd = pctx->p.window; in UpdateMonitor()
334 recvside_stream->sndvar->cwnd = 1; in UpdateMonitor()
|
| H A D | eventpoll.c | 227 struct tcp_send_vars *sndvar = stream->sndvar; in RaisePendingStreamEvents() local
228 if (!sndvar->sndbuf || in RaisePendingStreamEvents()
229 (sndvar->sndbuf && sndvar->sndbuf->len < sndvar->snd_wnd)) { in RaisePendingStreamEvents()
|
| /mOS-networking-stack/core/src/include/ |
| H A D | tcp_stream.h | 273 struct tcp_send_vars *sndvar; member
|