aboutsummaryrefslogtreecommitdiffstats
path: root/net/rxrpc/ar-input.c
diff options
context:
space:
mode:
Diffstat (limited to 'net/rxrpc/ar-input.c')
-rw-r--r--net/rxrpc/ar-input.c14
1 files changed, 4 insertions, 10 deletions
diff --git a/net/rxrpc/ar-input.c b/net/rxrpc/ar-input.c
index 4824a827d10d..01e038146b7c 100644
--- a/net/rxrpc/ar-input.c
+++ b/net/rxrpc/ar-input.c
@@ -25,12 +25,6 @@
25#include <net/net_namespace.h> 25#include <net/net_namespace.h>
26#include "ar-internal.h" 26#include "ar-internal.h"
27 27
28const char *rxrpc_pkts[] = {
29 "?00",
30 "DATA", "ACK", "BUSY", "ABORT", "ACKALL", "CHALL", "RESP", "DEBUG",
31 "?09", "?10", "?11", "?12", "VERSION", "?14", "?15"
32};
33
34/* 28/*
35 * queue a packet for recvmsg to pass to userspace 29 * queue a packet for recvmsg to pass to userspace
36 * - the caller must hold a lock on call->lock 30 * - the caller must hold a lock on call->lock
@@ -199,7 +193,7 @@ static int rxrpc_fast_process_data(struct rxrpc_call *call,
199 193
200 /* if the packet need security things doing to it, then it goes down 194 /* if the packet need security things doing to it, then it goes down
201 * the slow path */ 195 * the slow path */
202 if (call->conn->security) 196 if (call->conn->security_ix)
203 goto enqueue_packet; 197 goto enqueue_packet;
204 198
205 sp->call = call; 199 sp->call = call;
@@ -355,7 +349,7 @@ void rxrpc_fast_process_packet(struct rxrpc_call *call, struct sk_buff *skb)
355 write_lock_bh(&call->state_lock); 349 write_lock_bh(&call->state_lock);
356 if (call->state < RXRPC_CALL_COMPLETE) { 350 if (call->state < RXRPC_CALL_COMPLETE) {
357 call->state = RXRPC_CALL_REMOTELY_ABORTED; 351 call->state = RXRPC_CALL_REMOTELY_ABORTED;
358 call->abort_code = abort_code; 352 call->remote_abort = abort_code;
359 set_bit(RXRPC_CALL_EV_RCVD_ABORT, &call->events); 353 set_bit(RXRPC_CALL_EV_RCVD_ABORT, &call->events);
360 rxrpc_queue_call(call); 354 rxrpc_queue_call(call);
361 } 355 }
@@ -428,7 +422,7 @@ protocol_error:
428protocol_error_locked: 422protocol_error_locked:
429 if (call->state <= RXRPC_CALL_COMPLETE) { 423 if (call->state <= RXRPC_CALL_COMPLETE) {
430 call->state = RXRPC_CALL_LOCALLY_ABORTED; 424 call->state = RXRPC_CALL_LOCALLY_ABORTED;
431 call->abort_code = RX_PROTOCOL_ERROR; 425 call->local_abort = RX_PROTOCOL_ERROR;
432 set_bit(RXRPC_CALL_EV_ABORT, &call->events); 426 set_bit(RXRPC_CALL_EV_ABORT, &call->events);
433 rxrpc_queue_call(call); 427 rxrpc_queue_call(call);
434 } 428 }
@@ -500,7 +494,7 @@ protocol_error:
500 write_lock_bh(&call->state_lock); 494 write_lock_bh(&call->state_lock);
501 if (call->state <= RXRPC_CALL_COMPLETE) { 495 if (call->state <= RXRPC_CALL_COMPLETE) {
502 call->state = RXRPC_CALL_LOCALLY_ABORTED; 496 call->state = RXRPC_CALL_LOCALLY_ABORTED;
503 call->abort_code = RX_PROTOCOL_ERROR; 497 call->local_abort = RX_PROTOCOL_ERROR;
504 set_bit(RXRPC_CALL_EV_ABORT, &call->events); 498 set_bit(RXRPC_CALL_EV_ABORT, &call->events);
505 rxrpc_queue_call(call); 499 rxrpc_queue_call(call);
506 } 500 }