summaryrefslogtreecommitdiff
path: root/storage/ndb/src/kernel/blocks/suma
diff options
context:
space:
mode:
authorunknown <jonas@perch.ndb.mysql.com>2007-04-10 10:05:01 +0200
committerunknown <jonas@perch.ndb.mysql.com>2007-04-10 10:05:01 +0200
commiteaff83cb0ace80ec2165d5dba9b45284b4500e15 (patch)
tree4adf89c2bb0f7a832fe22e44a81f1f14e95ee59a /storage/ndb/src/kernel/blocks/suma
parent2c9c4508b17f5f7d2a9ae1e2823548a8eb4e7081 (diff)
downloadmariadb-git-eaff83cb0ace80ec2165d5dba9b45284b4500e15.tar.gz
ndb - bug#27728 (5.1)
Make sure API is connected to nodes when subscribing storage/ndb/include/kernel/signaldata/SumaImpl.hpp: new error code storage/ndb/src/kernel/blocks/suma/Suma.cpp: make sure API is connected in SUB_START_REQ storage/ndb/src/ndbapi/ndberror.c: new error code
Diffstat (limited to 'storage/ndb/src/kernel/blocks/suma')
-rw-r--r--storage/ndb/src/kernel/blocks/suma/Suma.cpp10
1 files changed, 10 insertions, 0 deletions
diff --git a/storage/ndb/src/kernel/blocks/suma/Suma.cpp b/storage/ndb/src/kernel/blocks/suma/Suma.cpp
index 1197ffdad94..717448ca03b 100644
--- a/storage/ndb/src/kernel/blocks/suma/Suma.cpp
+++ b/storage/ndb/src/kernel/blocks/suma/Suma.cpp
@@ -2394,6 +2394,16 @@ Suma::execSUB_START_REQ(Signal* signal){
sendSubStartRef(signal, 1412);
DBUG_VOID_RETURN;
}
+
+ if (c_startup.m_restart_server_node_id == 0 &&
+ !c_connected_nodes.get(refToNode(subscriberRef)))
+
+ {
+ jam();
+ sendSubStartRef(signal, SubStartRef::PartiallyConnected);
+ return;
+ }
+
DBUG_PRINT("info",("c_subscriberPool size: %d free: %d",
c_subscriberPool.getSize(),
c_subscriberPool.getNoOfFree()));