diff options
| author | David Howells <dhowells@redhat.com> | 2016-09-24 20:05:27 +0300 |
|---|---|---|
| committer | David Howells <dhowells@redhat.com> | 2016-09-25 01:49:46 +0300 |
| commit | dd7c1ee59a90ca8a75bce72c721851d5550f3c59 (patch) | |
| tree | 434537911ce88bd06b644980151336a78aa9e3df /net/rxrpc/input.c | |
| parent | b69d94d7991f83928d3ea18fe12ab011fa852bb0 (diff) | |
| download | linux-dd7c1ee59a90ca8a75bce72c721851d5550f3c59.tar.xz | |
rxrpc: Reinitialise the call ACK and timer state for client reply phase
Clear the ACK reason, ACK timer and resend timer when entering the client
reply phase when the first DATA packet is received. New ACKs will be
proposed once the data is queued.
The resend timer is no longer relevant and we need to cancel ACKs scheduled
to probe for a lost reply.
Signed-off-by: David Howells <dhowells@redhat.com>
Diffstat (limited to 'net/rxrpc/input.c')
| -rw-r--r-- | net/rxrpc/input.c | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/net/rxrpc/input.c b/net/rxrpc/input.c index 757c16f033a0..bda11eb2ab2a 100644 --- a/net/rxrpc/input.c +++ b/net/rxrpc/input.c @@ -149,6 +149,15 @@ static bool rxrpc_receiving_reply(struct rxrpc_call *call) { rxrpc_seq_t top = READ_ONCE(call->tx_top); + if (call->ackr_reason) { + spin_lock_bh(&call->lock); + call->ackr_reason = 0; + call->resend_at = call->expire_at; + call->ack_at = call->expire_at; + spin_unlock_bh(&call->lock); + rxrpc_set_timer(call, rxrpc_timer_init_for_reply); + } + if (!test_bit(RXRPC_CALL_TX_LAST, &call->flags)) rxrpc_rotate_tx_window(call, top); if (!test_bit(RXRPC_CALL_TX_LAST, &call->flags)) { |