Commit 0b9bb322 authored by David Howells's avatar David Howells
Browse files

rxrpc: Split out the call state changing functions into their own file 



Split out the functions that change the state of an rxrpc call into their
own file.  The idea being to remove anything to do with changing the state
of a call directly from the rxrpc sendmsg() and recvmsg() paths and have
all that done in the I/O thread only, with the ultimate aim of removing the
state lock entirely.  Moving the code out of sendmsg.c and recvmsg.c makes
that easier to manage.

Signed-off-by: default avatarDavid Howells <dhowells@redhat.com>
cc: Marc Dionne <marc.dionne@auristor.com>
cc: linux-afs@lists.infradead.org
parent 1bab27af

net/rxrpc/Makefile

+1 −0
Original line number Diff line number Diff line
@@ -10,6 +10,7 @@ rxrpc-y := \ 
	call_accept.o \

	call_event.o \

	call_object.o \

	call_state.o \

	conn_client.o \

	conn_event.o \

	conn_object.o \

net/rxrpc/ar-internal.h

+18 −8
Original line number Diff line number Diff line
@@ -885,6 +885,24 @@ static inline bool rxrpc_is_client_call(const struct rxrpc_call *call) 
	return !rxrpc_is_service_call(call);

}



/*

 * call_state.c

 */

bool __rxrpc_set_call_completion(struct rxrpc_call *call,

				 enum rxrpc_call_completion compl,

				 u32 abort_code,

				 int error);

bool rxrpc_set_call_completion(struct rxrpc_call *call,

			       enum rxrpc_call_completion compl,

			       u32 abort_code,

			       int error);

bool __rxrpc_call_completed(struct rxrpc_call *call);

bool rxrpc_call_completed(struct rxrpc_call *call);

bool __rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,

			u32 abort_code, int error, enum rxrpc_abort_reason why);

bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,

		      u32 abort_code, int error, enum rxrpc_abort_reason why);



/*

 * conn_client.c

 */
@@ -1116,14 +1134,6 @@ extern const struct seq_operations rxrpc_local_seq_ops; 
 * recvmsg.c

 */

void rxrpc_notify_socket(struct rxrpc_call *);

bool __rxrpc_set_call_completion(struct rxrpc_call *, enum rxrpc_call_completion, u32, int);

bool rxrpc_set_call_completion(struct rxrpc_call *, enum rxrpc_call_completion, u32, int);

bool __rxrpc_call_completed(struct rxrpc_call *);

bool rxrpc_call_completed(struct rxrpc_call *);

bool __rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,

			u32 abort_code, int error, enum rxrpc_abort_reason why);

bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,

		      u32 abort_code, int error, enum rxrpc_abort_reason why);

int rxrpc_recvmsg(struct socket *, struct msghdr *, size_t, int);



/*

net/rxrpc/call_state.c

0 → 100644
+89 −0
Original line number Diff line number Diff line 
// SPDX-License-Identifier: GPL-2.0-or-later

/* Call state changing functions.

 *

 * Copyright (C) 2022 Red Hat, Inc. All Rights Reserved.

 * Written by David Howells (dhowells@redhat.com)

 */



#include "ar-internal.h"



/*

 * Transition a call to the complete state.

 */

bool __rxrpc_set_call_completion(struct rxrpc_call *call,

				 enum rxrpc_call_completion compl,

				 u32 abort_code,

				 int error)

{

	if (call->state < RXRPC_CALL_COMPLETE) {

		call->abort_code = abort_code;

		call->error = error;

		call->completion = compl;

		call->state = RXRPC_CALL_COMPLETE;

		trace_rxrpc_call_complete(call);

		wake_up(&call->waitq);

		rxrpc_notify_socket(call);

		return true;

	}

	return false;

}



bool rxrpc_set_call_completion(struct rxrpc_call *call,

			       enum rxrpc_call_completion compl,

			       u32 abort_code,

			       int error)

{

	bool ret = false;



	if (call->state < RXRPC_CALL_COMPLETE) {

		write_lock(&call->state_lock);

		ret = __rxrpc_set_call_completion(call, compl, abort_code, error);

		write_unlock(&call->state_lock);

	}

	return ret;

}



