Merge pull request #97 from rosslagerwall/read-close-crash
authorRonnie Sahlberg <ronniesahlberg@gmail.com>
Mon, 11 Aug 2014 13:15:16 +0000 (06:15 -0700)
committerRonnie Sahlberg <ronniesahlberg@gmail.com>
Mon, 11 Aug 2014 13:15:16 +0000 (06:15 -0700)
libnfs: Don't perform operations on nfsfh after user callback

1  2 
lib/libnfs.c

diff --combined lib/libnfs.c
index 222721c39240f276e4d4b584f2dd80e6d5f9fe1a,06697e10c62311d7d59a0e88f19e837e044e4531..c213caddb20967361549c1b0eca28e6c1ae65822
@@@ -73,7 -73,6 +73,7 @@@
  #include <string.h>
  #include <assert.h>
  #include <errno.h>
 +#include <time.h>
  #include <sys/types.h>
  #include <sys/stat.h>
  #include <fcntl.h>
@@@ -1808,6 -1807,8 +1808,8 @@@ static void nfs_pread_mcb(struct rpc_co
        struct nfs_cb_data *data = mdata->data;
        struct nfs_context *nfs = data->nfs;
        READ3res *res;
+       int cb_err;
+       void *cb_data;
  
        assert(rpc->magic == RPC_CONTEXT_MAGIC);
  
                if (data->max_offset > data->org_offset + data->org_count) {
                        data->max_offset = data->org_offset + data->org_count;
                }
-               data->cb(data->max_offset - data->org_offset, nfs, data->buffer + (data->org_offset - data->offset), data->private_data);
+               cb_err = data->max_offset - data->org_offset;
+               cb_data = data->buffer + (data->org_offset - data->offset);
        } else {
-               data->cb(res->READ3res_u.resok.count, nfs, res->READ3res_u.resok.data.data_val, data->private_data);
+               cb_err = res->READ3res_u.resok.count;
+               cb_data = res->READ3res_u.resok.data.data_val;
        }
  
        data->nfsfh->ra.fh_offset = data->max_offset;
                data->nfsfh->ra.buf_ts = time(NULL);
                data->buffer = NULL;
        }
+       data->cb(cb_err, nfs, cb_data, data->private_data);
        free_nfs_cb_data(data);
  }
  
@@@ -2772,7 -2777,7 +2778,7 @@@ static void nfs_create_trunc_cb(struct 
  {
        struct nfs_cb_data *data = private_data;
        struct nfs_context *nfs = data->nfs;
 -      struct nfsfh *nfsfh;
 +      struct nfsfh *nfsfh = data->nfsfh;
        SETATTR3res *res;
  
        assert(rpc->magic == RPC_CONTEXT_MAGIC);
                return;
        }
  
 -      data->cb(0, nfs, data->nfsfh, data->private_data);
 +      data->cb(0, nfs, nfsfh, data->private_data);
        free_nfs_cb_data(data);
  }
  
@@@ -3989,12 -3994,12 +3995,12 @@@ int nfs_chmod_async_internal(struct nfs
  
  int nfs_chmod_async(struct nfs_context *nfs, const char *path, int mode, nfs_cb cb, void *private_data)
  {
 -      return nfs_chown_async_internal(nfs, path, 0, mode, cb, private_data);
 +      return nfs_chmod_async_internal(nfs, path, 0, mode, cb, private_data);
  }
  
  int nfs_lchmod_async(struct nfs_context *nfs, const char *path, int mode, nfs_cb cb, void *private_data)
  {
 -      return nfs_chown_async_internal(nfs, path, 1, mode, cb, private_data);
 +      return nfs_chmod_async_internal(nfs, path, 1, mode, cb, private_data);
  }
  
  /*