diff options
author | unknown <jonas@perch.ndb.mysql.com> | 2007-04-10 10:05:01 +0200 |
---|---|---|
committer | unknown <jonas@perch.ndb.mysql.com> | 2007-04-10 10:05:01 +0200 |
commit | eaff83cb0ace80ec2165d5dba9b45284b4500e15 (patch) | |
tree | 4adf89c2bb0f7a832fe22e44a81f1f14e95ee59a /storage/ndb/src/kernel/blocks/suma | |
parent | 2c9c4508b17f5f7d2a9ae1e2823548a8eb4e7081 (diff) | |
download | mariadb-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.cpp | 10 |
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())); |