Lines Matching refs:walk
356 tcp_stream *walk, *next; in RearrangeRTOStore() local
360 for (walk = TAILQ_FIRST(rto_list); in RearrangeRTOStore()
361 walk != NULL; walk = next) { in RearrangeRTOStore()
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()
371 walk->on_rto_idx = offset; in RearrangeRTOStore()
373 walk, sndvar->timer_link); in RearrangeRTOStore()
383 tcp_stream *walk, *next; in CheckRtmTimeout() local
402 for (walk = TAILQ_FIRST(rto_list); in CheckRtmTimeout()
403 walk != NULL; walk = next) { in CheckRtmTimeout()
407 next = TAILQ_NEXT(walk, sndvar->timer_link); in CheckRtmTimeout()
410 cnt, walk->s_id); in CheckRtmTimeout()
412 if (walk->on_rto_idx >= 0) { in CheckRtmTimeout()
413 TAILQ_REMOVE(rto_list, walk, sndvar->timer_link); in CheckRtmTimeout()
415 walk->on_rto_idx = -1; in CheckRtmTimeout()
416 HandleRTO(mtcp, cur_ts, walk); in CheckRtmTimeout()
418 TRACE_ERROR("Stream %d: not on rto list.\n", walk->id); in CheckRtmTimeout()
420 DumpStream(mtcp, walk); in CheckRtmTimeout()
443 tcp_stream *walk, *next; in CheckTimewaitExpire() local
450 for (walk = TAILQ_FIRST(&mtcp->timewait_list); in CheckTimewaitExpire()
451 walk != NULL; walk = next) { in CheckTimewaitExpire()
454 next = TAILQ_NEXT(walk, sndvar->timer_link); in CheckTimewaitExpire()
457 cnt, walk->s_id); in CheckTimewaitExpire()
459 if (walk->on_timewait_list) { in CheckTimewaitExpire()
461 if ((walk->pair_stream != NULL) in CheckTimewaitExpire()
462 && (walk->pair_stream->state != TCP_ST_CLOSED_RSVD) in CheckTimewaitExpire()
463 && (walk->pair_stream->state != TCP_ST_TIME_WAIT)) in CheckTimewaitExpire()
466 if ((int32_t)(cur_ts - walk->rcvvar->ts_tw_expire) >= 0) { in CheckTimewaitExpire()
467 if (!walk->sndvar->on_control_list) { in CheckTimewaitExpire()
469 TAILQ_REMOVE(&mtcp->timewait_list, walk, sndvar->timer_link); in CheckTimewaitExpire()
470 walk->on_timewait_list = FALSE; in CheckTimewaitExpire()
473 walk->state = TCP_ST_CLOSED_RSVD; in CheckTimewaitExpire()
474 walk->close_reason = TCP_ACTIVE_CLOSE; in CheckTimewaitExpire()
475 walk->cb_events |= MOS_ON_TCP_STATE_CHANGE; in CheckTimewaitExpire()
476 TRACE_STATE("Stream %d: TCP_ST_CLOSED_RSVD\n", walk->id); in CheckTimewaitExpire()
477 DestroyTCPStream(mtcp, walk); in CheckTimewaitExpire()
483 TRACE_ERROR("Stream %d: not on timewait list.\n", walk->id); in CheckTimewaitExpire()
485 DumpStream(mtcp, walk); in CheckTimewaitExpire()
496 tcp_stream *walk, *next; in CheckConnectionTimeout() local
502 for (walk = TAILQ_FIRST(&mtcp->timeout_list); in CheckConnectionTimeout()
503 walk != NULL; walk = next) { in CheckConnectionTimeout()
506 next = TAILQ_NEXT(walk, sndvar->timeout_link); in CheckConnectionTimeout()
508 if ((int32_t)(cur_ts - walk->last_active_ts) >= in CheckConnectionTimeout()
512 TCPStateToString(walk), in CheckConnectionTimeout()
513 TCPStateToString(walk->pair_stream)); in CheckConnectionTimeout()
515 walk->on_timeout_list = FALSE; in CheckConnectionTimeout()
516 TAILQ_REMOVE(&mtcp->timeout_list, walk, sndvar->timeout_link); in CheckConnectionTimeout()
518 walk->state = TCP_ST_CLOSED_RSVD; in CheckConnectionTimeout()
519 walk->close_reason = TCP_TIMEDOUT; in CheckConnectionTimeout()
520 walk->cb_events |= MOS_ON_TCP_STATE_CHANGE; in CheckConnectionTimeout()
521 if (walk->socket && HAS_STREAM_TYPE(walk, MOS_SOCK_STREAM)) { in CheckConnectionTimeout()
522 RaiseErrorEvent(mtcp, walk); in CheckConnectionTimeout()
524 DestroyTCPStream(mtcp, walk); in CheckConnectionTimeout()
538 struct timer *walk; in RegTimer() local
540 TAILQ_FOREACH_REVERSE(walk, &mtcp->timer_list, timer_head, timer_link) { in RegTimer()
541 if (TIMEVAL_LT(&walk->exp, &timer->exp)) { in RegTimer()
542 TAILQ_INSERT_AFTER(&mtcp->timer_list, walk, timer, timer_link); in RegTimer()
547 assert(!walk); in RegTimer()