summaryrefslogtreecommitdiffstats
path: root/xlators/features/shard
diff options
context:
space:
mode:
authorKrutika Dhananjay <kdhananj@redhat.com>2017-09-05 21:42:26 +0530
committerPranith Kumar Karampuri <pkarampu@redhat.com>2017-09-06 02:31:09 +0000
commit91430817ce5bcbeabf057e9c978485728a85fb2b (patch)
tree357cc3a21b477ed071864caa0e7141f2d381e3d3 /xlators/features/shard
parentb1352d0974328b367afa7360e9523585efb7178d (diff)
features/shard: Return aggregated size in stbuf of LINK fop
Change-Id: I42df7679d63fec9b4c03b8dbc66c5625f097fac0 BUG: 1488546 Signed-off-by: Krutika Dhananjay <kdhananj@redhat.com> Reviewed-on: https://review.gluster.org/18209 Smoke: Gluster Build System <jenkins@build.gluster.org> CentOS-regression: Gluster Build System <jenkins@build.gluster.org> Reviewed-by: Pranith Kumar Karampuri <pkarampu@redhat.com>
Diffstat (limited to 'xlators/features/shard')
-rw-r--r--xlators/features/shard/src/shard.c44
1 files changed, 42 insertions, 2 deletions
diff --git a/xlators/features/shard/src/shard.c b/xlators/features/shard/src/shard.c
index f892fb69efa..adf5da0d398 100644
--- a/xlators/features/shard/src/shard.c
+++ b/xlators/features/shard/src/shard.c
@@ -2233,11 +2233,16 @@ shard_link_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
struct iatt *postparent,
dict_t *xdata)
{
+ shard_local_t *local = NULL;
+
+ local = frame->local;
if (op_ret < 0)
goto err;
shard_inode_ctx_set (inode, this, buf, 0,
SHARD_MASK_NLINK | SHARD_MASK_TIMES);
+ buf->ia_size = local->prebuf.ia_size;
+ buf->ia_blocks = local->prebuf.ia_blocks;
SHARD_STACK_UNWIND (link, frame, op_ret, op_errno, inode, buf,
preparent, postparent, xdata);
@@ -2248,12 +2253,32 @@ err:
return 0;
}
+int
+shard_post_lookup_link_handler (call_frame_t *frame, xlator_t *this)
+{
+ shard_local_t *local = NULL;
+
+ local = frame->local;
+
+ if (local->op_ret < 0) {
+ SHARD_STACK_UNWIND (link, frame, local->op_ret, local->op_errno,
+ NULL, NULL, NULL, NULL, NULL);
+ return 0;
+ }
+
+ STACK_WIND (frame, shard_link_cbk, FIRST_CHILD(this),
+ FIRST_CHILD(this)->fops->link, &local->loc, &local->loc2,
+ local->xattr_req);
+ return 0;
+}
+
int32_t
shard_link (call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc,
dict_t *xdata)
{
int ret = -1;
uint64_t block_size = 0;
+ shard_local_t *local = NULL;
ret = shard_inode_ctx_get_block_size (oldloc->inode, this, &block_size);
if (ret) {
@@ -2271,8 +2296,23 @@ shard_link (call_frame_t *frame, xlator_t *this, loc_t *oldloc, loc_t *newloc,
return 0;
}
- STACK_WIND (frame, shard_link_cbk, FIRST_CHILD(this),
- FIRST_CHILD(this)->fops->link, oldloc, newloc, xdata);
+ if (!this->itable)
+ this->itable = oldloc->inode->table;
+
+ local = mem_get0 (this->local_pool);
+ if (!local)
+ goto err;
+
+ frame->local = local;
+
+ loc_copy (&local->loc, oldloc);
+ loc_copy (&local->loc2, newloc);
+ local->xattr_req = (xdata) ? dict_ref (xdata) : dict_new ();
+ if (!local->xattr_req)
+ goto err;
+
+ shard_lookup_base_file (frame, this, &local->loc,
+ shard_post_lookup_link_handler);
return 0;
err: