|
 |
d1681e |
From 684f7a9f2f6d79ac45fdf2cf994c5fca139e51cd Mon Sep 17 00:00:00 2001
|
|
|
d1681e |
From: Pranith Kumar K <pkarampu@redhat.com>
|
|
|
d1681e |
Date: Wed, 31 Jan 2018 22:10:46 +0530
|
|
|
d1681e |
Subject: [PATCH 178/180] cluster/ec: Do lock conflict check correctly for
|
|
|
d1681e |
wait-list
|
|
|
d1681e |
|
|
|
d1681e |
Problem:
|
|
|
d1681e |
ec_link_has_lock_conflict() is traversing over only owner_list
|
|
|
d1681e |
but the function is also getting called with wait_list.
|
|
|
d1681e |
|
|
|
d1681e |
Fix:
|
|
|
d1681e |
Modify ec_link_has_lock_conflict() to traverse lists correctly.
|
|
|
d1681e |
Updated the callers to reflect the changes.
|
|
|
d1681e |
|
|
|
d1681e |
>BUG: 1540896
|
|
|
d1681e |
>Change-Id: Ibd7ea10f4498e7c2761f9a6faac6d5cb7d750c91
|
|
|
d1681e |
>Signed-off-by: Pranith Kumar K <pkarampu@redhat.com>
|
|
|
d1681e |
|
|
|
d1681e |
Master Patch: https://review.gluster.org/19415
|
|
|
d1681e |
Release-3.13 Patch: https://review.gluster.org/19428
|
|
|
d1681e |
|
|
|
d1681e |
BUG: 1540908
|
|
|
d1681e |
Change-Id: I859aab86d591c22d635bf7a2ef17b77b605d32d8
|
|
|
d1681e |
Signed-off-by: Pranith Kumar K <pkarampu@redhat.com>
|
|
|
d1681e |
Reviewed-on: https://code.engineering.redhat.com/gerrit/129249
|
|
|
d1681e |
Tested-by: RHGS Build Bot <nigelb@redhat.com>
|
|
|
d1681e |
Reviewed-by: Sunil Kumar Heggodu Gopala Acharya <sheggodu@redhat.com>
|
|
|
d1681e |
---
|
|
|
d1681e |
xlators/cluster/ec/src/ec-common.c | 23 +++++++++++++++--------
|
|
|
d1681e |
1 file changed, 15 insertions(+), 8 deletions(-)
|
|
|
d1681e |
|
|
|
d1681e |
diff --git a/xlators/cluster/ec/src/ec-common.c b/xlators/cluster/ec/src/ec-common.c
|
|
|
d1681e |
index 051fff6..bd2ae50 100644
|
|
|
d1681e |
--- a/xlators/cluster/ec/src/ec-common.c
|
|
|
d1681e |
+++ b/xlators/cluster/ec/src/ec-common.c
|
|
|
d1681e |
@@ -1643,18 +1643,27 @@ ec_lock_update_fd(ec_lock_t *lock, ec_fop_data_t *fop)
|
|
|
d1681e |
}
|
|
|
d1681e |
|
|
|
d1681e |
static gf_boolean_t
|
|
|
d1681e |
-ec_link_has_lock_conflict (ec_lock_link_t *link, struct list_head *owners)
|
|
|
d1681e |
+ec_link_has_lock_conflict (ec_lock_link_t *link, gf_boolean_t waitlist_check)
|
|
|
d1681e |
{
|
|
|
d1681e |
- ec_lock_link_t *owner_link = NULL;
|
|
|
d1681e |
+ ec_lock_link_t *trav_link = NULL;
|
|
|
d1681e |
ec_t *ec = link->fop->xl->private;
|
|
|
d1681e |
|
|
|
d1681e |
if (!ec->parallel_writes)
|
|
|
d1681e |
return _gf_true;
|
|
|
d1681e |
|
|
|
d1681e |
- list_for_each_entry (owner_link, owners, owner_list) {
|
|
|
d1681e |
- if (ec_lock_conflict (owner_link, link))
|
|
|
d1681e |
+ list_for_each_entry (trav_link, &link->lock->owners, owner_list) {
|
|
|
d1681e |
+ if (ec_lock_conflict (trav_link, link))
|
|
|
d1681e |
return _gf_true;
|
|
|
d1681e |
}
|
|
|
d1681e |
+
|
|
|
d1681e |
+ if (!waitlist_check)
|
|
|
d1681e |
+ return _gf_false;
|
|
|
d1681e |
+
|
|
|
d1681e |
+ list_for_each_entry (trav_link, &link->lock->waiting, wait_list) {
|
|
|
d1681e |
+ if (ec_lock_conflict (trav_link, link))
|
|
|
d1681e |
+ return _gf_true;
|
|
|
d1681e |
+ }
|
|
|
d1681e |
+
|
|
|
d1681e |
return _gf_false;
|
|
|
d1681e |
}
|
|
|
d1681e |
|
|
|
d1681e |
@@ -1676,7 +1685,7 @@ ec_lock_wake_shared(ec_lock_t *lock, struct list_head *list)
|
|
|
d1681e |
|
|
|
d1681e |
/* If the fop is not shareable, only this fop can be assigned as owner.
|
|
|
d1681e |
* Other fops will need to wait until this one finishes. */
|
|
|
d1681e |
- if (ec_link_has_lock_conflict (link, &lock->owners)) {
|
|
|
d1681e |
+ if (ec_link_has_lock_conflict (link, _gf_false)) {
|
|
|
d1681e |
conflict = _gf_true;
|
|
|
d1681e |
}
|
|
|
d1681e |
|
|
|
d1681e |
@@ -1923,9 +1932,7 @@ ec_lock_assign_owner(ec_lock_link_t *link)
|
|
|
d1681e |
* owners, or waiters(to prevent starvation).
|
|
|
d1681e |
* Otherwise we need to wait.
|
|
|
d1681e |
*/
|
|
|
d1681e |
- if (!lock->acquired ||
|
|
|
d1681e |
- ec_link_has_lock_conflict (link, &lock->owners) ||
|
|
|
d1681e |
- ec_link_has_lock_conflict (link, &lock->waiting)) {
|
|
|
d1681e |
+ if (!lock->acquired || ec_link_has_lock_conflict (link, _gf_true)) {
|
|
|
d1681e |
ec_trace("LOCK_QUEUE_WAIT", fop, "lock=%p", lock);
|
|
|
d1681e |
|
|
|
d1681e |
list_add_tail(&link->wait_list, &lock->waiting);
|
|
|
d1681e |
--
|
|
|
d1681e |
1.8.3.1
|
|
|
d1681e |
|