337 static void rxrpc_peer_keepalive_dispatch(struct rxrpc_net *rxnet,  in rxrpc_peer_keepalive_dispatch()  argument
343 	const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1;  in rxrpc_peer_keepalive_dispatch()
347 	spin_lock_bh(&rxnet->peer_hash_lock);  in rxrpc_peer_keepalive_dispatch()
357 		spin_unlock_bh(&rxnet->peer_hash_lock);  in rxrpc_peer_keepalive_dispatch()
375 		spin_lock_bh(&rxnet->peer_hash_lock);  in rxrpc_peer_keepalive_dispatch()
377 			      &rxnet->peer_keepalive[slot & mask]);  in rxrpc_peer_keepalive_dispatch()
381 	spin_unlock_bh(&rxnet->peer_hash_lock);  in rxrpc_peer_keepalive_dispatch()
389 	struct rxrpc_net *rxnet =  in rxrpc_peer_keepalive_worker()  local
391 	const u8 mask = ARRAY_SIZE(rxnet->peer_keepalive) - 1;  in rxrpc_peer_keepalive_worker()
397 	base = rxnet->peer_keepalive_base;  in rxrpc_peer_keepalive_worker()
398 	cursor = rxnet->peer_keepalive_cursor;  in rxrpc_peer_keepalive_worker()
401 	if (!rxnet->live)  in rxrpc_peer_keepalive_worker()
411 	spin_lock_bh(&rxnet->peer_hash_lock);  in rxrpc_peer_keepalive_worker()
412 	list_splice_init(&rxnet->peer_keepalive_new, &collector);  in rxrpc_peer_keepalive_worker()
414 	stop = cursor + ARRAY_SIZE(rxnet->peer_keepalive);  in rxrpc_peer_keepalive_worker()
416 		list_splice_tail_init(&rxnet->peer_keepalive[cursor & mask],  in rxrpc_peer_keepalive_worker()
423 	spin_unlock_bh(&rxnet->peer_hash_lock);  in rxrpc_peer_keepalive_worker()
425 	rxnet->peer_keepalive_base = base;  in rxrpc_peer_keepalive_worker()
426 	rxnet->peer_keepalive_cursor = cursor;  in rxrpc_peer_keepalive_worker()
427 	rxrpc_peer_keepalive_dispatch(rxnet, &collector, base, cursor);  in rxrpc_peer_keepalive_worker()
431 	cursor = rxnet->peer_keepalive_cursor;  in rxrpc_peer_keepalive_worker()
434 		if (!list_empty(&rxnet->peer_keepalive[cursor & mask]))  in rxrpc_peer_keepalive_worker()
444 	if (rxnet->live)  in rxrpc_peer_keepalive_worker()
445 		timer_reduce(&rxnet->peer_keepalive_timer, jiffies + delay);  in rxrpc_peer_keepalive_worker()