Searched refs:ack_at (Results 1 - 10 of 10) sorted by relevance
/kernel/linux/linux-5.10/net/rxrpc/ |
H A D | call_event.c | 112 unsigned long now = jiffies, ack_at; in __rxrpc_propose_ACK() local 115 ack_at = usecs_to_jiffies(call->peer->srtt_us >> 3); 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, no in __rxrpc_propose_ACK() [all...] |
H A D | conn_event.c | 419 unsigned long ack_at; in rxrpc_process_delayed_final_acks() local 425 ack_at = READ_ONCE(chan->final_ack_at); in rxrpc_process_delayed_final_acks() 427 if (time_before(j, ack_at) && !force) { in rxrpc_process_delayed_final_acks() 428 if (time_before(ack_at, next_j)) { in rxrpc_process_delayed_final_acks() 429 next_j = ack_at; in rxrpc_process_delayed_final_acks()
|
H A D | call_object.c | 226 call->ack_at = j; in rxrpc_start_call_timer()
|
H A D | ar-internal.h | 553 unsigned long ack_at; /* When deferred ACK needs to happen */ member
|
H A D | sendmsg.c | 235 WRITE_ONCE(call->ack_at, now + MAX_JIFFY_OFFSET); in rxrpc_queue_packet()
|
H A D | input.c | 316 WRITE_ONCE(call->ack_at, timo); in rxrpc_receiving_reply()
|
/kernel/linux/linux-6.6/net/rxrpc/ |
H A D | call_event.c | 44 unsigned long now = jiffies, ack_at; in rxrpc_propose_delay_ACK() local 49 ack_at = usecs_to_jiffies(call->peer->srtt_us >> 3); in rxrpc_propose_delay_ACK() 51 ack_at = expiry; in rxrpc_propose_delay_ACK() 53 ack_at += READ_ONCE(call->tx_backoff); in rxrpc_propose_delay_ACK() 54 ack_at += now; in rxrpc_propose_delay_ACK() 55 if (time_before(ack_at, call->delay_ack_at)) { in rxrpc_propose_delay_ACK() 56 WRITE_ONCE(call->delay_ack_at, ack_at); in rxrpc_propose_delay_ACK() 57 rxrpc_reduce_call_timer(call, ack_at, now, in rxrpc_propose_delay_ACK()
|
H A D | conn_event.c | 302 unsigned long ack_at; in rxrpc_process_delayed_final_acks() local 307 ack_at = chan->final_ack_at; in rxrpc_process_delayed_final_acks() 308 if (time_before(j, ack_at) && !force) { in rxrpc_process_delayed_final_acks() 309 if (time_before(ack_at, next_j)) { in rxrpc_process_delayed_final_acks() 310 next_j = ack_at; in rxrpc_process_delayed_final_acks()
|
/kernel/linux/linux-6.6/include/trace/events/ |
H A D | rxrpc.h | 1324 __field(long, ack_at) 1338 __entry->ack_at = call->delay_ack_at; 1350 __entry->ack_at - __entry->now, 1367 __field(long, ack_at) 1380 __entry->ack_at = call->delay_ack_at; 1391 __entry->ack_at - __entry->now,
|
/kernel/linux/linux-5.10/include/trace/events/ |
H A D | rxrpc.h | 1154 __field(long, ack_at ) 1168 __entry->ack_at = call->ack_at; 1180 __entry->ack_at - __entry->now,
|
Completed in 12 milliseconds