Lines Matching refs:sndvar
36 mtcp->rto_store->rto_now_ts = cur_stream->sndvar->ts_rto; in AddtoRTOList()
49 int diff = (int32_t)(cur_stream->sndvar->ts_rto - mtcp->rto_store->rto_now_ts); in AddtoRTOList()
56 cur_stream, sndvar->timer_link); in AddtoRTOList()
62 cur_stream, sndvar->timer_link); in AddtoRTOList()
78 cur_stream, sndvar->timer_link); in RemoveFromRTOList()
91 TAILQ_REMOVE(&mtcp->timewait_list, cur_stream, sndvar->timer_link); in AddtoTimewaitList()
92 TAILQ_INSERT_TAIL(&mtcp->timewait_list, cur_stream, sndvar->timer_link); in AddtoTimewaitList()
105 TAILQ_INSERT_TAIL(&mtcp->timewait_list, cur_stream, sndvar->timer_link); in AddtoTimewaitList()
118 TAILQ_REMOVE(&mtcp->timewait_list, cur_stream, sndvar->timer_link); in RemoveFromTimewaitList()
132 TAILQ_INSERT_TAIL(&mtcp->timeout_list, cur_stream, sndvar->timeout_link); in AddtoTimeoutList()
141 TAILQ_REMOVE(&mtcp->timeout_list, cur_stream, sndvar->timeout_link); in RemoveFromTimeoutList()
150 TAILQ_REMOVE(&mtcp->timeout_list, cur_stream, sndvar->timeout_link); in UpdateTimeoutList()
151 TAILQ_INSERT_TAIL(&mtcp->timeout_list, cur_stream, sndvar->timeout_link); in UpdateTimeoutList()
160 assert(cur_stream->sndvar->rto > 0); in UpdateRetransmissionTimer()
161 cur_stream->sndvar->nrtx = 0; in UpdateRetransmissionTimer()
169 if (TCP_SEQ_GT(cur_stream->snd_nxt, cur_stream->sndvar->snd_una)) { in UpdateRetransmissionTimer()
172 cur_stream->sndvar->ts_rto = cur_ts + cur_stream->sndvar->rto; in UpdateRetransmissionTimer()
178 cur_stream->sndvar->snd_una, cur_stream->snd_nxt); in UpdateRetransmissionTimer()
188 cur_stream->id, cur_stream->sndvar->rto, TS_TO_MSEC(cur_stream->sndvar->rto), in HandleRTO()
189 cur_stream->sndvar->snd_una, cur_stream->snd_nxt); in HandleRTO()
190 assert(cur_stream->sndvar->rto > 0); in HandleRTO()
193 if (cur_stream->sndvar->nrtx < TCP_MAX_RTX) { 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()
222 backoff = MIN(cur_stream->sndvar->nrtx, TCP_MAX_BACKOFF); in HandleRTO()
224 rto_prev = cur_stream->sndvar->rto; in HandleRTO()
225 cur_stream->sndvar->rto = in HandleRTO()
227 if (cur_stream->sndvar->rto <= 0) { in HandleRTO()
229 cur_stream->id, cur_stream->sndvar->rto, rto_prev, in HandleRTO()
231 cur_stream->sndvar->rto = rto_prev; in HandleRTO()
235 if (cur_stream->sndvar->nrtx < TCP_MAX_BACKOFF) { in HandleRTO()
236 cur_stream->sndvar->rto <<= 1; 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()
248 cur_stream->id, cur_stream->sndvar->cwnd, cur_stream->sndvar->ssthresh); in HandleRTO()
252 cur_stream->sndvar->rstat.rto_cnt++; in HandleRTO()
253 cur_stream->sndvar->rstat.rto_bytes += (cur_stream->snd_nxt - cur_stream->sndvar->snd_una); in HandleRTO()
262 if (cur_stream->sndvar->nrtx > TCP_MAX_SYN_RETRY) { in HandleRTO()
277 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
282 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
287 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
292 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
298 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
303 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
306 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
311 cur_stream->id, cur_stream->snd_nxt, cur_stream->sndvar->snd_una); in HandleRTO()
315 TCPStateToString(cur_stream), cur_stream->sndvar->rto); in HandleRTO()
320 cur_stream->snd_nxt = cur_stream->sndvar->snd_una; in HandleRTO()
330 if (cur_stream->sndvar->fss == 0) { in HandleRTO()
334 if (TCP_SEQ_LT(cur_stream->snd_nxt, cur_stream->sndvar->fss)) { in HandleRTO()
336 if (cur_stream->sndvar->on_control_list) { in HandleRTO()
362 next = TAILQ_NEXT(walk, sndvar->timer_link); in RearrangeRTOStore()
364 int diff = (int32_t)(mtcp->rto_store->rto_now_ts - walk->sndvar->ts_rto); in RearrangeRTOStore()
370 walk, sndvar->timer_link); in RearrangeRTOStore()
373 walk, sndvar->timer_link); in RearrangeRTOStore()
407 next = TAILQ_NEXT(walk, sndvar->timer_link); in CheckRtmTimeout()
413 TAILQ_REMOVE(rto_list, walk, sndvar->timer_link); in CheckRtmTimeout()
454 next = TAILQ_NEXT(walk, sndvar->timer_link); in CheckTimewaitExpire()
467 if (!walk->sndvar->on_control_list) { in CheckTimewaitExpire()
469 TAILQ_REMOVE(&mtcp->timewait_list, walk, sndvar->timer_link); in CheckTimewaitExpire()
506 next = TAILQ_NEXT(walk, sndvar->timeout_link); in CheckConnectionTimeout()
516 TAILQ_REMOVE(&mtcp->timeout_list, walk, sndvar->timeout_link); in CheckConnectionTimeout()