Lines Matching full:cursor
246 u8 cursor) in rxrpc_peer_keepalive_dispatch() argument
271 cursor, peer->debug_id, slot, &peer->srx.transport); in rxrpc_peer_keepalive_dispatch()
283 slot += cursor; in rxrpc_peer_keepalive_dispatch()
307 u8 cursor, stop; in rxrpc_peer_keepalive_worker() local
312 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
313 _enter("%lld,%u", base - now, cursor); in rxrpc_peer_keepalive_worker()
321 * Everything in the bucket at the cursor is processed this in rxrpc_peer_keepalive_worker()
322 * second; the bucket at cursor + 1 goes at now + 1s and so in rxrpc_peer_keepalive_worker()
328 stop = cursor + ARRAY_SIZE(rxnet->peer_keepalive); in rxrpc_peer_keepalive_worker()
329 while (base <= now && (s8)(cursor - stop) < 0) { in rxrpc_peer_keepalive_worker()
330 list_splice_tail_init(&rxnet->peer_keepalive[cursor & mask], in rxrpc_peer_keepalive_worker()
333 cursor++; in rxrpc_peer_keepalive_worker()
340 rxnet->peer_keepalive_cursor = cursor; in rxrpc_peer_keepalive_worker()
341 rxrpc_peer_keepalive_dispatch(rxnet, &collector, base, cursor); in rxrpc_peer_keepalive_worker()
345 cursor = rxnet->peer_keepalive_cursor; in rxrpc_peer_keepalive_worker()
346 stop = cursor + RXRPC_KEEPALIVE_TIME - 1; in rxrpc_peer_keepalive_worker()
347 for (; (s8)(cursor - stop) < 0; cursor++) { in rxrpc_peer_keepalive_worker()
348 if (!list_empty(&rxnet->peer_keepalive[cursor & mask])) in rxrpc_peer_keepalive_worker()