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: David Howells <dhowells@redhat.com>

7 files changed, 139 insertions, 91 deletions

diff --git a/fs/afs/fs_probe.c b/fs/afs/fs_probe.c
index 3a9eaec06756..5d3abde52a0f 100644
--- a/fs/afs/fs_probe.c
+++ b/fs/afs/fs_probe.c
@@ -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)
diff --git a/fs/afs/fsclient.c b/fs/afs/fsclient.c
index 0b37867b5c20..5eefcf35d73d 100644
--- a/fs/afs/fsclient.c
+++ b/fs/afs/fsclient.c
@@ -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_server *server,
-                            struct afs_addr_cursor *ac,
-                            struct key *key,
-                            unsigned int server_index,
-                            bool async)
+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)
 {
         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);
 }
diff --git a/fs/afs/internal.h b/fs/afs/internal.h
index 3904ab0b9563..61e24551574d 100644
--- a/fs/afs/internal.h
+++ b/fs/afs/internal.h
@@ -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 *);
 
 /*
diff --git a/fs/afs/rxrpc.c b/fs/afs/rxrpc.c
index 15c7e82d80cb..bc5aa590f348 100644
--- a/fs/afs/rxrpc.c
+++ b/fs/afs/rxrpc.c
@@ -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,10 +598,10 @@ 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,
-                                          struct afs_addr_cursor *ac)
+long afs_wait_for_call_to_complete(struct afs_call *call,
+                                   struct afs_addr_cursor *ac)
 {
         signed long rtt2, timeout;
         long ret;
@@ -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);
diff --git a/fs/afs/vl_probe.c b/fs/afs/vl_probe.c
index f402ee8171a1..b05e0de04f42 100644
--- a/fs/afs/vl_probe.c
+++ b/fs/afs/vl_probe.c
@@ -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)
diff --git a/fs/afs/vlclient.c b/fs/afs/vlclient.c
index c3d9e5a5f67e..e98ffe6df1c1 100644
--- a/fs/afs/vlclient.c
+++ b/fs/afs/vlclient.c
@@ -167,7 +167,8 @@ struct afs_vldb_entry *afs_vl_get_entry_by_name_u(struct afs_vl_cursor *vc,
                 memset((void *)bp + volnamesz, 0, padsz);
 
         trace_afs_make_vl_call(call);
-        return (struct afs_vldb_entry *)afs_make_call(&vc->ac, call, GFP_KERNEL, false);
+        afs_make_call(&vc->ac, call, GFP_KERNEL);
+        return (struct afs_vldb_entry *)afs_wait_for_call_to_complete(call, &vc->ac);
 }
 
 /*
@@ -304,7 +305,8 @@ struct afs_addr_list *afs_vl_get_addrs_u(struct afs_vl_cursor *vc,
                 r->uuid.node[i] = htonl(u->node[i]);
 
         trace_afs_make_vl_call(call);
-        return (struct afs_addr_list *)afs_make_call(&vc->ac, call, GFP_KERNEL, false);
+        afs_make_call(&vc->ac, call, GFP_KERNEL);
+        return (struct afs_addr_list *)afs_wait_for_call_to_complete(call, &vc->ac);
 }
 
 /*
@@ -378,12 +380,11 @@ static const struct afs_call_type afs_RXVLGetCapabilities = {
  * We use this to probe for service upgrade to determine what the server at the
  * other end supports.
  */
-int afs_vl_get_capabilities(struct afs_net *net,
-                            struct afs_addr_cursor *ac,
-                            struct key *key,
-                            struct afs_vlserver *server,
-                            unsigned int server_index,
-                            bool async)
+struct afs_call *afs_vl_get_capabilities(struct afs_net *net,
+                                         struct afs_addr_cursor *ac,
+                                         struct key *key,
+                                         struct afs_vlserver *server,
+                                         unsigned int server_index)
 {
         struct afs_call *call;
         __be32 *bp;
@@ -392,13 +393,14 @@ int afs_vl_get_capabilities(struct afs_net *net,
 
         call = afs_alloc_flat_call(net, &afs_RXVLGetCapabilities, 1 * 4, 16 * 4);
         if (!call)
-                return -ENOMEM;
+                return ERR_PTR(-ENOMEM);
 
         call->key = key;
         call->reply[0] = afs_get_vlserver(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;
@@ -406,7 +408,8 @@ int afs_vl_get_capabilities(struct afs_net *net,
 
         /* Can't take a ref on server */
         trace_afs_make_vl_call(call);
-        return afs_make_call(ac, call, GFP_KERNEL, async);
+        afs_make_call(ac, call, GFP_KERNEL);
+        return call;
 }
 
 /*
@@ -647,5 +650,6 @@ struct afs_addr_list *afs_yfsvl_get_endpoints(struct afs_vl_cursor *vc,
         memcpy(bp, uuid, sizeof(*uuid)); /* Type opr_uuid */
 
         trace_afs_make_vl_call(call);
-        return (struct afs_addr_list *)afs_make_call(&vc->ac, call, GFP_KERNEL, false);
+        afs_make_call(&vc->ac, call, GFP_KERNEL);
+        return (struct afs_addr_list *)afs_wait_for_call_to_complete(call, &vc->ac);
 }
diff --git a/fs/afs/yfsclient.c b/fs/afs/yfsclient.c
index 6e97a42d24d1..95b04cb76c8c 100644
--- a/fs/afs/yfsclient.c
+++ b/fs/afs/yfsclient.c
@@ -519,7 +519,8 @@ int yfs_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);
 }
 
 /*
@@ -708,7 +709,8 @@ int yfs_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);
 }
 
 /*
@@ -808,7 +810,8 @@ int yfs_fs_create_file(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);
 }
 
 static const struct afs_call_type yfs_RXFSMakeDir = {
@@ -871,7 +874,8 @@ int yfs_fs_make_dir(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);
 }
 
 /*
@@ -961,7 +965,8 @@ int yfs_fs_remove_file2(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);
 }
 
 /*
@@ -1048,7 +1053,8 @@ int yfs_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);
 }
 
 /*
@@ -1133,7 +1139,8 @@ int yfs_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);
 }
 
 /*
@@ -1229,7 +1236,8 @@ int yfs_fs_symlink(struct afs_fs_cursor *fc,
 
         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);
 }
 
 /*
@@ -1327,7 +1335,8 @@ int yfs_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);
 }
 
 /*
@@ -1433,7 +1442,8 @@ int yfs_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);
 }
 
 /*
@@ -1521,7 +1531,8 @@ static int yfs_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);
 }
 
 /*
@@ -1564,7 +1575,8 @@ int yfs_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);
 }
 
 /*
@@ -1751,7 +1763,8 @@ int yfs_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);
 }
 
 /*
@@ -1845,7 +1858,8 @@ int yfs_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);
 }
 
 /*
@@ -1880,7 +1894,8 @@ int yfs_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);
 }
 
 /*
@@ -1915,7 +1930,8 @@ int yfs_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);
 }
 
 /*
@@ -2003,7 +2019,8 @@ int yfs_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);
 }
 
 /*
@@ -2180,5 +2197,6 @@ int yfs_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);
 }