Lines Matching refs:rxnet
302 static void rxrpc_peer_keepalive_dispatch(struct rxrpc_net *rxnet, in rxrpc_peer_keepalive_dispatch() argument
308 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_dispatch()
312 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
323 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
342 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
344 &rxnet->peer_keepalive[slot & mask]); in rxrpc_peer_keepalive_dispatch()
350 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_dispatch()
358 struct rxrpc_net *rxnet = in rxrpc_peer_keepalive_worker() local
360 const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1; in rxrpc_peer_keepalive_worker()
366 base = rxnet->peer_keepalive_base; in rxrpc_peer_keepalive_worker()
367 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
370 if (!rxnet->live) in rxrpc_peer_keepalive_worker()
380 spin_lock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_worker()
381 list_splice_init(&rxnet->peer_keepalive_new, &collector); in rxrpc_peer_keepalive_worker()
383 stop = cursor + ARRAY_SIZE(rxnet->peer_keepalive); in rxrpc_peer_keepalive_worker()
385 list_splice_tail_init(&rxnet->peer_keepalive[cursor & mask], in rxrpc_peer_keepalive_worker()
392 spin_unlock_bh(&rxnet->peer_hash_lock); in rxrpc_peer_keepalive_worker()
394 rxnet->peer_keepalive_base = base; in rxrpc_peer_keepalive_worker()
395 rxnet->peer_keepalive_cursor = cursor; in rxrpc_peer_keepalive_worker()
396 rxrpc_peer_keepalive_dispatch(rxnet, &collector, base, cursor); in rxrpc_peer_keepalive_worker()
400 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
403 if (!list_empty(&rxnet->peer_keepalive[cursor & mask])) in rxrpc_peer_keepalive_worker()
413 if (rxnet->live) in rxrpc_peer_keepalive_worker()
414 timer_reduce(&rxnet->peer_keepalive_timer, jiffies + delay); in rxrpc_peer_keepalive_worker()