Home
last modified time | relevance | path

Searched refs:ack_at (Results 1 – 6 of 6) sorted by relevance

/net/rxrpc/
Dcall_event.c112 unsigned long now = jiffies, ack_at; in __rxrpc_propose_ACK() local
115 ack_at = nsecs_to_jiffies(call->peer->rtt); in __rxrpc_propose_ACK()
117 ack_at = expiry; in __rxrpc_propose_ACK()
119 ack_at += READ_ONCE(call->tx_backoff); in __rxrpc_propose_ACK()
120 ack_at += now; in __rxrpc_propose_ACK()
121 if (time_before(ack_at, call->ack_at)) { in __rxrpc_propose_ACK()
122 WRITE_ONCE(call->ack_at, ack_at); in __rxrpc_propose_ACK()
123 rxrpc_reduce_call_timer(call, ack_at, now, in __rxrpc_propose_ACK()
354 t = READ_ONCE(call->ack_at); in rxrpc_process_call()
357 cmpxchg(&call->ack_at, t, now + MAX_JIFFY_OFFSET); in rxrpc_process_call()
[all …]
Dconn_event.c410 unsigned long ack_at; in rxrpc_process_delayed_final_acks() local
416 ack_at = READ_ONCE(chan->final_ack_at); in rxrpc_process_delayed_final_acks()
418 if (time_before(j, ack_at)) { in rxrpc_process_delayed_final_acks()
419 if (time_before(ack_at, next_j)) { in rxrpc_process_delayed_final_acks()
420 next_j = ack_at; in rxrpc_process_delayed_final_acks()
Dcall_object.c201 call->ack_at = j; in rxrpc_start_call_timer()
Dsendmsg.c200 WRITE_ONCE(call->ack_at, now + MAX_JIFFY_OFFSET); in rxrpc_queue_packet()
Dar-internal.h562 unsigned long ack_at; /* When deferred ACK needs to happen */ member
Dinput.c317 WRITE_ONCE(call->ack_at, timo); in rxrpc_receiving_reply()