summaryrefslogtreecommitdiff
path: root/storage
diff options
context:
space:
mode:
authorunknown <jonas@perch.ndb.mysql.com>2006-06-01 14:34:46 +0200
committerunknown <jonas@perch.ndb.mysql.com>2006-06-01 14:34:46 +0200
commit57b262f32a8f3e54ac07b9f2dc0a6429673472ad (patch)
tree7f3970fda61faeaf4edb0e0defdaa558b85570f9 /storage
parent5f91dfde9e92436bc07df70bde7695292b72df3e (diff)
downloadmariadb-git-57b262f32a8f3e54ac07b9f2dc0a6429673472ad.tar.gz
ndb - bug#20197
also close scan which are in "delivered" state, as it's impossible to release locks afterwards storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp: also close scan which are in "delivered" state, as it's impossible to release locks afterwards
Diffstat (limited to 'storage')
-rw-r--r--storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp12
1 files changed, 12 insertions, 0 deletions
diff --git a/storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp b/storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
index 869ae116f43..415720b430a 100644
--- a/storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
+++ b/storage/ndb/src/kernel/blocks/dbtc/DbtcMain.cpp
@@ -7052,6 +7052,18 @@ void Dbtc::checkScanActiveInFailedLqh(Signal* signal,
found = true;
}
}
+
+ ScanFragList deliv(c_scan_frag_pool, scanptr.p->m_delivered_scan_frags);
+ for(deliv.first(ptr); !ptr.isNull(); deliv.next(ptr))
+ {
+ jam();
+ if (refToNode(ptr.p->lqhBlockref) == failedNodeId)
+ {
+ jam();
+ found = true;
+ break;
+ }
+ }
}
if(found){
jam();