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

afs: Split wait from afs_make_call() 



Split the call to afs_wait_for_call_to_complete() from afs_make_call() to
make it easier to handle asynchronous calls and to make it easier to
convert a synchronous call to an asynchronous one in future, for instance
when someone tries to interrupt an operation by pressing Ctrl-C.

Signed-off-by: default avatarDavid Howells <dhowells@redhat.com>
parent cd8dead0

fs/afs/fs_probe.c

+7 −6
Original line number Diff line number Diff line
@@ -141,8 +141,8 @@ static int afs_do_probe_fileserver(struct afs_net *net, 
	struct afs_addr_cursor ac = {

		.index = 0,

	};

	struct afs_call *call;

	bool in_progress = false;

	int err;



	_enter("%pU", &server->uuid);
@@ -156,12 +156,13 @@ static int afs_do_probe_fileserver(struct afs_net *net, 
	server->probe.rtt = UINT_MAX;



	for (ac.index = 0; ac.index < ac.alist->nr_addrs; ac.index++) {

		err = afs_fs_get_capabilities(net, server, &ac, key, server_index,

					      true);

		if (err == -EINPROGRESS)

		call = afs_fs_get_capabilities(net, server, &ac, key, server_index);

		if (!IS_ERR(call)) {

			afs_put_call(call);

			in_progress = true;

		else

			afs_prioritise_error(_e, err, ac.abort_code);

		} else {

			afs_prioritise_error(_e, PTR_ERR(call), ac.abort_code);

		}

	}



	if (!in_progress)

fs/afs/fsclient.c

+50 −28
Original line number Diff line number Diff line
@@ -468,7 +468,9 @@ int afs_fs_fetch_file_status(struct afs_fs_cursor *fc, struct afs_volsync *volsy 
	call->cb_break = fc->cb_break;

	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);



	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -660,7 +662,8 @@ static int afs_fs_fetch_data64(struct afs_fs_cursor *fc, struct afs_read *req) 
	call->cb_break = fc->cb_break;

	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -707,7 +710,8 @@ int afs_fs_fetch_data(struct afs_fs_cursor *fc, struct afs_read *req) 
	call->cb_break = fc->cb_break;

	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -827,7 +831,8 @@ int afs_fs_create(struct afs_fs_cursor *fc, 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -922,7 +927,8 @@ int afs_fs_remove(struct afs_fs_cursor *fc, struct afs_vnode *vnode, 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &dvnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1014,7 +1020,8 @@ int afs_fs_link(struct afs_fs_cursor *fc, struct afs_vnode *vnode, 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1128,7 +1135,8 @@ int afs_fs_symlink(struct afs_fs_cursor *fc, 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1246,7 +1254,8 @@ int afs_fs_rename(struct afs_fs_cursor *fc, 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &orig_dvnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1350,7 +1359,8 @@ static int afs_fs_store_data64(struct afs_fs_cursor *fc, 
	*bp++ = htonl((u32) i_size);



	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1426,7 +1436,8 @@ int afs_fs_store_data(struct afs_fs_cursor *fc, struct address_space *mapping, 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1524,7 +1535,8 @@ static int afs_fs_setattr_size64(struct afs_fs_cursor *fc, struct iattr *attr) 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1570,7 +1582,8 @@ static int afs_fs_setattr_size(struct afs_fs_cursor *fc, struct iattr *attr) 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1614,7 +1627,8 @@ int afs_fs_setattr(struct afs_fs_cursor *fc, struct iattr *attr) 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1798,7 +1812,8 @@ int afs_fs_get_volume_status(struct afs_fs_cursor *fc, 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1885,7 +1900,8 @@ int afs_fs_set_lock(struct afs_fs_cursor *fc, afs_lock_type_t type) 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1919,7 +1935,8 @@ int afs_fs_extend_lock(struct afs_fs_cursor *fc) 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1953,7 +1970,8 @@ int afs_fs_release_lock(struct afs_fs_cursor *fc) 


	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &vnode->fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -1998,7 +2016,8 @@ int afs_fs_give_up_all_callbacks(struct afs_net *net, 
	*bp++ = htonl(FSGIVEUPALLCALLBACKS);



	/* Can't take a ref on server */

	return afs_make_call(ac, call, GFP_NOFS, false);

	afs_make_call(ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, ac);

}



/*
@@ -2068,12 +2087,11 @@ static const struct afs_call_type afs_RXFSGetCapabilities = { 
 * Probe a fileserver for the capabilities that it supports.  This can

 * return up to 196 words.

 */

int afs_fs_get_capabilities(struct afs_net *net,

struct afs_call *afs_fs_get_capabilities(struct afs_net *net,

					 struct afs_server *server,

					 struct afs_addr_cursor *ac,

					 struct key *key,

			    unsigned int server_index,

			    bool async)

					 unsigned int server_index)

{

	struct afs_call *call;

	__be32 *bp;
@@ -2082,13 +2100,14 @@ int afs_fs_get_capabilities(struct afs_net *net, 


	call = afs_alloc_flat_call(net, &afs_RXFSGetCapabilities, 1 * 4, 16 * 4);

	if (!call)

		return -ENOMEM;

		return ERR_PTR(-ENOMEM);



	call->key = key;

	call->reply[0] = afs_get_server(server);

	call->reply[1] = (void *)(long)server_index;

	call->upgrade = true;

	call->want_reply_time = true;

	call->async = true;



	/* marshall the parameters */

	bp = call->request;
@@ -2096,7 +2115,8 @@ int afs_fs_get_capabilities(struct afs_net *net, 


	/* Can't take a ref on server */

	trace_afs_make_fs_call(call, NULL);

	return afs_make_call(ac, call, GFP_NOFS, async);

	afs_make_call(ac, call, GFP_NOFS);

	return call;

}



/*
@@ -2183,7 +2203,8 @@ int afs_fs_fetch_status(struct afs_fs_cursor *fc, 
	call->cb_break = fc->cb_break;

	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, fid);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}



/*
@@ -2363,5 +2384,6 @@ int afs_fs_inline_bulk_status(struct afs_fs_cursor *fc, 
	call->cb_break = fc->cb_break;

	afs_use_fs_server(call, fc->cbi);

	trace_afs_make_fs_call(call, &fids[0]);

	return afs_make_call(&fc->ac, call, GFP_NOFS, false);

	afs_make_call(&fc->ac, call, GFP_NOFS);

	return afs_wait_for_call_to_complete(call, &fc->ac);

}

fs/afs/internal.h

+7 −5
Original line number Diff line number Diff line
@@ -939,8 +939,9 @@ extern int afs_fs_extend_lock(struct afs_fs_cursor *); 
extern int afs_fs_release_lock(struct afs_fs_cursor *);

extern int afs_fs_give_up_all_callbacks(struct afs_net *, struct afs_server *,

					struct afs_addr_cursor *, struct key *);

extern int afs_fs_get_capabilities(struct afs_net *, struct afs_server *,

				   struct afs_addr_cursor *, struct key *, unsigned int, bool);

extern struct afs_call *afs_fs_get_capabilities(struct afs_net *, struct afs_server *,

						struct afs_addr_cursor *, struct key *,

						unsigned int);

extern int afs_fs_inline_bulk_status(struct afs_fs_cursor *, struct afs_net *,

				     struct afs_fid *, struct afs_file_status *,

				     struct afs_callback *, unsigned int,
@@ -1073,7 +1074,8 @@ extern int __net_init afs_open_socket(struct afs_net *); 
extern void __net_exit afs_close_socket(struct afs_net *);

extern void afs_charge_preallocation(struct work_struct *);

extern void afs_put_call(struct afs_call *);

extern long afs_make_call(struct afs_addr_cursor *, struct afs_call *, gfp_t, bool);

extern void afs_make_call(struct afs_addr_cursor *, struct afs_call *, gfp_t);

extern long afs_wait_for_call_to_complete(struct afs_call *, struct afs_addr_cursor *);

extern struct afs_call *afs_alloc_flat_call(struct afs_net *,

					    const struct afs_call_type *,

					    size_t, size_t);
@@ -1218,8 +1220,8 @@ extern void afs_fs_exit(void); 
extern struct afs_vldb_entry *afs_vl_get_entry_by_name_u(struct afs_vl_cursor *,

							 const char *, int);

extern struct afs_addr_list *afs_vl_get_addrs_u(struct afs_vl_cursor *, const uuid_t *);

extern int afs_vl_get_capabilities(struct afs_net *, struct afs_addr_cursor *, struct key *,

				   struct afs_vlserver *, unsigned int, bool);

extern struct afs_call *afs_vl_get_capabilities(struct afs_net *, struct afs_addr_cursor *,

						struct key *, struct afs_vlserver *, unsigned int);

extern struct afs_addr_list *afs_yfsvl_get_endpoints(struct afs_vl_cursor *, const uuid_t *);



/*

fs/afs/rxrpc.c

+16 −17
Original line number Diff line number Diff line
@@ -21,7 +21,6 @@ 
struct workqueue_struct *afs_async_calls;



static void afs_wake_up_call_waiter(struct sock *, struct rxrpc_call *, unsigned long);

static long afs_wait_for_call_to_complete(struct afs_call *, struct afs_addr_cursor *);

static void afs_wake_up_async_call(struct sock *, struct rxrpc_call *, unsigned long);

static void afs_delete_async_call(struct work_struct *);

static void afs_process_async_call(struct work_struct *);
@@ -361,10 +360,10 @@ static int afs_send_pages(struct afs_call *call, struct msghdr *msg) 
}



/*

 * initiate a call

 * Initiate a call and synchronously queue up the parameters for dispatch.  Any

 * error is stored into the call struct, which the caller must check for.

 */

long afs_make_call(struct afs_addr_cursor *ac, struct afs_call *call,

		   gfp_t gfp, bool async)

void afs_make_call(struct afs_addr_cursor *ac, struct afs_call *call, gfp_t gfp)

{

	struct sockaddr_rxrpc *srx = &ac->alist->addrs[ac->index];

	struct rxrpc_call *rxcall;
@@ -382,7 +381,6 @@ long afs_make_call(struct afs_addr_cursor *ac, struct afs_call *call, 
	       call, call->type->name, key_serial(call->key),

	       atomic_read(&call->net->nr_outstanding_calls));



	call->async = async;

	call->addr_ix = ac->index;

	call->alist = afs_get_addrlist(ac->alist);
@@ -415,7 +413,7 @@ long afs_make_call(struct afs_addr_cursor *ac, struct afs_call *call, 
	rxcall = rxrpc_kernel_begin_call(call->net->socket, srx, call->key,

					 (unsigned long)call,

					 tx_total_len, gfp,

					 (async ?

					 (call->async ?

					  afs_wake_up_async_call :

					  afs_wake_up_call_waiter),

					 call->upgrade,
@@ -453,13 +451,11 @@ long afs_make_call(struct afs_addr_cursor *ac, struct afs_call *call, 


	/* Note that at this point, we may have received the reply or an abort

	 * - and an asynchronous call may already have completed.

	 *

	 * afs_wait_for_call_to_complete(call, ac)

	 * must be called to synchronously clean up.

	 */

	if (call->async) {

		afs_put_call(call);

		return -EINPROGRESS;

	}



	return afs_wait_for_call_to_complete(call, ac);

	return;



error_do_abort:

	if (ret != -ECONNABORTED) {
@@ -495,9 +491,7 @@ error_kill_call: 


	ac->error = ret;

	call->state = AFS_CALL_COMPLETE;

	afs_put_call(call);

	_leave(" = %d", ret);

	return ret;

}



/*
@@ -604,9 +598,9 @@ call_complete: 
}



/*

 * wait synchronously for a call to complete

 * Wait synchronously for a call to complete and clean up the call struct.

 */

static long afs_wait_for_call_to_complete(struct afs_call *call,

long afs_wait_for_call_to_complete(struct afs_call *call,

				   struct afs_addr_cursor *ac)

{

	signed long rtt2, timeout;
@@ -620,6 +614,10 @@ static long afs_wait_for_call_to_complete(struct afs_call *call, 


	_enter("");



	ret = call->error;

	if (ret < 0)

		goto out;



	rtt = rxrpc_kernel_get_rtt(call->net->socket, call->rxcall);

	rtt2 = nsecs_to_jiffies64(rtt) * 2;

	if (rtt2 < 2)
@@ -703,6 +701,7 @@ static long afs_wait_for_call_to_complete(struct afs_call *call, 
		break;

	}



out:

	_debug("call complete");

	afs_put_call(call);

	_leave(" = %p", (void *)ret);

fs/afs/vl_probe.c

+8 −6
Original line number Diff line number Diff line
@@ -141,8 +141,8 @@ static bool afs_do_probe_vlserver(struct afs_net *net, 
	struct afs_addr_cursor ac = {

		.index = 0,

	};

	struct afs_call *call;

	bool in_progress = false;

	int err;



	_enter("%s", server->name);
@@ -156,12 +156,14 @@ static bool afs_do_probe_vlserver(struct afs_net *net, 
	server->probe.rtt = UINT_MAX;



	for (ac.index = 0; ac.index < ac.alist->nr_addrs; ac.index++) {

		err = afs_vl_get_capabilities(net, &ac, key, server,

					      server_index, true);

		if (err == -EINPROGRESS)

		call = afs_vl_get_capabilities(net, &ac, key, server,

					       server_index);

		if (!IS_ERR(call)) {

			afs_put_call(call);

			in_progress = true;

		else

			afs_prioritise_error(_e, err, ac.abort_code);

		} else {

			afs_prioritise_error(_e, PTR_ERR(call), ac.abort_code);

		}

	}



	if (!in_progress)

CRA Git | Maintained and supported by SUSTech CRA and CCSE