diff options
| author | David Howells <dhowells@redhat.com> | 2016-10-06 09:11:50 +0200 |
|---|---|---|
| committer | David Howells <dhowells@redhat.com> | 2016-10-06 09:11:50 +0200 |
| commit | d7833d00915e1fb5743e94d3c207810b30e9fc38 (patch) | |
| tree | 5d0c5805693642c1fcaa1bc9e75e5182ed95cc50 /net | |
| parent | rxrpc: Partially handle OpenAFS's improper termination of calls (diff) | |
| download | linux-d7833d00915e1fb5743e94d3c207810b30e9fc38.tar.xz linux-d7833d00915e1fb5743e94d3c207810b30e9fc38.zip | |
rxrpc: Queue the call on expiry
When a call expires, it must be queued for the background processor to deal
with otherwise a service call that is improperly terminated will just sit
there awaiting an ACK and won't expire.
Signed-off-by: David Howells <dhowells@redhat.com>
Diffstat (limited to 'net')
| -rw-r--r-- | net/rxrpc/call_event.c | 10 |
1 files changed, 6 insertions, 4 deletions
diff --git a/net/rxrpc/call_event.c b/net/rxrpc/call_event.c index eeea9602cb89..e2a987fd31ce 100644 --- a/net/rxrpc/call_event.c +++ b/net/rxrpc/call_event.c @@ -35,8 +35,11 @@ void rxrpc_set_timer(struct rxrpc_call *call, enum rxrpc_timer_trace why, if (call->state < RXRPC_CALL_COMPLETE) { t = call->expire_at; - if (!ktime_after(t, now)) + if (!ktime_after(t, now)) { + trace_rxrpc_timer(call, why, now, now_j); + queue = true; goto out; + } if (!ktime_after(call->resend_at, now)) { call->resend_at = call->expire_at; @@ -76,12 +79,11 @@ void rxrpc_set_timer(struct rxrpc_call *call, enum rxrpc_timer_trace why, mod_timer(&call->timer, t_j); trace_rxrpc_timer(call, why, now, now_j); } - - if (queue) - rxrpc_queue_call(call); } out: + if (queue) + rxrpc_queue_call(call); read_unlock_bh(&call->state_lock); } |