Remove most static variables in the NFS server functions.
[bluesky.git] / nfs3 / nfs3.c
index 0ba7f56..3f858ac 100644 (file)
@@ -9,9 +9,6 @@
 
 extern BlueSkyFS *fs;
 
-static int null_int;
-static void *null_result = (void *)&null_int;
-
 /* Check that a string is a valid file name.  We require that it be valid
  * UTF-8, that it not be empty, and that it not contain embedded forward
  * slashes.  Also checks that the length of the string is not more than the
@@ -139,16 +136,15 @@ void encode_pre_wcc(struct wcc_data *wcc, BlueSkyInode *inode)
     wcc->before.pre_op_attr_u.attributes.ctime.nseconds = (inode->ctime % 1000000) * 1000;
 }
 
-void *
-nfsproc3_null_3_svc(void *argp, struct svc_req *rqstp)
+void nfsproc3_null_3_svc(void *argp, RPCRequest *req)
 {
-    return null_result;
+    async_rpc_send_reply(req, NULL);
 }
 
-getattr3res *
-nfsproc3_getattr_3_svc(nfs_fh3 *argp, struct svc_req *rqstp)
+void nfsproc3_getattr_3_svc(nfs_fh3 *argp, RPCRequest *req)
 {
-    static getattr3res result;
+    getattr3res result;
+    memset(&result, 0, sizeof(result));
 
     BlueSkyInode *inode = lookup_fh(argp);
     if (inode != NULL) {
@@ -158,20 +154,21 @@ nfsproc3_getattr_3_svc(nfs_fh3 *argp, struct svc_req *rqstp)
         result.status = NFS3ERR_STALE;
     }
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-wccstat3 *
-nfsproc3_setattr_3_svc(setattr3args *argp, struct svc_req *rqstp)
+void nfsproc3_setattr_3_svc(setattr3args *argp, RPCRequest *req)
 {
-    static wccstat3 result;
+    wccstat3 result;
+    memset(&result, 0, sizeof(result));
 
     result.wccstat3_u.wcc.before.present = FALSE;
     result.wccstat3_u.wcc.after.present = FALSE;
     BlueSkyInode *inode = lookup_fh(&argp->object);
     if (inode == NULL) {
         result.status = NFS3ERR_STALE;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     encode_pre_wcc(&result.wccstat3_u.wcc, inode);
@@ -180,7 +177,8 @@ nfsproc3_setattr_3_svc(setattr3args *argp, struct svc_req *rqstp)
             result.status = NFS3ERR_NOT_SYNC;
             result.wccstat3_u.wcc.after.present = TRUE;
             encode_fattr3(&result.wccstat3_u.wcc.after.post_op_attr_u.attributes, inode);
-            return &result;
+            async_rpc_send_reply(req, &result);
+            return;
         }
     }
 
@@ -191,19 +189,20 @@ nfsproc3_setattr_3_svc(setattr3args *argp, struct svc_req *rqstp)
                   inode);
     result.status = NFS3_OK;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-lookup3res *
-nfsproc3_lookup_3_svc(diropargs3 *argp, struct svc_req *rqstp)
+void nfsproc3_lookup_3_svc(diropargs3 *argp, RPCRequest *req)
 {
-    static lookup3res result;
+    lookup3res result;
+    memset(&result, 0, sizeof(result));
 
     BlueSkyInode *dir = lookup_fh(&argp->dir);
     if (dir == NULL) {
         result.status = NFS3ERR_STALE;
         result.lookup3res_u.resfail.present = FALSE;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     result.lookup3res_u.resfail.present = TRUE;
@@ -213,19 +212,22 @@ nfsproc3_lookup_3_svc(diropargs3 *argp, struct svc_req *rqstp)
             result.status = NFS3ERR_NAMETOOLONG;
         else
             result.status = NFS3ERR_NOENT;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     /* TODO: Special-case "." and "..". */
     uint64_t inum = bluesky_directory_lookup(dir, argp->name);
     if (inum == 0) {
         result.status = NFS3ERR_NOENT;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
     BlueSkyInode *inode = bluesky_get_inode(fs, inum);
     if (inode == NULL) {
         result.status = NFS3ERR_NOENT;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     result.status = NFS3_OK;
@@ -234,24 +236,25 @@ nfsproc3_lookup_3_svc(diropargs3 *argp, struct svc_req *rqstp)
     result.lookup3res_u.resok.obj_attributes.present = TRUE;
     encode_fattr3(&result.lookup3res_u.resok.obj_attributes.post_op_attr_u.attributes, inode);
 
-    static uint64_t fh_bytes;
+    uint64_t fh_bytes;
     fh_bytes = GUINT64_TO_BE(inum);
     result.lookup3res_u.resok.object.data.data_len = 8;
     result.lookup3res_u.resok.object.data.data_val = (char *)&fh_bytes;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-access3res *
-nfsproc3_access_3_svc(access3args *argp, struct svc_req *rqstp)
+void nfsproc3_access_3_svc(access3args *argp, RPCRequest *req)
 {
-    static access3res result;
+    access3res result;
+    memset(&result, 0, sizeof(result));
 
     BlueSkyInode *inode = lookup_fh(&argp->object);
     if (inode == NULL) {
         result.status = NFS3ERR_STALE;
         result.access3res_u.resfail.present = FALSE;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     result.status = NFS3_OK;
@@ -259,13 +262,12 @@ nfsproc3_access_3_svc(access3args *argp, struct svc_req *rqstp)
     encode_fattr3(&result.access3res_u.resok.obj_attributes.post_op_attr_u.attributes, inode);
     result.access3res_u.resok.access = argp->access;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-readlink3res *
-nfsproc3_readlink_3_svc(nfs_fh3 *argp, struct svc_req *rqstp)
+void nfsproc3_readlink_3_svc(nfs_fh3 *argp, RPCRequest *req)
 {
-    static readlink3res result;
+    readlink3res result;
     memset(&result, 0, sizeof(result));
 
     BlueSkyInode *inode = lookup_fh(argp);
@@ -284,20 +286,21 @@ nfsproc3_readlink_3_svc(nfs_fh3 *argp, struct svc_req *rqstp)
         result.status = NFS3ERR_STALE;
     }
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-read3res *
-nfsproc3_read_3_svc(read3args *argp, struct svc_req *rqstp)
+void nfsproc3_read_3_svc(read3args *argp, RPCRequest *req)
 {
-    static read3res result;
-    static char buf[32768];
+    read3res result;
+    memset(&result, 0, sizeof(result));
+    char buf[32768];
 
     BlueSkyInode *inode = lookup_fh(&argp->file);
     if (inode == NULL) {
         result.status = NFS3ERR_STALE;
         result.read3res_u.resfail.present = FALSE;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     int count = argp->count;
@@ -321,13 +324,13 @@ nfsproc3_read_3_svc(read3args *argp, struct svc_req *rqstp)
     result.read3res_u.resok.data.data_val = buf;
     result.read3res_u.resok.data.data_len = count;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-write3res *
-nfsproc3_write_3_svc(write3args *argp, struct svc_req *rqstp)
+void nfsproc3_write_3_svc(write3args *argp, RPCRequest *req)
 {
-    static write3res result;
+    write3res result;
+    memset(&result, 0, sizeof(result));
     struct wcc_data wcc;
     memset(&wcc, 0, sizeof(wcc));
 
@@ -335,14 +338,16 @@ nfsproc3_write_3_svc(write3args *argp, struct svc_req *rqstp)
     if (inode == NULL) {
         result.status = NFS3ERR_STALE;
         result.write3res_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     encode_pre_wcc(&wcc, inode);
     if (inode->type != BLUESKY_REGULAR) {
         result.status = NFS3ERR_INVAL;
         result.write3res_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     uint64_t lastbyte = argp->offset + argp->count;
@@ -363,13 +368,13 @@ nfsproc3_write_3_svc(write3args *argp, struct svc_req *rqstp)
     result.write3res_u.resok.count = argp->count;
     result.write3res_u.resok.committed = FILE_SYNC;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-diropres3 *
-nfsproc3_create_3_svc(create3args *argp, struct svc_req *rqstp)
+void nfsproc3_create_3_svc(create3args *argp, RPCRequest *req)
 {
-    static diropres3 result;
+    diropres3 result;
+    memset(&result, 0, sizeof(result));
     struct wcc_data wcc;
     memset(&wcc, 0, sizeof(wcc));
 
@@ -377,14 +382,16 @@ nfsproc3_create_3_svc(create3args *argp, struct svc_req *rqstp)
     if (dir == NULL) {
         result.status = NFS3ERR_STALE;
         result.diropres3_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     encode_pre_wcc(&wcc, dir);
     if (dir->type != BLUESKY_DIRECTORY) {
         result.status = NFS3ERR_NOTDIR;
         result.diropres3_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     if (!validate_filename(argp->where.name)
@@ -393,7 +400,8 @@ nfsproc3_create_3_svc(create3args *argp, struct svc_req *rqstp)
     {
         result.status = NFS3ERR_EXIST;
         result.diropres3_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     BlueSkyInode *file;
@@ -418,19 +426,19 @@ nfsproc3_create_3_svc(create3args *argp, struct svc_req *rqstp)
     encode_fattr3(&result.diropres3_u.resok.obj_attributes.post_op_attr_u.attributes, file);
     result.diropres3_u.resok.dir_wcc = wcc;
 
-    static uint64_t fh_bytes;
+    uint64_t fh_bytes;
     fh_bytes = GUINT64_TO_BE(file->inum);
     result.diropres3_u.resok.obj.present = TRUE;
     result.diropres3_u.resok.obj.post_op_fh3_u.handle.data.data_len = 8;
     result.diropres3_u.resok.obj.post_op_fh3_u.handle.data.data_val = (char *)&fh_bytes;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-diropres3 *
-nfsproc3_mkdir_3_svc(mkdir3args *argp, struct svc_req *rqstp)
+void nfsproc3_mkdir_3_svc(mkdir3args *argp, RPCRequest *req)
 {
-    static diropres3 result;
+    diropres3 result;
+    memset(&result, 0, sizeof(result));
     struct wcc_data wcc;
     memset(&wcc, 0, sizeof(wcc));
 
@@ -438,14 +446,16 @@ nfsproc3_mkdir_3_svc(mkdir3args *argp, struct svc_req *rqstp)
     if (dir == NULL) {
         result.status = NFS3ERR_STALE;
         result.diropres3_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     encode_pre_wcc(&wcc, dir);
     if (dir->type != BLUESKY_DIRECTORY) {
         result.status = NFS3ERR_NOTDIR;
         result.diropres3_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     if (!validate_filename(argp->where.name)
@@ -454,7 +464,8 @@ nfsproc3_mkdir_3_svc(mkdir3args *argp, struct svc_req *rqstp)
     {
         result.status = NFS3ERR_EXIST;
         result.diropres3_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     BlueSkyInode *file;
@@ -479,19 +490,19 @@ nfsproc3_mkdir_3_svc(mkdir3args *argp, struct svc_req *rqstp)
     encode_fattr3(&result.diropres3_u.resok.obj_attributes.post_op_attr_u.attributes, file);
     result.diropres3_u.resok.dir_wcc = wcc;
 
-    static uint64_t fh_bytes;
+    uint64_t fh_bytes;
     fh_bytes = GUINT64_TO_BE(file->inum);
     result.diropres3_u.resok.obj.present = TRUE;
     result.diropres3_u.resok.obj.post_op_fh3_u.handle.data.data_len = 8;
     result.diropres3_u.resok.obj.post_op_fh3_u.handle.data.data_val = (char *)&fh_bytes;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-diropres3 *
-nfsproc3_symlink_3_svc(symlink3args *argp, struct svc_req *rqstp)
+void nfsproc3_symlink_3_svc(symlink3args *argp, RPCRequest *req)
 {
-    static diropres3 result;
+    diropres3 result;
+    memset(&result, 0, sizeof(result));
     struct wcc_data wcc;
     memset(&wcc, 0, sizeof(wcc));
 
@@ -499,14 +510,16 @@ nfsproc3_symlink_3_svc(symlink3args *argp, struct svc_req *rqstp)
     if (dir == NULL) {
         result.status = NFS3ERR_STALE;
         result.diropres3_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     encode_pre_wcc(&wcc, dir);
     if (dir->type != BLUESKY_DIRECTORY) {
         result.status = NFS3ERR_NOTDIR;
         result.diropres3_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     if (!validate_filename(argp->where.name)
@@ -515,7 +528,8 @@ nfsproc3_symlink_3_svc(symlink3args *argp, struct svc_req *rqstp)
     {
         result.status = NFS3ERR_EXIST;
         result.diropres3_u.resfail = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     BlueSkyInode *file;
@@ -540,37 +554,35 @@ nfsproc3_symlink_3_svc(symlink3args *argp, struct svc_req *rqstp)
     encode_fattr3(&result.diropres3_u.resok.obj_attributes.post_op_attr_u.attributes, file);
     result.diropres3_u.resok.dir_wcc = wcc;
 
-    static uint64_t fh_bytes;
+    uint64_t fh_bytes;
     fh_bytes = GUINT64_TO_BE(file->inum);
     result.diropres3_u.resok.obj.present = TRUE;
     result.diropres3_u.resok.obj.post_op_fh3_u.handle.data.data_len = 8;
     result.diropres3_u.resok.obj.post_op_fh3_u.handle.data.data_val = (char *)&fh_bytes;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-diropres3 *
-nfsproc3_mknod_3_svc(mknod3args *argp, struct svc_req *rqstp)
+void nfsproc3_mknod_3_svc(mknod3args *argp, RPCRequest *req)
 {
-    static diropres3 result;
+    diropres3 result;
+    memset(&result, 0, sizeof(result));
 
     result.status = NFS3ERR_NOTSUPP;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-wccstat3 *
-nfsproc3_remove_3_svc(diropargs3 *argp, struct svc_req *rqstp)
+void nfsproc3_remove_3_svc(diropargs3 *argp, RPCRequest *req)
 {
-    static wccstat3 result;
-
-    result.wccstat3_u.wcc.before.present = FALSE;
-    result.wccstat3_u.wcc.after.present = FALSE;
+    wccstat3 result;
+    memset(&result, 0, sizeof(result));
 
     BlueSkyInode *dir = lookup_fh(&argp->dir);
     if (dir == NULL) {
         result.status = NFS3ERR_STALE;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     encode_pre_wcc(&result.wccstat3_u.wcc, dir);
@@ -580,7 +592,8 @@ nfsproc3_remove_3_svc(diropargs3 *argp, struct svc_req *rqstp)
         || strcmp(argp->name, "..") == 0)
     {
         result.status = NFS3ERR_NOENT;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     /* TODO: Decrement link count, deallocate inode if needed. */
@@ -592,39 +605,85 @@ nfsproc3_remove_3_svc(diropargs3 *argp, struct svc_req *rqstp)
     encode_fattr3(&result.wccstat3_u.wcc.after.post_op_attr_u.attributes,
                   dir);
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-wccstat3 *
-nfsproc3_rmdir_3_svc(diropargs3 *argp, struct svc_req *rqstp)
+void nfsproc3_rmdir_3_svc(diropargs3 *argp, RPCRequest *req)
 {
-    static wccstat3 result;
+    wccstat3 result;
+    memset(&result, 0, sizeof(result));
 
-    result.status = NFS3ERR_NOTSUPP;
+    BlueSkyInode *dir = lookup_fh(&argp->dir);
+    if (dir == NULL) {
+        result.status = NFS3ERR_STALE;
+        async_rpc_send_reply(req, &result);
+        return;
+    }
+
+    encode_pre_wcc(&result.wccstat3_u.wcc, dir);
+
+    if (!validate_filename(argp->name)
+        || strcmp(argp->name, ".") == 0
+        || strcmp(argp->name, "..") == 0)
+    {
+        result.status = NFS3ERR_NOENT;
+        async_rpc_send_reply(req, &result);
+        return;
+    }
 
-    return &result;
+    uint64_t inum = bluesky_directory_lookup(dir, argp->name);
+    BlueSkyInode *inode = bluesky_get_inode(fs, inum);
+    if (inode == NULL) {
+        result.status = NFS3ERR_NOENT;
+        async_rpc_send_reply(req, &result);
+        return;
+    }
+
+    if (inode->type != BLUESKY_DIRECTORY) {
+        result.status = NFS3ERR_NOTDIR;
+        async_rpc_send_reply(req, &result);
+        return;
+    }
+    if (g_sequence_get_length(inode->dirents) > 0) {
+        printf("Directory not empty: %d entries\n",
+               g_sequence_get_length(inode->dirents));
+        result.status = NFS3ERR_NOTEMPTY;
+        async_rpc_send_reply(req, &result);
+        return;
+    }
+
+    /* TODO: Decrement link count, deallocate inode if needed. */
+
+    bluesky_directory_remove(dir, argp->name);
+
+    result.status = NFS3_OK;
+    result.wccstat3_u.wcc.after.present = TRUE;
+    encode_fattr3(&result.wccstat3_u.wcc.after.post_op_attr_u.attributes,
+                  dir);
+
+    async_rpc_send_reply(req, &result);
 }
 
-rename3res *
-nfsproc3_rename_3_svc(rename3args *argp, struct svc_req *rqstp)
+void nfsproc3_rename_3_svc(rename3args *argp, RPCRequest *req)
 {
-    static rename3res result;
+    rename3res result;
+    memset(&result, 0, sizeof(result));
     wcc_data *wcc1 = &result.rename3res_u.res.fromdir_wcc;
     wcc_data *wcc2 = &result.rename3res_u.res.todir_wcc;
-    memset(wcc1, 0, sizeof(*wcc1));
-    memset(wcc2, 0, sizeof(*wcc2));
 
     BlueSkyInode *dir1 = lookup_fh(&argp->from.dir);
     if (dir1 == NULL) {
         result.status = NFS3ERR_STALE;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
     encode_pre_wcc(wcc1, dir1);
 
     BlueSkyInode *dir2 = lookup_fh(&argp->to.dir);
     if (dir2 == NULL) {
         result.status = NFS3ERR_STALE;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
     encode_pre_wcc(wcc2, dir1);
 
@@ -641,13 +700,13 @@ nfsproc3_rename_3_svc(rename3args *argp, struct svc_req *rqstp)
     else
         result.status = NFS3ERR_PERM;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-link3res *
-nfsproc3_link_3_svc(link3args *argp, struct svc_req *rqstp)
+void nfsproc3_link_3_svc(link3args *argp, RPCRequest *req)
 {
-    static link3res result;
+    link3res result;
+    memset(&result, 0, sizeof(result));
     struct wcc_data wcc;
     memset(&wcc, 0, sizeof(wcc));
 
@@ -655,21 +714,24 @@ nfsproc3_link_3_svc(link3args *argp, struct svc_req *rqstp)
     if (inode == NULL) {
         result.status = NFS3ERR_STALE;
         result.link3res_u.res.linkdir_wcc = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     BlueSkyInode *dir = lookup_fh(&argp->link.dir);
     if (dir == NULL) {
         result.status = NFS3ERR_STALE;
         result.link3res_u.res.linkdir_wcc = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     encode_pre_wcc(&wcc, dir);
     if (dir->type != BLUESKY_DIRECTORY) {
         result.status = NFS3ERR_NOTDIR;
         result.link3res_u.res.linkdir_wcc = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     if (!validate_filename(argp->link.name)
@@ -679,13 +741,15 @@ nfsproc3_link_3_svc(link3args *argp, struct svc_req *rqstp)
     {
         result.status = NFS3ERR_EXIST;
         result.link3res_u.res.linkdir_wcc = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     if (!bluesky_directory_insert(dir, argp->link.name, inode->inum)) {
         result.status = NFS3ERR_EXIST;
         result.link3res_u.res.linkdir_wcc = wcc;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
     inode->nlink++;
     bluesky_inode_update_ctime(inode, 0);
@@ -697,23 +761,24 @@ nfsproc3_link_3_svc(link3args *argp, struct svc_req *rqstp)
     encode_fattr3(&result.link3res_u.res.file_attributes.post_op_attr_u.attributes, inode);
     result.link3res_u.res.linkdir_wcc = wcc;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
 gint bluesky_dirent_compare(gconstpointer a, gconstpointer b,
                             gpointer unused);
 
-#define MAX_READDIR_DIRENTS 4
-readdir3res *
-nfsproc3_readdir_3_svc(readdir3args *argp, struct svc_req *rqstp)
+#define MAX_READDIR_DIRENTS 64
+void nfsproc3_readdir_3_svc(readdir3args *argp, RPCRequest *req)
 {
-    static readdir3res result;
+    readdir3res result;
+    memset(&result, 0, sizeof(result));
 
     BlueSkyInode *dir = lookup_fh(&argp->dir);
     if (dir == NULL) {
         result.status = NFS3ERR_STALE;
         result.readdir3res_u.resfail.present = FALSE;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     result.status = NFS3_OK;
@@ -722,7 +787,7 @@ nfsproc3_readdir_3_svc(readdir3args *argp, struct svc_req *rqstp)
     memset(result.readdir3res_u.resok.cookieverf, 0,
            sizeof(result.readdir3res_u.resok.cookieverf));
 
-    static entry3 dirents[MAX_READDIR_DIRENTS];
+    entry3 dirents[MAX_READDIR_DIRENTS];
     int count = 0;
 
     BlueSkyDirent start = {NULL, NULL, argp->cookie, 0};
@@ -747,19 +812,27 @@ nfsproc3_readdir_3_svc(readdir3args *argp, struct svc_req *rqstp)
         result.readdir3res_u.resok.reply.entries = NULL;
     result.readdir3res_u.resok.reply.eof = g_sequence_iter_is_end(i);
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-readdirplus3res *
-nfsproc3_readdirplus_3_svc(readdirplus3args *argp, struct svc_req *rqstp)
+void nfsproc3_readdirplus_3_svc(readdirplus3args *argp, RPCRequest *req)
 {
-    static readdirplus3res result;
+    /* XDR-encoded sizes:
+     *   post_op_attr: 88 bytes
+     *   base readdirplus3resok: 88 + 16 bytes
+     *   base directory entry: 24 bytes + filename
+     *   attributes/fh3: 88 + 8 + filehandle size
+     */
+    size_t dircount = 88 + 16, attrcount = 0;
+    readdirplus3res result;
+    memset(&result, 0, sizeof(result));
 
     BlueSkyInode *dir = lookup_fh(&argp->dir);
     if (dir == NULL) {
         result.status = NFS3ERR_STALE;
         result.readdirplus3res_u.resfail.present = FALSE;
-        return &result;
+        async_rpc_send_reply(req, &result);
+        return;
     }
 
     result.status = NFS3_OK;
@@ -768,8 +841,8 @@ nfsproc3_readdirplus_3_svc(readdirplus3args *argp, struct svc_req *rqstp)
     memset(result.readdirplus3res_u.resok.cookieverf, 0,
            sizeof(result.readdirplus3res_u.resok.cookieverf));
 
-    static entryplus3 dirents[MAX_READDIR_DIRENTS];
-    static uint64_t fh_bytes[MAX_READDIR_DIRENTS];
+    entryplus3 dirents[MAX_READDIR_DIRENTS];
+    uint64_t fh_bytes[MAX_READDIR_DIRENTS];
     int count = 0;
 
     /* TODO: Handle dircount, maxcount arguments from client. */
@@ -782,6 +855,11 @@ nfsproc3_readdirplus_3_svc(readdirplus3args *argp, struct svc_req *rqstp)
         BlueSkyDirent *d = g_sequence_get(i);
         BlueSkyInode *inode = bluesky_get_inode(fs, d->inum);
         if (inode != NULL) {
+            dircount += 24 + ((strlen(d->name) + 3) & ~3);
+            attrcount += 88 + 8 + 8;
+            if (dircount > argp->dircount
+                || dircount + attrcount > argp->maxcount)
+                break;
             dirents[count].fileid = d->inum;
             dirents[count].name = d->name;
             dirents[count].cookie = d->cookie;
@@ -806,23 +884,41 @@ nfsproc3_readdirplus_3_svc(readdirplus3args *argp, struct svc_req *rqstp)
         result.readdirplus3res_u.resok.reply.entries = NULL;
     result.readdirplus3res_u.resok.reply.eof = g_sequence_iter_is_end(i);
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-fsstat3res *
-nfsproc3_fsstat_3_svc(nfs_fh3 *argp, struct svc_req *rqstp)
+void nfsproc3_fsstat_3_svc(nfs_fh3 *argp, RPCRequest *req)
 {
-    static fsstat3res result;
+    fsstat3res result;
+    memset(&result, 0, sizeof(result));
 
-    result.status = NFS3ERR_NOTSUPP;
+    BlueSkyInode *inode = lookup_fh(argp);
+    if (inode == NULL) {
+        result.status = NFS3ERR_STALE;
+        result.fsstat3res_u.resfail.present = FALSE;
+        async_rpc_send_reply(req, &result);
+        return;
+    }
 
-    return &result;
+    result.status = NFS3_OK;
+    result.fsstat3res_u.resok.obj_attributes.present = TRUE;
+    encode_fattr3(&result.fsstat3res_u.resok.obj_attributes.post_op_attr_u.attributes, inode);
+
+    result.fsstat3res_u.resok.tbytes = (1 << 30);
+    result.fsstat3res_u.resok.fbytes = (1 << 30);
+    result.fsstat3res_u.resok.abytes = (1 << 30);
+    result.fsstat3res_u.resok.tfiles = 0;
+    result.fsstat3res_u.resok.ffiles = 0;
+    result.fsstat3res_u.resok.afiles = 0;
+    result.fsstat3res_u.resok.invarsec = 0;
+
+    async_rpc_send_reply(req, &result);
 }
 
-fsinfo3res *
-nfsproc3_fsinfo_3_svc(nfs_fh3 *argp, struct svc_req *rqstp)
+void nfsproc3_fsinfo_3_svc(nfs_fh3 *argp, RPCRequest *req)
 {
-    static fsinfo3res result;
+    fsinfo3res result;
+    memset(&result, 0, sizeof(result));
 
     BlueSkyInode *inode = bluesky_get_inode(fs, 1);
     result.status = NFS3_OK;
@@ -841,13 +937,13 @@ nfsproc3_fsinfo_3_svc(nfs_fh3 *argp, struct svc_req *rqstp)
     result.fsinfo3res_u.resok.properties
         = FSF3_LINK | FSF3_SYMLINK | FSF3_HOMOGENEOUS | FSF3_CANSETTIME;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-pathconf3res *
-nfsproc3_pathconf_3_svc(nfs_fh3 *argp, struct svc_req *rqstp)
+void nfsproc3_pathconf_3_svc(nfs_fh3 *argp, RPCRequest *req)
 {
-    static pathconf3res result;
+    pathconf3res result;
+    memset(&result, 0, sizeof(result));
 
     BlueSkyInode *inode = bluesky_get_inode(fs, 1);
     result.status = NFS3_OK;
@@ -860,15 +956,15 @@ nfsproc3_pathconf_3_svc(nfs_fh3 *argp, struct svc_req *rqstp)
     result.pathconf3res_u.resok.case_insensitive = FALSE;
     result.pathconf3res_u.resok.case_preserving = TRUE;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }
 
-commit3res *
-nfsproc3_commit_3_svc(commit3args *argp, struct svc_req *rqstp)
+void nfsproc3_commit_3_svc(commit3args *argp, RPCRequest *req)
 {
-    static commit3res result;
+    commit3res result;
+    memset(&result, 0, sizeof(result));
 
     result.status = NFS3ERR_NOTSUPP;
 
-    return &result;
+    async_rpc_send_reply(req, &result);
 }