summaryrefslogtreecommitdiffstats
path: root/xlators/cluster/afr/src
diff options
context:
space:
mode:
authorRavishankar N <ravishankar@redhat.com>2015-08-04 18:37:47 +0530
committerKaushal M <kaushal@redhat.com>2015-08-31 08:03:09 -0700
commit7924eb1a11fe0b1443903a69b7e93e4767061064 (patch)
treecba81e366f8bdab5a2c726c32aee0a6025c7a4cc /xlators/cluster/afr/src
parent1cc232c9bfad531ec2ee9052fa198519353516a1 (diff)
afr: modify afr_txn_nothing_failed()
Backport of http://review.gluster.org/#/c/11827/ In an AFR transaction, we need to consider something as failed only if the failure (either in the pre-op or the FOP phase) occurs on the bricks on which a transaction lock was obtained. Without this, we would end up considering the transaction as failure even on the bricks on which the lock was not obtained, resulting in unnecessary fsyncs during the post-op phase of every write transaction for non-appending writes. Change-Id: Iee79e5d85dc7b4c41459d8bdd04a8454bdaf9a9d BUG: 1255698 Signed-off-by: Ravishankar N <ravishankar@redhat.com> Reviewed-on: http://review.gluster.org/11985 Tested-by: Gluster Build System <jenkins@build.gluster.com> Reviewed-by: Pranith Kumar Karampuri <pkarampu@redhat.com> Tested-by: NetBSD Build System <jenkins@build.gluster.org>
Diffstat (limited to 'xlators/cluster/afr/src')
-rw-r--r--xlators/cluster/afr/src/afr-transaction.c15
1 files changed, 3 insertions, 12 deletions
diff --git a/xlators/cluster/afr/src/afr-transaction.c b/xlators/cluster/afr/src/afr-transaction.c
index ba50abd6d38..d773b5ace7a 100644
--- a/xlators/cluster/afr/src/afr-transaction.c
+++ b/xlators/cluster/afr/src/afr-transaction.c
@@ -493,18 +493,14 @@ afr_txn_nothing_failed (call_frame_t *frame, xlator_t *this)
{
afr_private_t *priv = NULL;
afr_local_t *local = NULL;
- int pre_op_count = 0;
int i = 0;
local = frame->local;
priv = this->private;
- pre_op_count = AFR_COUNT (local->transaction.pre_op, priv->child_count);
- if (pre_op_count < priv->child_count)
- return _gf_false;
-
for (i = 0; i < priv->child_count; i++) {
- if (local->transaction.failed_subvols[i])
+ if (local->transaction.pre_op[i] &&
+ local->transaction.failed_subvols[i])
return _gf_false;
}
@@ -1156,14 +1152,9 @@ afr_changelog_pre_op (call_frame_t *frame, xlator_t *this)
goto err;
}
- if (call_count > 1 &&
- (local->transaction.type == AFR_DATA_TRANSACTION ||
+ if ((local->transaction.type == AFR_DATA_TRANSACTION ||
!local->optimistic_change_log)) {
- /* If we are performing change on only one subvol, no
- need to mark dirty, because we are setting the pending
- counts already anyways
- */
local->dirty[idx] = hton32(1);
ret = dict_set_static_bin (xdata_req, AFR_DIRTY, local->dirty,