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.c22
1 files changed, 0 insertions, 22 deletions
diff --git a/xlators/cluster/afr/src/afr-dir-write.c b/xlators/cluster/afr/src/afr-dir-write.c
index 11da7fd3958..27dd3517794 100644
--- a/xlators/cluster/afr/src/afr-dir-write.c
+++ b/xlators/cluster/afr/src/afr-dir-write.c
@@ -77,11 +77,9 @@ int
afr_create_unwind (call_frame_t *frame, xlator_t *this)
{
call_frame_t *main_frame = NULL;
- afr_private_t * priv = NULL;
afr_local_t *local = NULL;
struct iatt *unwind_buf = NULL;
- priv = this->private;
local = frame->local;
LOCK (&frame->lock);
@@ -1400,13 +1398,11 @@ afr_rename_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
struct iatt *prenewparent, struct iatt *postnewparent)
{
afr_local_t * local = NULL;
- afr_private_t * priv = NULL;
int call_count = -1;
int child_index = -1;
local = frame->local;
- priv = this->private;
child_index = (long) cookie;
@@ -1444,7 +1440,6 @@ afr_rename_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
if (call_count == 0) {
local->transaction.unwind (frame, this);
-
local->transaction.resume (frame, this);
}
@@ -1622,14 +1617,10 @@ afr_unlink_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int call_count = -1;
int child_index = (long) cookie;
- int need_unwind = 0;
- int read_child = 0;
local = frame->local;
priv = this->private;
- read_child = afr_read_child (this, local->loc.inode);
-
LOCK (&frame->lock);
{
if (child_index == local->read_child_index) {
@@ -1652,11 +1643,6 @@ afr_unlink_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
}
local->success_count++;
-
- if ((local->success_count == priv->wait_count)
- && local->read_child_returned) {
- need_unwind = 1;
- }
}
local->op_errno = op_errno;
@@ -1837,14 +1823,11 @@ afr_rmdir_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
int call_count = -1;
int child_index = (long) cookie;
- int need_unwind = 0;
int read_child = 0;
local = frame->local;
priv = this->private;
- read_child = afr_read_child (this, local->loc.inode);
-
LOCK (&frame->lock);
{
if (child_index == read_child) {
@@ -1868,10 +1851,6 @@ afr_rmdir_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
}
local->success_count++;
-
- if ((local->success_count == priv->wait_count)
- && local->read_child_returned)
- need_unwind = 1;
}
local->op_errno = op_errno;
@@ -1882,7 +1861,6 @@ afr_rmdir_wind_cbk (call_frame_t *frame, void *cookie, xlator_t *this,
if (call_count == 0) {
local->transaction.unwind (frame, this);
-
local->transaction.resume (frame, this);
}