Lines Matching refs:call
24 static void rxrpc_request_final_ACK(struct rxrpc_call *call)
26 /* the call may be aborted before we have a chance to ACK it */
27 write_lock(&call->state_lock);
29 switch (call->state) {
31 call->state = RXRPC_CALL_CLIENT_FINAL_ACK;
34 /* get an extra ref on the call for the final-ACK generator to
36 rxrpc_get_call(call);
37 set_bit(RXRPC_CALL_ACK_FINAL, &call->events);
38 if (try_to_del_timer_sync(&call->ack_timer) >= 0)
39 rxrpc_queue_call(call);
43 call->state = RXRPC_CALL_SERVER_ACK_REQUEST;
48 write_unlock(&call->state_lock);
52 * drop the bottom ACK off of the call ACK window and advance the window
54 static void rxrpc_hard_ACK_data(struct rxrpc_call *call,
60 spin_lock_bh(&call->lock);
65 call->ackr_window[loop] >>= 1;
66 call->ackr_window[loop] |=
67 call->ackr_window[loop + 1] << (BITS_PER_LONG - 1);
71 ASSERTCMP(seq, ==, call->rx_data_eaten + 1);
72 call->rx_data_eaten = seq;
74 if (call->ackr_win_top < UINT_MAX)
75 call->ackr_win_top++;
77 ASSERTIFCMP(call->state <= RXRPC_CALL_COMPLETE,
78 call->rx_data_post, >=, call->rx_data_recv);
79 ASSERTIFCMP(call->state <= RXRPC_CALL_COMPLETE,
80 call->rx_data_recv, >=, call->rx_data_eaten);
83 rxrpc_request_final_ACK(call);
84 } else if (atomic_dec_and_test(&call->ackr_not_idle) &&
85 test_and_clear_bit(RXRPC_CALL_TX_SOFT_ACK, &call->flags)) {
87 __rxrpc_propose_ACK(call, RXRPC_ACK_IDLE, sp->hdr.serial,
91 spin_unlock_bh(&call->lock);
96 * - advance the hard-ACK state of the parent call (done here in case something
103 struct rxrpc_call *call = sp->call;
105 _enter("%p{%p}", skb, call);
107 if (call) {
108 /* send the final ACK on a client call */
110 rxrpc_hard_ACK_data(call, sp);
111 rxrpc_put_call(call);
112 sp->call = NULL;