Lines Matching full:call
27 static void rxrpc_propose_ping(struct rxrpc_call *call, in rxrpc_propose_ping() argument
32 !test_and_set_bit(RXRPC_CALL_EV_PING, &call->events)) in rxrpc_propose_ping()
33 rxrpc_queue_call(call); in rxrpc_propose_ping()
38 if (time_before(ping_at, call->ping_at)) { in rxrpc_propose_ping()
39 WRITE_ONCE(call->ping_at, ping_at); in rxrpc_propose_ping()
40 rxrpc_reduce_call_timer(call, ping_at, now, in rxrpc_propose_ping()
49 static void __rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, in __rxrpc_propose_ACK() argument
62 rxrpc_propose_ping(call, immediate, background); in __rxrpc_propose_ACK()
71 call->ackr_reason, rxrpc_ack_priority[call->ackr_reason]); in __rxrpc_propose_ACK()
72 if (ack_reason == call->ackr_reason) { in __rxrpc_propose_ACK()
75 call->ackr_serial = serial; in __rxrpc_propose_ACK()
76 call->ackr_skew = skew; in __rxrpc_propose_ACK()
80 } else if (prior > rxrpc_ack_priority[call->ackr_reason]) { in __rxrpc_propose_ACK()
81 call->ackr_reason = ack_reason; in __rxrpc_propose_ACK()
82 call->ackr_serial = serial; in __rxrpc_propose_ACK()
83 call->ackr_skew = skew; in __rxrpc_propose_ACK()
111 if (test_bit(RXRPC_CALL_EV_ACK, &call->events)) { in __rxrpc_propose_ACK()
114 _debug("immediate ACK %lx", call->events); in __rxrpc_propose_ACK()
115 if (!test_and_set_bit(RXRPC_CALL_EV_ACK, &call->events) && in __rxrpc_propose_ACK()
117 rxrpc_queue_call(call); in __rxrpc_propose_ACK()
121 if (call->peer->rtt_usage > 0) in __rxrpc_propose_ACK()
122 ack_at = nsecs_to_jiffies(call->peer->rtt); in __rxrpc_propose_ACK()
126 ack_at += READ_ONCE(call->tx_backoff); in __rxrpc_propose_ACK()
128 if (time_before(ack_at, call->ack_at)) { in __rxrpc_propose_ACK()
129 WRITE_ONCE(call->ack_at, ack_at); in __rxrpc_propose_ACK()
130 rxrpc_reduce_call_timer(call, ack_at, now, in __rxrpc_propose_ACK()
136 trace_rxrpc_propose_ack(call, why, ack_reason, serial, immediate, in __rxrpc_propose_ACK()
141 * propose an ACK be sent, locking the call structure
143 void rxrpc_propose_ACK(struct rxrpc_call *call, u8 ack_reason, in rxrpc_propose_ACK() argument
147 spin_lock_bh(&call->lock); in rxrpc_propose_ACK()
148 __rxrpc_propose_ACK(call, ack_reason, skew, serial, in rxrpc_propose_ACK()
150 spin_unlock_bh(&call->lock); in rxrpc_propose_ACK()
156 static void rxrpc_congestion_timeout(struct rxrpc_call *call) in rxrpc_congestion_timeout() argument
158 set_bit(RXRPC_CALL_RETRANS_TIMEOUT, &call->flags); in rxrpc_congestion_timeout()
164 static void rxrpc_resend(struct rxrpc_call *call, unsigned long now_j) in rxrpc_resend() argument
173 _enter("{%d,%d}", call->tx_hard_ack, call->tx_top); in rxrpc_resend()
175 if (call->peer->rtt_usage > 1) in rxrpc_resend()
176 timeout = ns_to_ktime(call->peer->rtt * 3 / 2); in rxrpc_resend()
186 spin_lock_bh(&call->lock); in rxrpc_resend()
188 cursor = call->tx_hard_ack; in rxrpc_resend()
189 top = call->tx_top; in rxrpc_resend()
198 trace_rxrpc_resend(call, (cursor + 1) & RXRPC_RXTX_BUFF_MASK); in rxrpc_resend()
202 annotation = call->rxtx_annotations[ix]; in rxrpc_resend()
208 skb = call->rxtx_buffer[ix]; in rxrpc_resend()
222 call->rxtx_annotations[ix] = RXRPC_TX_ANNO_RETRANS | annotation; in rxrpc_resend()
224 trace_rxrpc_retransmit(call, seq, annotation | anno_type, in rxrpc_resend()
230 WRITE_ONCE(call->resend_at, resend_at); in rxrpc_resend()
233 rxrpc_congestion_timeout(call); in rxrpc_resend()
240 rxrpc_reduce_call_timer(call, resend_at, now_j, in rxrpc_resend()
242 spin_unlock_bh(&call->lock); in rxrpc_resend()
243 ack_ts = ktime_sub(now, call->acks_latest_ts); in rxrpc_resend()
244 if (ktime_to_ns(ack_ts) < call->peer->rtt) in rxrpc_resend()
246 rxrpc_propose_ACK(call, RXRPC_ACK_PING, 0, 0, true, false, in rxrpc_resend()
248 rxrpc_send_ack_packet(call, true, NULL); in rxrpc_resend()
259 annotation = call->rxtx_annotations[ix]; in rxrpc_resend()
264 skb = call->rxtx_buffer[ix]; in rxrpc_resend()
266 spin_unlock_bh(&call->lock); in rxrpc_resend()
268 if (rxrpc_send_data_packet(call, skb, true) < 0) { in rxrpc_resend()
273 if (rxrpc_is_client_call(call)) in rxrpc_resend()
274 rxrpc_expose_client_call(call); in rxrpc_resend()
277 spin_lock_bh(&call->lock); in rxrpc_resend()
284 if (after(seq, call->tx_hard_ack)) { in rxrpc_resend()
285 annotation = call->rxtx_annotations[ix]; in rxrpc_resend()
293 call->rxtx_annotations[ix] = annotation; in rxrpc_resend()
296 if (after(call->tx_hard_ack, seq)) in rxrpc_resend()
297 seq = call->tx_hard_ack; in rxrpc_resend()
301 spin_unlock_bh(&call->lock); in rxrpc_resend()
311 struct rxrpc_call *call = in rxrpc_process_call() local
317 rxrpc_see_call(call); in rxrpc_process_call()
321 call->debug_id, rxrpc_call_states[call->state], call->events); in rxrpc_process_call()
329 if (test_and_clear_bit(RXRPC_CALL_EV_ABORT, &call->events)) { in rxrpc_process_call()
330 rxrpc_send_abort_packet(call); in rxrpc_process_call()
334 if (call->state == RXRPC_CALL_COMPLETE) { in rxrpc_process_call()
335 del_timer_sync(&call->timer); in rxrpc_process_call()
336 rxrpc_notify_socket(call); in rxrpc_process_call()
342 t = READ_ONCE(call->expect_rx_by); in rxrpc_process_call()
344 trace_rxrpc_timer(call, rxrpc_timer_exp_normal, now); in rxrpc_process_call()
345 set_bit(RXRPC_CALL_EV_EXPIRED, &call->events); in rxrpc_process_call()
348 t = READ_ONCE(call->expect_req_by); in rxrpc_process_call()
349 if (call->state == RXRPC_CALL_SERVER_RECV_REQUEST && in rxrpc_process_call()
351 trace_rxrpc_timer(call, rxrpc_timer_exp_idle, now); in rxrpc_process_call()
352 set_bit(RXRPC_CALL_EV_EXPIRED, &call->events); in rxrpc_process_call()
355 t = READ_ONCE(call->expect_term_by); in rxrpc_process_call()
357 trace_rxrpc_timer(call, rxrpc_timer_exp_hard, now); in rxrpc_process_call()
358 set_bit(RXRPC_CALL_EV_EXPIRED, &call->events); in rxrpc_process_call()
361 t = READ_ONCE(call->ack_at); in rxrpc_process_call()
363 trace_rxrpc_timer(call, rxrpc_timer_exp_ack, now); in rxrpc_process_call()
364 cmpxchg(&call->ack_at, t, now + MAX_JIFFY_OFFSET); in rxrpc_process_call()
365 set_bit(RXRPC_CALL_EV_ACK, &call->events); in rxrpc_process_call()
368 t = READ_ONCE(call->ack_lost_at); in rxrpc_process_call()
370 trace_rxrpc_timer(call, rxrpc_timer_exp_lost_ack, now); in rxrpc_process_call()
371 cmpxchg(&call->ack_lost_at, t, now + MAX_JIFFY_OFFSET); in rxrpc_process_call()
372 set_bit(RXRPC_CALL_EV_ACK_LOST, &call->events); in rxrpc_process_call()
375 t = READ_ONCE(call->keepalive_at); in rxrpc_process_call()
377 trace_rxrpc_timer(call, rxrpc_timer_exp_keepalive, now); in rxrpc_process_call()
378 cmpxchg(&call->keepalive_at, t, now + MAX_JIFFY_OFFSET); in rxrpc_process_call()
379 rxrpc_propose_ACK(call, RXRPC_ACK_PING, 0, 0, true, true, in rxrpc_process_call()
381 set_bit(RXRPC_CALL_EV_PING, &call->events); in rxrpc_process_call()
384 t = READ_ONCE(call->ping_at); in rxrpc_process_call()
386 trace_rxrpc_timer(call, rxrpc_timer_exp_ping, now); in rxrpc_process_call()
387 cmpxchg(&call->ping_at, t, now + MAX_JIFFY_OFFSET); in rxrpc_process_call()
388 set_bit(RXRPC_CALL_EV_PING, &call->events); in rxrpc_process_call()
391 t = READ_ONCE(call->resend_at); in rxrpc_process_call()
393 trace_rxrpc_timer(call, rxrpc_timer_exp_resend, now); in rxrpc_process_call()
394 cmpxchg(&call->resend_at, t, now + MAX_JIFFY_OFFSET); in rxrpc_process_call()
395 set_bit(RXRPC_CALL_EV_RESEND, &call->events); in rxrpc_process_call()
399 if (test_and_clear_bit(RXRPC_CALL_EV_EXPIRED, &call->events)) { in rxrpc_process_call()
400 if (test_bit(RXRPC_CALL_RX_HEARD, &call->flags) && in rxrpc_process_call()
401 (int)call->conn->hi_serial - (int)call->rx_serial > 0) { in rxrpc_process_call()
402 trace_rxrpc_call_reset(call); in rxrpc_process_call()
403 rxrpc_abort_call("EXP", call, 0, RX_USER_ABORT, -ECONNRESET); in rxrpc_process_call()
405 rxrpc_abort_call("EXP", call, 0, RX_USER_ABORT, -ETIME); in rxrpc_process_call()
407 set_bit(RXRPC_CALL_EV_ABORT, &call->events); in rxrpc_process_call()
412 if (test_and_clear_bit(RXRPC_CALL_EV_ACK_LOST, &call->events)) { in rxrpc_process_call()
413 call->acks_lost_top = call->tx_top; in rxrpc_process_call()
414 rxrpc_propose_ACK(call, RXRPC_ACK_PING, 0, 0, true, false, in rxrpc_process_call()
416 send_ack = &call->acks_lost_ping; in rxrpc_process_call()
419 if (test_and_clear_bit(RXRPC_CALL_EV_ACK, &call->events) || in rxrpc_process_call()
421 if (call->ackr_reason) { in rxrpc_process_call()
422 rxrpc_send_ack_packet(call, false, send_ack); in rxrpc_process_call()
427 if (test_and_clear_bit(RXRPC_CALL_EV_PING, &call->events)) { in rxrpc_process_call()
428 rxrpc_send_ack_packet(call, true, NULL); in rxrpc_process_call()
432 if (test_and_clear_bit(RXRPC_CALL_EV_RESEND, &call->events)) { in rxrpc_process_call()
433 rxrpc_resend(call, now); in rxrpc_process_call()
438 next = call->expect_rx_by; in rxrpc_process_call()
442 set(call->expect_req_by); in rxrpc_process_call()
443 set(call->expect_term_by); in rxrpc_process_call()
444 set(call->ack_at); in rxrpc_process_call()
445 set(call->ack_lost_at); in rxrpc_process_call()
446 set(call->resend_at); in rxrpc_process_call()
447 set(call->keepalive_at); in rxrpc_process_call()
448 set(call->ping_at); in rxrpc_process_call()
454 rxrpc_reduce_call_timer(call, next, now, rxrpc_timer_restart); in rxrpc_process_call()
457 if (call->events && call->state < RXRPC_CALL_COMPLETE) in rxrpc_process_call()
461 rxrpc_put_call(call, rxrpc_call_put); in rxrpc_process_call()
467 __rxrpc_queue_call(call); in rxrpc_process_call()