diff options
author | Miklos Szeredi <miklos@szeredi.hu> | 2005-10-26 15:29:06 +0000 |
---|---|---|
committer | Miklos Szeredi <miklos@szeredi.hu> | 2005-10-26 15:29:06 +0000 |
commit | d9079a75b14b73e7953adf4958709b1e5ab3804c (patch) | |
tree | 6c20aef91825f2d4d62e18080579be7a1d54f62e /lib/fuse.c | |
parent | 2c650415ef3e655dbe1c6d39b8fc65c3a6efe998 (diff) |
atomic open+create added
Diffstat (limited to 'lib/fuse.c')
-rw-r--r-- | lib/fuse.c | 61 |
1 files changed, 61 insertions, 0 deletions
@@ -994,6 +994,66 @@ static void fuse_link(fuse_req_t req, fuse_ino_t ino, fuse_ino_t newparent, reply_entry(req, &e, err); } +static void fuse_create(fuse_req_t req, fuse_ino_t parent, const char *name, + mode_t mode, struct fuse_file_info *fi) +{ + struct fuse *f = req_fuse_prepare(req); + struct fuse_entry_param e; + char *path; + int err; + + err = -ENOENT; + pthread_rwlock_rdlock(&f->tree_lock); + path = get_path_name(f, parent, name); + if (path != NULL) { + err = -ENOSYS; + if (f->op.create && f->op.getattr) { + err = f->op.create(path, mode, fi); + if (!err) { + if (f->flags & FUSE_DEBUG) { + printf("CREATE[%lu] flags: 0x%x %s\n", fi->fh, fi->flags, + path); + fflush(stdout); + } + err = lookup_path(f, parent, name, path, &e); + if (err) { + if (f->op.release) + f->op.release(path, fi); + } else if (!S_ISREG(e.attr.st_mode)) { + err = -EIO; + if (f->op.release) + f->op.release(path, fi); + forget_node(f, e.ino, 1); + } + } + } + } + + if (!err) { + if (f->flags & FUSE_DIRECT_IO) + fi->direct_io = 1; + if (f->flags & FUSE_KERNEL_CACHE) + fi->keep_cache = 1; + + pthread_mutex_lock(&f->lock); + if (fuse_reply_create(req, &e, fi) == -ENOENT) { + /* The open syscall was interrupted, so it must be cancelled */ + if(f->op.release) + f->op.release(path, fi); + forget_node(f, e.ino, 1); + } else { + struct node *node = get_node(f, e.ino); + node->open_count ++; + } + pthread_mutex_unlock(&f->lock); + } else + reply_err(req, err); + + if (path) + free(path); + pthread_rwlock_unlock(&f->tree_lock); +} + static void fuse_open(fuse_req_t req, fuse_ino_t ino, struct fuse_file_info *fi) { @@ -1654,6 +1714,7 @@ static struct fuse_lowlevel_ops fuse_path_ops = { .symlink = fuse_symlink, .rename = fuse_rename, .link = fuse_link, + .create = fuse_create, .open = fuse_open, .read = fuse_read, .write = fuse_write, |