diff options
Diffstat (limited to 'xlators/storage/posix/src/posix.c')
-rw-r--r-- | xlators/storage/posix/src/posix.c | 46 |
1 files changed, 36 insertions, 10 deletions
diff --git a/xlators/storage/posix/src/posix.c b/xlators/storage/posix/src/posix.c index d571bf4ac9a..3fd58b62454 100644 --- a/xlators/storage/posix/src/posix.c +++ b/xlators/storage/posix/src/posix.c @@ -5758,7 +5758,7 @@ out: int do_xattrop (call_frame_t *frame, xlator_t *this, loc_t *loc, fd_t *fd, - gf_xattrop_flags_t optype, dict_t *xattr) + gf_xattrop_flags_t optype, dict_t *xattr, dict_t *xdata) { int op_ret = 0; int op_errno = 0; @@ -5767,7 +5767,9 @@ do_xattrop (call_frame_t *frame, xlator_t *this, loc_t *loc, fd_t *fd, struct posix_fd *pfd = NULL; inode_t *inode = NULL; posix_xattr_filler_t filler = {0,}; - dict_t *xdata = NULL; + dict_t *xattr_rsp = NULL; + dict_t *xdata_rsp = NULL; + struct iatt stbuf = {0}; VALIDATE_OR_GOTO (frame, out); VALIDATE_OR_GOTO (xattr, out); @@ -5800,8 +5802,8 @@ do_xattrop (call_frame_t *frame, xlator_t *this, loc_t *loc, fd_t *fd, inode = fd->inode; } - xdata = dict_new (); - if (xdata == NULL) { + xattr_rsp = dict_new (); + if (xattr_rsp == NULL) { op_ret = -1; op_errno = ENOMEM; goto out; @@ -5812,19 +5814,43 @@ do_xattrop (call_frame_t *frame, xlator_t *this, loc_t *loc, fd_t *fd, filler.real_path = real_path; filler.flags = (int)optype; filler.inode = inode; - filler.xattr = xdata; + filler.xattr = xattr_rsp; op_ret = dict_foreach (xattr, _posix_handle_xattr_keyvalue_pair, &filler); op_errno = filler.op_errno; + if (op_ret < 0) + goto out; + + if (!xdata) + goto out; + if (fd) { + op_ret = posix_fdstat (this, _fd, &stbuf); + } else { + op_ret = posix_pstat (this, inode->gfid, real_path, + &stbuf); + } + if (op_ret < 0) { + op_errno = errno; + goto out; + } + xdata_rsp = posix_xattr_fill (this, real_path, loc, fd, _fd, + xdata, &stbuf); + if (!xdata_rsp) { + op_ret = -1; + op_errno = ENOMEM; + } out: - STACK_UNWIND_STRICT (xattrop, frame, op_ret, op_errno, xdata, NULL); + STACK_UNWIND_STRICT (xattrop, frame, op_ret, op_errno, xattr_rsp, + xdata_rsp); - if (xdata) - dict_unref (xdata); + if (xattr_rsp) + dict_unref (xattr_rsp); + if (xdata_rsp) + dict_unref (xdata_rsp); return 0; } @@ -5833,7 +5859,7 @@ int posix_xattrop (call_frame_t *frame, xlator_t *this, loc_t *loc, gf_xattrop_flags_t optype, dict_t *xattr, dict_t *xdata) { - do_xattrop (frame, this, loc, NULL, optype, xattr); + do_xattrop (frame, this, loc, NULL, optype, xattr, xdata); return 0; } @@ -5842,7 +5868,7 @@ int posix_fxattrop (call_frame_t *frame, xlator_t *this, fd_t *fd, gf_xattrop_flags_t optype, dict_t *xattr, dict_t *xdata) { - do_xattrop (frame, this, NULL, fd, optype, xattr); + do_xattrop (frame, this, NULL, fd, optype, xattr, xdata); return 0; } |