summaryrefslogtreecommitdiff
path: root/storage/ndb/src/kernel/blocks/suma
diff options
context:
space:
mode:
authorunknown <jonas@perch.ndb.mysql.com>2007-10-18 23:21:18 +0200
committerunknown <jonas@perch.ndb.mysql.com>2007-10-18 23:21:18 +0200
commit78951216ff29b017e3cb98ecb34c954090beb020 (patch)
treea295ea7535f2df405afb5955fb1c87224b10c5e6 /storage/ndb/src/kernel/blocks/suma
parent4815760bd85c48e87cadbb084b9d167c19c571ba (diff)
downloadmariadb-git-78951216ff29b017e3cb98ecb34c954090beb020.tar.gz
ndb - bug#31701 Node failure with repl. wo/ load, can lead to endless out of order buckets
Correct check for buffer/no buffer storage/ndb/src/kernel/blocks/ERROR_codes.txt: new error code storage/ndb/src/kernel/blocks/suma/Suma.cpp: correct check for buffer/no buffer storage/ndb/test/ndbapi/test_event.cpp: test prg storage/ndb/test/run-test/daily-basic-tests.txt: test prg
Diffstat (limited to 'storage/ndb/src/kernel/blocks/suma')
-rw-r--r--storage/ndb/src/kernel/blocks/suma/Suma.cpp6
1 files changed, 4 insertions, 2 deletions
diff --git a/storage/ndb/src/kernel/blocks/suma/Suma.cpp b/storage/ndb/src/kernel/blocks/suma/Suma.cpp
index 717448ca03b..94df9a2b32e 100644
--- a/storage/ndb/src/kernel/blocks/suma/Suma.cpp
+++ b/storage/ndb/src/kernel/blocks/suma/Suma.cpp
@@ -3650,6 +3650,8 @@ Suma::execSUB_GCP_COMPLETE_REP(Signal* signal)
if(m_gcp_complete_rep_count && !c_subscriber_nodes.isclear())
{
+ CRASH_INSERTION(13033);
+
NodeReceiverGroup rg(API_CLUSTERMGR, c_subscriber_nodes);
sendSignal(rg, GSN_SUB_GCP_COMPLETE_REP, signal,
SubGcpCompleteRep::SignalLength, JBB);
@@ -3669,8 +3671,8 @@ Suma::execSUB_GCP_COMPLETE_REP(Signal* signal)
{
if(m_active_buckets.get(i))
continue;
-
- if(c_buckets[i].m_buffer_tail != RNIL)
+
+ if (!c_subscriber_nodes.isclear())
{
//Uint32* dst;
get_buffer_ptr(signal, i, gci, 0);