Home
last modified time | relevance | path

Searched refs:rcvvar (Results 1 – 13 of 13) sorted by relevance

/mOS-networking-stack/core/src/
H A Dtcp_in.c258 struct tcp_recv_vars *rcvvar = cur_stream->rcvvar; in EstimateRTT() local
277 if (rcvvar->mdev > rcvvar->mdev_max) { in EstimateRTT()
278 rcvvar->mdev_max = rcvvar->mdev; in EstimateRTT()
279 if (rcvvar->mdev_max > rcvvar->rttvar) { in EstimateRTT()
280 rcvvar->rttvar = rcvvar->mdev_max; in EstimateRTT()
284 if (rcvvar->mdev_max < rcvvar->rttvar) { in EstimateRTT()
285 rcvvar->rttvar -= (rcvvar->rttvar - rcvvar->mdev_max) >> 2; in EstimateRTT()
294 rcvvar->mdev_max = rcvvar->rttvar = MAX(rcvvar->mdev, tcp_rto_min); in EstimateRTT()
300 rcvvar->srtt, TS_TO_MSEC((rcvvar->srtt) >> 3), rcvvar->mdev, in EstimateRTT()
301 rcvvar->mdev_max, rcvvar->rttvar, rcvvar->rtt_seq); in EstimateRTT()
[all …]
H A Dtcp_stream.c241 rcvvar = stream->rcvvar; in RaiseReadEvent()
246 } else if (rcvvar->rcvbuf && tcprb_cflen(rcvvar->rcvbuf) > 0) { in RaiseReadEvent()
452 if (!stream->rcvvar) {
549 stream->rcvvar->snd_wl1 = stream->rcvvar->irs - 1;
900 struct tcp_recv_vars *rcvvar = stream->rcvvar; local
980 rcvvar->rcv_wnd, rcvvar->snd_wl1, rcvvar->snd_wl2);
985 rcvvar->last_ack_seq, rcvvar->dup_acks);
988 "ts_tw_expire: %u\n", rcvvar->ts_recent, rcvvar->ts_lastack_rcvd,
989 rcvvar->ts_last_ts_upd, rcvvar->ts_tw_expire);
992 rcvvar->srtt, rcvvar->mdev, rcvvar->mdev_max,
[all …]
H A Dapi.c1457 struct tcp_recv_vars *rcvvar = cur_stream->rcvvar; in PeekForUser() local
1459 tcprb_t *rb = rcvvar->rcvbuf; in PeekForUser()
1472 struct tcp_recv_vars *rcvvar = cur_stream->rcvvar; in CopyToUser() local
1474 tcprb_t *rb = rcvvar->rcvbuf; in CopyToUser()
1507 struct tcp_recv_vars *rcvvar; in mtcp_recv() local
1542 if (!cur_stream || !cur_stream->rcvvar || !cur_stream->rcvvar->rcvbuf || in mtcp_recv()
1549 rcvvar = cur_stream->rcvvar; in mtcp_recv()
1567 SBUF_LOCK(&rcvvar->read_lock); in mtcp_recv()
1623 struct tcp_recv_vars *rcvvar; in mtcp_readv() local
1661 rcvvar = cur_stream->rcvvar; in mtcp_readv()
[all …]
H A Dtcp_util.c50 cur_stream->rcvvar->ts_recent = ntohl(*(uint32_t *)(tcpopt + i)); in ParseTCPOptions()
51 cur_stream->rcvvar->ts_last_ts_upd = cur_ts; in ParseTCPOptions()
122 cur_stream->rcvvar->sack_table in ParseSACKOption()
123 [cur_stream->rcvvar->sacks].left_edge = left_edge; in ParseSACKOption()
124 cur_stream->rcvvar->sack_table in ParseSACKOption()
125 [cur_stream->rcvvar->sacks].right_edge = right_edge; in ParseSACKOption()
126 cur_stream->rcvvar->sacks++; in ParseSACKOption()
132 if (cur_stream->rcvvar->dup_acks == 3) { in ParseSACKOption()
H A Dfhash.c151 TAILQ_INSERT_TAIL(&ht->ht_table[idx], item, rcvvar->he_link); in HTInsert()
152 item->rcvvar->he_mybucket = &ht->ht_table[idx]; in HTInsert()
172 head = item->rcvvar->he_mybucket; in HTRemove()
174 TAILQ_REMOVE(head, item, rcvvar->he_link); in HTRemove()
208 TAILQ_FOREACH(walk, head, rcvvar->he_link) { in HTSearch()
H A Dtcp.c101 cur_stream->rcvvar->irs = pctx->p.seq; in CreateServerStream()
103 cur_stream->rcv_nxt = cur_stream->rcvvar->irs; in CreateServerStream()
127 stream->rcvvar->irs = pctx->p.seq; in CreateMonitorStream()
129 stream->rcv_nxt = stream->rcvvar->irs + 1; in CreateMonitorStream()
331 recvside_stream->rcvvar->irs = pctx->p.seq; in UpdateMonitor()
333 recvside_stream->rcv_nxt = recvside_stream->rcvvar->irs + 1; in UpdateMonitor()
468 if (cur_stream->rcvvar && cur_stream->rcvvar->rcvbuf) in ProcessInTCPPacket()
469 pctx->p.offset = (uint64_t)seq2loff(cur_stream->rcvvar->rcvbuf, in ProcessInTCPPacket()
470 pctx->p.seq, cur_stream->rcvvar->irs + 1); in ProcessInTCPPacket()
H A Dmos_api.c288 if (cur_stream->rcvvar != NULL && in mtcp_peek()
289 cur_stream->rcvvar->rcvbuf != NULL) { in mtcp_peek()
290 tcprb_t *rcvbuf = cur_stream->rcvvar->rcvbuf; in mtcp_peek()
406 if (cur_stream->rcvvar != NULL && in mtcp_ppeek()
407 cur_stream->rcvvar->rcvbuf != NULL) { in mtcp_ppeek()
408 tcprb_t *rcvbuf = cur_stream->rcvvar->rcvbuf; in mtcp_ppeek()
588 socket->monitor_stream->stream->rcvvar->ts_recent, in mtcp_sendpkt()
589 socket->monitor_stream->stream->rcvvar->ts_lastack_rcvd, in mtcp_sendpkt()
H A Dtcp_out.c76 ts[1] = htonl(cur_stream->rcvvar->ts_recent); in GenerateTCPTimestamp()
327 window32 = cur_stream->rcvvar->rcv_wnd >> wscale; in SendTCPPacket()
395 if (recvside_stream->rcvvar && recvside_stream->rcvvar->rcvbuf) in SendTCPPacket()
396 pctx.p.offset = (uint64_t)seq2loff(recvside_stream->rcvvar->rcvbuf, in SendTCPPacket()
398 recvside_stream->rcvvar->irs + 1); in SendTCPPacket()
744 if ((rb = cur_stream->rcvvar->rcvbuf) && in WriteTCPACKList()
746 (cur_stream->rcvvar->irs + 1) + rb->pile in WriteTCPACKList()
H A Deventpoll.c215 struct tcp_recv_vars *rcvvar = stream->rcvvar; in RaisePendingStreamEvents() local
216 if (rcvvar->rcvbuf && tcprb_cflen(rcvvar->rcvbuf) > 0) { in RaisePendingStreamEvents()
H A Dtimer.c87 cur_stream->rcvvar->ts_tw_expire = cur_ts + g_config.mos->tcp_tw_interval; in AddtoTimewaitList()
226 ((cur_stream->rcvvar->srtt >> 3) + cur_stream->rcvvar->rttvar) << backoff; in HandleRTO()
466 if ((int32_t)(cur_ts - walk->rcvvar->ts_tw_expire) >= 0) { in CheckTimewaitExpire()
H A Dtcp_rb.c902 if (pctx->p.payloadlen > 0 && recvside_stream->rcvvar != NULL in tcp_rb_overlapchk()
903 && (rb = recvside_stream->rcvvar->rcvbuf) != NULL) { in tcp_rb_overlapchk()
905 loff_t off = seq2loff(rb, pctx->p.seq, recvside_stream->rcvvar->irs + 1); in tcp_rb_overlapchk()
H A Dcore.c441 if (cur_stream->rcvvar != NULL && in FlushMonitorReadEvents()
442 cur_stream->rcvvar->rcvbuf != NULL) { in FlushMonitorReadEvents()
494 if (cur_stream->rcvvar != NULL && in FlushBufferedReadEvents()
495 cur_stream->rcvvar->rcvbuf != NULL) { in FlushBufferedReadEvents()
805 TAILQ_FOREACH(walk, &ht->ht_table[i], rcvvar->he_link) { in DestroyRemainingFlows()
/mOS-networking-stack/core/src/include/
H A Dtcp_stream.h272 struct tcp_recv_vars *rcvvar; member