/*

 * Record that a call successfully completed.

 */

bool __rxrpc_call_completed(struct rxrpc_call *call)

{

	return __rxrpc_set_call_completion(call, RXRPC_CALL_SUCCEEDED, 0, 0);

}



bool rxrpc_call_completed(struct rxrpc_call *call)

{

	bool ret = false;



	if (call->state < RXRPC_CALL_COMPLETE) {

		write_lock(&call->state_lock);

		ret = __rxrpc_call_completed(call);

		write_unlock(&call->state_lock);

	}

	return ret;

}



/*

 * Record that a call is locally aborted.

 */

bool __rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,

			u32 abort_code, int error, enum rxrpc_abort_reason why)

{

	trace_rxrpc_abort(call->debug_id, why, call->cid, call->call_id, seq,

			  abort_code, error);

	return __rxrpc_set_call_completion(call, RXRPC_CALL_LOCALLY_ABORTED,

					   abort_code, error);

}



bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,

		      u32 abort_code, int error, enum rxrpc_abort_reason why)

{

	bool ret;



	write_lock(&call->state_lock);

	ret = __rxrpc_abort_call(call, seq, abort_code, error, why);

	write_unlock(&call->state_lock);

	if (ret && test_bit(RXRPC_CALL_EXPOSED, &call->flags))

		rxrpc_send_abort_packet(call);

	return ret;

}

net/rxrpc/recvmsg.c

+0 −81
Original line number Diff line number Diff line
@@ -58,87 +58,6 @@ void rxrpc_notify_socket(struct rxrpc_call *call) 
	_leave("");

}



/*

 * Transition a call to the complete state.

 */

bool __rxrpc_set_call_completion(struct rxrpc_call *call,

				 enum rxrpc_call_completion compl,

				 u32 abort_code,

				 int error)

{

	if (call->state < RXRPC_CALL_COMPLETE) {

		call->abort_code = abort_code;

		call->error = error;

		call->completion = compl;

		call->state = RXRPC_CALL_COMPLETE;

		trace_rxrpc_call_complete(call);

		wake_up(&call->waitq);

		rxrpc_notify_socket(call);

		return true;

	}

	return false;

}



bool rxrpc_set_call_completion(struct rxrpc_call *call,

			       enum rxrpc_call_completion compl,

			       u32 abort_code,

			       int error)

{

	bool ret = false;



	if (call->state < RXRPC_CALL_COMPLETE) {

		write_lock(&call->state_lock);

		ret = __rxrpc_set_call_completion(call, compl, abort_code, error);

		write_unlock(&call->state_lock);

	}

	return ret;

}



/*

 * Record that a call successfully completed.

 */

bool __rxrpc_call_completed(struct rxrpc_call *call)

{

	return __rxrpc_set_call_completion(call, RXRPC_CALL_SUCCEEDED, 0, 0);

}



bool rxrpc_call_completed(struct rxrpc_call *call)

{

	bool ret = false;



	if (call->state < RXRPC_CALL_COMPLETE) {

		write_lock(&call->state_lock);

		ret = __rxrpc_call_completed(call);

		write_unlock(&call->state_lock);

	}

	return ret;

}



/*

 * Record that a call is locally aborted.

 */

bool __rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,

			u32 abort_code, int error, enum rxrpc_abort_reason why)

{

	trace_rxrpc_abort(call->debug_id, why, call->cid, call->call_id, seq,

			  abort_code, error);

	return __rxrpc_set_call_completion(call, RXRPC_CALL_LOCALLY_ABORTED,

					   abort_code, error);

}



bool rxrpc_abort_call(struct rxrpc_call *call, rxrpc_seq_t seq,

		      u32 abort_code, int error, enum rxrpc_abort_reason why)

{

	bool ret;



	write_lock(&call->state_lock);

	ret = __rxrpc_abort_call(call, seq, abort_code, error, why);

	write_unlock(&call->state_lock);

	if (ret && test_bit(RXRPC_CALL_EXPOSED, &call->flags))

		rxrpc_send_abort_packet(call);

	return ret;

}



/*

 * Pass a call terminating message to userspace.

 */