Lines Matching refs:hc_entry
316 tcp_hc_cmp(struct hc_metrics *hc_entry, struct in_conninfo *inc) in tcp_hc_cmp() argument
321 if (memcmp(&inc->inc6_faddr, &hc_entry->ip6, in tcp_hc_cmp()
325 if (memcmp(&inc->inc_faddr, &hc_entry->ip4, in tcp_hc_cmp()
341 struct hc_metrics *hc_entry; in tcp_hc_lookup() local
351 CK_SLIST_FOREACH(hc_entry, &hc_head->hch_bucket, rmx_q) in tcp_hc_lookup()
352 if (tcp_hc_cmp(hc_entry, inc)) in tcp_hc_lookup()
355 if (hc_entry != NULL) { in tcp_hc_lookup()
356 if (atomic_load_int(&hc_entry->rmx_expire) != in tcp_hc_lookup()
358 atomic_store_int(&hc_entry->rmx_expire, in tcp_hc_lookup()
361 hc_entry->rmx_hits++; in tcp_hc_lookup()
366 return (hc_entry); in tcp_hc_lookup()
377 struct hc_metrics *hc_entry; in tcp_hc_get() local
387 hc_entry = tcp_hc_lookup(inc); in tcp_hc_get()
392 if (hc_entry == NULL) { in tcp_hc_get()
397 hc_metrics_lite->rmx_mtu = atomic_load_32(&hc_entry->rmx_mtu); in tcp_hc_get()
398 hc_metrics_lite->rmx_ssthresh = atomic_load_32(&hc_entry->rmx_ssthresh); in tcp_hc_get()
399 hc_metrics_lite->rmx_rtt = atomic_load_32(&hc_entry->rmx_rtt); in tcp_hc_get()
400 hc_metrics_lite->rmx_rttvar = atomic_load_32(&hc_entry->rmx_rttvar); in tcp_hc_get()
401 hc_metrics_lite->rmx_cwnd = atomic_load_32(&hc_entry->rmx_cwnd); in tcp_hc_get()
402 hc_metrics_lite->rmx_sendpipe = atomic_load_32(&hc_entry->rmx_sendpipe); in tcp_hc_get()
403 hc_metrics_lite->rmx_recvpipe = atomic_load_32(&hc_entry->rmx_recvpipe); in tcp_hc_get()
416 struct hc_metrics *hc_entry; in tcp_hc_getmtu() local
422 hc_entry = tcp_hc_lookup(inc); in tcp_hc_getmtu()
423 if (hc_entry == NULL) { in tcp_hc_getmtu()
427 mtu = atomic_load_32(&hc_entry->rmx_mtu); in tcp_hc_getmtu()
453 struct hc_metrics *hc_entry, *hc_prev; in tcp_hc_update() local
464 CK_SLIST_FOREACH(hc_entry, &hc_head->hch_bucket, rmx_q) { in tcp_hc_update()
465 if (tcp_hc_cmp(hc_entry, inc)) in tcp_hc_update()
467 if (CK_SLIST_NEXT(hc_entry, rmx_q) != NULL) in tcp_hc_update()
468 hc_prev = hc_entry; in tcp_hc_update()
471 if (hc_entry != NULL) { in tcp_hc_update()
472 if (atomic_load_int(&hc_entry->rmx_expire) != in tcp_hc_update()
474 atomic_store_int(&hc_entry->rmx_expire, in tcp_hc_update()
477 hc_entry->rmx_updates++; in tcp_hc_update()
495 hc_entry = CK_SLIST_NEXT(hc_prev, rmx_q); in tcp_hc_update()
496 KASSERT(CK_SLIST_NEXT(hc_entry, rmx_q) == NULL, in tcp_hc_update()
500 } else if ((hc_entry = in tcp_hc_update()
502 KASSERT(CK_SLIST_NEXT(hc_entry, rmx_q) == NULL, in tcp_hc_update()
504 __func__, hc_entry)); in tcp_hc_update()
518 uma_zfree_smr(V_tcp_hostcache.zone, hc_entry); in tcp_hc_update()
524 hc_entry = uma_zalloc_smr(V_tcp_hostcache.zone, M_NOWAIT); in tcp_hc_update()
525 if (hc_entry == NULL) { in tcp_hc_update()
533 bzero(hc_entry, sizeof(*hc_entry)); in tcp_hc_update()
535 hc_entry->ip6 = inc->inc6_faddr; in tcp_hc_update()
536 hc_entry->ip6_zoneid = inc->inc6_zoneid; in tcp_hc_update()
538 hc_entry->ip4 = inc->inc_faddr; in tcp_hc_update()
539 hc_entry->rmx_expire = V_tcp_hostcache.expire; in tcp_hc_update()
548 atomic_store_32(&hc_entry->rmx_mtu, hcml->rmx_mtu); in tcp_hc_update()
551 if (hc_entry->rmx_rtt == 0) in tcp_hc_update()
554 v = ((uint64_t)hc_entry->rmx_rtt + in tcp_hc_update()
556 atomic_store_32(&hc_entry->rmx_rtt, v); in tcp_hc_update()
560 if (hc_entry->rmx_rttvar == 0) in tcp_hc_update()
563 v = ((uint64_t)hc_entry->rmx_rttvar + in tcp_hc_update()
565 atomic_store_32(&hc_entry->rmx_rttvar, v); in tcp_hc_update()
569 if (hc_entry->rmx_ssthresh == 0) in tcp_hc_update()
572 v = (hc_entry->rmx_ssthresh + hcml->rmx_ssthresh) / 2; in tcp_hc_update()
573 atomic_store_32(&hc_entry->rmx_ssthresh, v); in tcp_hc_update()
577 if (hc_entry->rmx_cwnd == 0) in tcp_hc_update()
580 v = ((uint64_t)hc_entry->rmx_cwnd + in tcp_hc_update()
582 atomic_store_32(&hc_entry->rmx_cwnd, v); in tcp_hc_update()
586 if (hc_entry->rmx_sendpipe == 0) in tcp_hc_update()
589 v = ((uint64_t)hc_entry->rmx_sendpipe + in tcp_hc_update()
591 atomic_store_32(&hc_entry->rmx_sendpipe, v); in tcp_hc_update()
595 if (hc_entry->rmx_recvpipe == 0) in tcp_hc_update()
598 v = ((uint64_t)hc_entry->rmx_recvpipe + in tcp_hc_update()
600 atomic_store_32(&hc_entry->rmx_recvpipe, v); in tcp_hc_update()
608 CK_SLIST_INSERT_HEAD(&hc_head->hch_bucket, hc_entry, rmx_q); in tcp_hc_update()
614 } else if (hc_entry != CK_SLIST_FIRST(&hc_head->hch_bucket)) { in tcp_hc_update()
615 KASSERT(CK_SLIST_NEXT(hc_prev, rmx_q) == hc_entry, in tcp_hc_update()
616 ("%s: %p next is not %p", __func__, hc_prev, hc_entry)); in tcp_hc_update()
618 CK_SLIST_INSERT_HEAD(&hc_head->hch_bucket, hc_entry, rmx_q); in tcp_hc_update()
633 struct hc_metrics *hc_entry; in sysctl_tcp_hc_list() local
670 CK_SLIST_FOREACH(hc_entry, in sysctl_tcp_hc_list()
678 hc_entry->ip4.s_addr ? in sysctl_tcp_hc_list()
679 inet_ntoa_r(hc_entry->ip4, ip4buf) : in sysctl_tcp_hc_list()
681 ip6_sprintf(ip6buf, &hc_entry->ip6), in sysctl_tcp_hc_list()
685 hc_entry->rmx_mtu, in sysctl_tcp_hc_list()
686 hc_entry->rmx_ssthresh, in sysctl_tcp_hc_list()
687 msec((u_long)hc_entry->rmx_rtt * in sysctl_tcp_hc_list()
689 msec((u_long)hc_entry->rmx_rttvar * in sysctl_tcp_hc_list()
691 hc_entry->rmx_cwnd, in sysctl_tcp_hc_list()
692 hc_entry->rmx_sendpipe, in sysctl_tcp_hc_list()
693 hc_entry->rmx_recvpipe, in sysctl_tcp_hc_list()
695 hc_entry->rmx_hits, in sysctl_tcp_hc_list()
696 hc_entry->rmx_updates, in sysctl_tcp_hc_list()
698 hc_entry->rmx_expire); in sysctl_tcp_hc_list()
758 struct hc_metrics *hc_entry, *hc_next, *hc_prev; in tcp_hc_purge_internal() local
765 CK_SLIST_FOREACH_SAFE(hc_entry, &head->hch_bucket, rmx_q, in tcp_hc_purge_internal()
772 atomic_load_int(&hc_entry->rmx_expire) <= 0) { in tcp_hc_purge_internal()
774 KASSERT(hc_entry == in tcp_hc_purge_internal()
777 __func__, hc_entry, hc_prev)); in tcp_hc_purge_internal()
780 KASSERT(hc_entry == in tcp_hc_purge_internal()
783 __func__, hc_entry)); in tcp_hc_purge_internal()
787 uma_zfree_smr(V_tcp_hostcache.zone, hc_entry); in tcp_hc_purge_internal()
791 atomic_subtract_int(&hc_entry->rmx_expire, in tcp_hc_purge_internal()
793 hc_prev = hc_entry; in tcp_hc_purge_internal()