Lines Matching refs:cursor

309 	u8 cursor = peer->rtt_cursor, usage = peer->rtt_usage;  in rxrpc_peer_add_rtt()  local
318 sum -= peer->rtt_cache[cursor]; in rxrpc_peer_add_rtt()
320 peer->rtt_cache[cursor] = rtt; in rxrpc_peer_add_rtt()
321 peer->rtt_cursor = (cursor + 1) & (RXRPC_RTT_CACHE_SIZE - 1); in rxrpc_peer_add_rtt()
350 u8 cursor) in rxrpc_peer_keepalive_dispatch() argument
372 cursor, peer->debug_id, slot, &peer->srx.transport); in rxrpc_peer_keepalive_dispatch()
383 slot += cursor; in rxrpc_peer_keepalive_dispatch()
403 u8 cursor, stop; in rxrpc_peer_keepalive_worker() local
408 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
409 _enter("%lld,%u", base - now, cursor); in rxrpc_peer_keepalive_worker()
424 stop = cursor + ARRAY_SIZE(rxnet->peer_keepalive); in rxrpc_peer_keepalive_worker()
425 while (base <= now && (s8)(cursor - stop) < 0) { in rxrpc_peer_keepalive_worker()
426 list_splice_tail_init(&rxnet->peer_keepalive[cursor & mask], in rxrpc_peer_keepalive_worker()
429 cursor++; in rxrpc_peer_keepalive_worker()
436 rxnet->peer_keepalive_cursor = cursor; in rxrpc_peer_keepalive_worker()
437 rxrpc_peer_keepalive_dispatch(rxnet, &collector, base, cursor); in rxrpc_peer_keepalive_worker()
441 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
442 stop = cursor + RXRPC_KEEPALIVE_TIME - 1; in rxrpc_peer_keepalive_worker()
443 for (; (s8)(cursor - stop) < 0; cursor++) { in rxrpc_peer_keepalive_worker()
444 if (!list_empty(&rxnet->peer_keepalive[cursor & mask])) in rxrpc_peer_keepalive_worker()