Lines Matching refs:rxnet

521 static void rxrpc_peer_keepalive_dispatch(struct rxrpc_net *rxnet,  in rxrpc_peer_keepalive_dispatch()  argument
527 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_dispatch()
531 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
542 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
561 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
563 &rxnet->peer_keepalive[slot & mask]); in rxrpc_peer_keepalive_dispatch()
569 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
577 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_worker() local
579 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_worker()
585 base = rxnet->peer_keepalive_base; in rxrpc_peer_keepalive_worker()
586 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
589 if (!rxnet->live) in rxrpc_peer_keepalive_worker()
599 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_worker()
600 list_splice_init(&rxnet->peer_keepalive_new, &collector); in rxrpc_peer_keepalive_worker()
602 stop = cursor + ARRAY_SIZE(rxnet->peer_keepalive); in rxrpc_peer_keepalive_worker()
604 list_splice_tail_init(&rxnet->peer_keepalive[cursor & mask], in rxrpc_peer_keepalive_worker()
611 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_worker()
613 rxnet->peer_keepalive_base = base; in rxrpc_peer_keepalive_worker()
614 rxnet->peer_keepalive_cursor = cursor; in rxrpc_peer_keepalive_worker()
615 rxrpc_peer_keepalive_dispatch(rxnet, &collector, base, cursor); in rxrpc_peer_keepalive_worker()
619 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
622 if (!list_empty(&rxnet->peer_keepalive[cursor & mask])) in rxrpc_peer_keepalive_worker()
632 if (rxnet->live) in rxrpc_peer_keepalive_worker()
633 timer_reduce(&rxnet->peer_keepalive_timer, jiffies + delay); in rxrpc_peer_keepalive_worker()