diff options
author | Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com> | 2011-08-02 11:36:24 +0530 |
---|---|---|
committer | Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com> | 2011-08-25 20:16:42 +0530 |
commit | b9cb88b0565c9a292f79a1c7bd387b8e9978e2a6 (patch) | |
tree | a0e895b36135e9b4151dc9bcf5d9df05ab5ade34 /hw/9pfs | |
parent | 95f65511c36fe4e2b319de4551f8a5657a63b67f (diff) |
hw/9pfs: mark directories also as un-reclaimable on unlink
Signed-off-by: Aneesh Kumar K.V <aneesh.kumar@linux.vnet.ibm.com>
Diffstat (limited to 'hw/9pfs')
-rw-r--r-- | hw/9pfs/virtio-9p.c | 73 |
1 files changed, 38 insertions, 35 deletions
diff --git a/hw/9pfs/virtio-9p.c b/hw/9pfs/virtio-9p.c index 16f7d4e2d7..94b7090e7d 100644 --- a/hw/9pfs/virtio-9p.c +++ b/hw/9pfs/virtio-9p.c @@ -235,6 +235,27 @@ static size_t v9fs_string_size(V9fsString *str) return str->size; } +/* + * returns 0 if fid got re-opened, 1 if not, < 0 on error */ +static int v9fs_reopen_fid(V9fsState *s, V9fsFidState *f) +{ + int err = 1; + if (f->fid_type == P9_FID_FILE) { + if (f->fs.fd == -1) { + do { + err = v9fs_co_open(s, f, f->open_flags); + } while (err == -EINTR); + } + } else if (f->fid_type == P9_FID_DIR) { + if (f->fs.dir == NULL) { + do { + err = v9fs_co_opendir(s, f); + } while (err == -EINTR); + } + } + return err; +} + static V9fsFidState *get_fid(V9fsState *s, int32_t fid) { int err; @@ -249,34 +270,17 @@ static V9fsFidState *get_fid(V9fsState *s, int32_t fid) * in open later. */ f->ref++; - /* * check whether we need to reopen the * file. We might have closed the fd * while trying to free up some file * descriptors. */ - if (f->fid_type == P9_FID_FILE) { - if (f->fs.fd == -1) { - do { - err = v9fs_co_open(s, f, f->open_flags); - } while (err == -EINTR); - if (err < 0) { - f->ref--; - return NULL; - } - } - } else if (f->fid_type == P9_FID_DIR) { - if (f->fs.dir == NULL) { - do { - err = v9fs_co_opendir(s, f); - } while (err == -EINTR); - if (err < 0) { - f->ref--; - return NULL; - } - } - } + err = v9fs_reopen_fid(s, f); + if (err < 0) { + f->ref--; + return NULL; + } /* * Mark the fid as referenced so that the LRU * reclaim won't close the file descriptor @@ -490,19 +494,18 @@ static int v9fs_mark_fids_unreclaim(V9fsState *s, V9fsString *str) if (!strcmp(fidp->path.data, str->data)) { /* Mark the fid non reclaimable. */ fidp->flags |= FID_NON_RECLAIMABLE; - /* reopen the file if already closed */ - if (fidp->fs.fd == -1) { - do { - err = v9fs_co_open(s, fidp, fidp->open_flags); - } while (err == -EINTR); - if (err < 0) { - return -1; - } - /* - * Go back to head of fid list because - * the list could have got updated when - * switched to the worker thread - */ + + /* reopen the file/dir if already closed */ + err = v9fs_reopen_fid(s, fidp); + if (err < 0) { + return -1; + } + /* + * Go back to head of fid list because + * the list could have got updated when + * switched to the worker thread + */ + if (err == 0) { fidp = &head_fid; } } |