Lines Matching refs:rto_store

35 		mtcp->rto_store->rto_now_idx = 0;  in AddtoRTOList()
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()
53 int offset= ((diff + mtcp->rto_store->rto_now_idx) & (RTO_HASH - 1)); in AddtoRTOList()
55 TAILQ_INSERT_TAIL(&(mtcp->rto_store->rto_list[offset]), in AddtoRTOList()
61 TAILQ_INSERT_TAIL(&(mtcp->rto_store->rto_list[RTO_HASH]), in AddtoRTOList()
77 TAILQ_REMOVE(&mtcp->rto_store->rto_list[cur_stream->on_rto_idx], in RemoveFromRTOList()
357 struct rto_head* rto_list = &mtcp->rto_store->rto_list[RTO_HASH]; in RearrangeRTOStore()
364 int diff = (int32_t)(mtcp->rto_store->rto_now_ts - walk->sndvar->ts_rto); in RearrangeRTOStore()
367 int offset = ((diff + mtcp->rto_store->rto_now_idx) & (RTO_HASH - 1)); in RearrangeRTOStore()
368 if (!TAILQ_EMPTY(&mtcp->rto_store->rto_list[RTO_HASH])) { in RearrangeRTOStore()
369 TAILQ_REMOVE(&mtcp->rto_store->rto_list[RTO_HASH], in RearrangeRTOStore()
372 TAILQ_INSERT_TAIL(&(mtcp->rto_store->rto_list[offset]), in RearrangeRTOStore()
397 rto_list = &mtcp->rto_store->rto_list[mtcp->rto_store->rto_now_idx]; in CheckRtmTimeout()
398 if ((int32_t)(cur_ts - mtcp->rto_store->rto_now_ts) < 0) { in CheckRtmTimeout()
428 mtcp->rto_store->rto_now_idx = ((mtcp->rto_store->rto_now_idx + 1) & (RTO_HASH - 1)); in CheckRtmTimeout()
429 mtcp->rto_store->rto_now_ts++; in CheckRtmTimeout()
430 if (!((mtcp->rto_store->rto_now_idx & (1024 - 1)))) { in CheckRtmTimeout()