summaryrefslogtreecommitdiffstats
path: root/xlators/cluster/afr/src/afr-dir-write.c
diff options
context:
space:
mode:
Diffstat (limited to 'xlators/cluster/afr/src/afr-dir-write.c')
-rw-r--r--xlators/cluster/afr/src/afr-dir-write.c15
1 files changed, 10 insertions, 5 deletions
diff --git a/xlators/cluster/afr/src/afr-dir-write.c b/xlators/cluster/afr/src/afr-dir-write.c
index 9f2b975df6f..0b804bef580 100644
--- a/xlators/cluster/afr/src/afr-dir-write.c
+++ b/xlators/cluster/afr/src/afr-dir-write.c
@@ -196,7 +196,8 @@ unlock:
afr_set_read_ctx_from_policy (this, inode,
local->fresh_children,
local->read_child_index,
- priv->read_child);
+ priv->read_child,
+ local->cont.create.buf.ia_gfid);
local->transaction.unwind (frame, this);
local->transaction.resume (frame, this);
@@ -429,7 +430,8 @@ afr_mknod_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
afr_set_read_ctx_from_policy (this, inode,
local->fresh_children,
local->read_child_index,
- priv->read_child);
+ priv->read_child,
+ local->cont.mknod.buf.ia_gfid);
local->transaction.unwind (frame, this);
local->transaction.resume (frame, this);
@@ -657,7 +659,8 @@ afr_mkdir_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
afr_set_read_ctx_from_policy (this, inode,
local->fresh_children,
local->read_child_index,
- priv->read_child);
+ priv->read_child,
+ local->cont.mkdir.buf.ia_gfid);
local->transaction.unwind (frame, this);
local->transaction.resume (frame, this);
@@ -887,7 +890,8 @@ afr_link_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
afr_set_read_ctx_from_policy (this, inode,
local->fresh_children,
local->read_child_index,
- priv->read_child);
+ priv->read_child,
+ local->cont.link.buf.ia_gfid);
local->transaction.unwind (frame, this);
local->transaction.resume (frame, this);
@@ -1110,7 +1114,8 @@ afr_symlink_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
afr_set_read_ctx_from_policy (this, inode,
local->fresh_children,
local->read_child_index,
- priv->read_child);
+ priv->read_child,
+ local->cont.symlink.buf.ia_gfid);
local->transaction.unwind (frame, this);
local->transaction.resume (frame, this);