MySQL Lists are EOL. Please join:

List:Commits« Previous MessageNext Message »
From:lzhou Date:September 19 2006 6:08pm
Subject:bk commit into 5.1 tree (lzhou:1.2291)
View as plain text  
Below is the list of changes that have just been committed into a local
5.1 repository of root. When root does a push these changes will
be propagated to the main repository and, within 24 hours after the
push, to the public repository.
For information on how to access the public repository
see http://dev.mysql.com/doc/mysql/en/installing-source-tree.html

ChangeSet@stripped, 2006-09-19 18:08:14+00:00, lzhou@stripped +6 -0
  Merge dev3-138.dev.cn.tlan:/home/zhl/mysql/mysql-5.0/bug21799
  into  dev3-138.dev.cn.tlan:/home/zhl/mysql/mysql-5.1/bug21799
  MERGE: 1.1810.1697.128

  sql/ha_ndbcluster.cc@stripped, 2006-09-19 18:08:09+00:00, lzhou@stripped +0 -0
    Auto merged
    MERGE: 1.175.1.104

  sql/sql_base.cc@stripped, 2006-09-19 18:08:10+00:00, lzhou@stripped +0 -0
    Auto merged
    MERGE: 1.235.1.116

  sql/sql_view.cc@stripped, 2006-09-19 18:08:10+00:00, lzhou@stripped +0 -0
    Auto merged
    MERGE: 1.78.1.16

  storage/ndb/src/mgmclient/CommandInterpreter.cpp@stripped, 2006-09-19 18:08:10+00:00, lzhou@stripped +0 -0
    Auto merged
    MERGE: 1.49.21.3

  storage/ndb/src/mgmclient/CommandInterpreter.cpp@stripped, 2006-09-19 18:08:09+00:00, lzhou@stripped +0 -0
    Merge rename: ndb/src/mgmclient/CommandInterpreter.cpp -> storage/ndb/src/mgmclient/CommandInterpreter.cpp

  storage/ndb/src/ndbapi/NdbScanOperation.cpp@stripped, 2006-09-19 18:08:10+00:00, lzhou@stripped +0 -0
    Auto merged
    MERGE: 1.66.13.2

  storage/ndb/src/ndbapi/NdbScanOperation.cpp@stripped, 2006-09-19 18:08:09+00:00, lzhou@stripped +0 -0
    Merge rename: ndb/src/ndbapi/NdbScanOperation.cpp -> storage/ndb/src/ndbapi/NdbScanOperation.cpp

  storage/ndb/src/ndbapi/ndberror.c@stripped, 2006-09-19 18:08:10+00:00, lzhou@stripped +0 -0
    Auto merged
    MERGE: 1.30.28.3

  storage/ndb/src/ndbapi/ndberror.c@stripped, 2006-09-19 18:08:09+00:00, lzhou@stripped +0 -0
    Merge rename: ndb/src/ndbapi/ndberror.c -> storage/ndb/src/ndbapi/ndberror.c

# This is a BitKeeper patch.  What follows are the unified diffs for the
# set of deltas contained in the patch.  The rest of the patch, the part
# that BitKeeper cares about, is below these diffs.
# User:	lzhou
# Host:	dev3-138.dev.cn.tlan
# Root:	/home/zhl/mysql/mysql-5.1/bug21799/RESYNC

--- 1.49.21.2/ndb/src/mgmclient/CommandInterpreter.cpp	2006-09-19 18:08:20 +00:00
+++ 1.74/storage/ndb/src/mgmclient/CommandInterpreter.cpp	2006-09-19 18:08:20 +00:00
@@ -16,14 +16,7 @@
 
 #include <ndb_global.h>
 #include <my_sys.h>
-
-//#define HAVE_GLOBAL_REPLICATION
-
 #include <Vector.hpp>
-#ifdef  HAVE_GLOBAL_REPLICATION
-#include "../rep/repapi/repapi.h"
-#endif
-
 #include <mgmapi.h>
 #include <util/BaseString.hpp>
 
@@ -168,11 +161,6 @@
   int m_verbose;
   int try_reconnect;
   int m_error;
-#ifdef HAVE_GLOBAL_REPLICATION  
-  NdbRepHandle m_repserver;
-  const char *rep_host;
-  bool rep_connected;
-#endif
   struct NdbThread* m_event_thread;
   NdbMutex *m_print_mutex;
 };
@@ -237,10 +225,6 @@
 #include <NdbMem.h>
 #include <EventLogger.hpp>
 #include <signaldata/SetLogLevelOrd.hpp>
-#include <signaldata/GrepImpl.hpp>
-#ifdef HAVE_GLOBAL_REPLICATION
-
-#endif // HAVE_GLOBAL_REPLICATION
 #include "MgmtErrorReporter.hpp"
 #include <Parser.hpp>
 #include <SocketServer.hpp>
@@ -268,9 +252,6 @@
 "---------------------------------------------------------------------------\n"
 "HELP                                   Print help text\n"
 "HELP COMMAND                           Print detailed help for COMMAND(e.g. SHOW)\n"
-#ifdef HAVE_GLOBAL_REPLICATION
-"HELP REPLICATION                       Help for global replication\n"
-#endif // HAVE_GLOBAL_REPLICATION
 #ifdef VM_TRACE // DEBUG ONLY
 "HELP DEBUG                             Help for debug compiled version\n"
 #endif
@@ -294,9 +275,6 @@
 "EXIT SINGLE USER MODE                  Exit single user mode\n"
 "<id> STATUS                            Print status\n"
 "<id> CLUSTERLOG {<category>=<level>}+  Set log level for cluster log\n"
-#ifdef HAVE_GLOBAL_REPLICATION
-"REP CONNECT <host:port>                Connect to REP server on host:port\n"
-#endif
 "PURGE STALE SESSIONS                   Reset reserved nodeid's in the mgmt server\n"
 "CONNECT [<connectstring>]              Connect to management server (reconnect if already connected)\n"
 "QUIT                                   Quit management client\n"
@@ -596,39 +574,6 @@
 ;
 
 
-#ifdef HAVE_GLOBAL_REPLICATION
-static const char* helpTextRep =
-"---------------------------------------------------------------------------\n"
-" NDB Cluster -- Management Client -- Help for Global Replication\n"
-"---------------------------------------------------------------------------\n"
-"Commands should be executed on the standby NDB Cluster\n"
-"These features are in an experimental release state.\n"
-"\n"
-"Simple Commands:\n"
-"REP START              Start Global Replication\n" 
-"REP START REQUESTOR    Start Global Replication Requestor\n" 
-"REP STATUS             Show Global Replication status\n" 
-"REP STOP               Stop Global Replication\n"
-"REP STOP REQUESTOR     Stop Global Replication Requestor\n"
-"\n" 
-"Advanced Commands:\n"
-"REP START <protocol>   Starts protocol\n"
-"REP STOP <protocol>    Stops protocol\n"
-"<protocol> = TRANSFER | APPLY | DELETE\n"
-"\n"
-#ifdef VM_TRACE // DEBUG ONLY
-"Debugging commands:\n"
-"REP DELETE             Removes epochs stored in primary and standy systems\n"
-"REP DROP <tableid>     Drop a table in SS identified by table id\n"
-"REP SLOWSTOP           Stop Replication (Tries to synchonize with primary)\n" 
-"REP FASTSTOP           Stop Replication (Stops in consistent state)\n" 
-"<component> = SUBSCRIPTION\n"
-"              METALOG | METASCAN | DATALOG | DATASCAN\n"
-"              REQUESTOR | TRANSFER | APPLY | DELETE\n"
-#endif
-;
-#endif // HAVE_GLOBAL_REPLICATION
-
 #ifdef VM_TRACE // DEBUG ONLY
 static const char* helpTextDebug =
 "---------------------------------------------------------------------------\n"
@@ -681,10 +626,6 @@
   {"PURGE STALE SESSIONS", helpTextPurgeStaleSessions},
   {"CONNECT", helpTextConnect},
   {"QUIT", helpTextQuit},
-#ifdef HAVE_GLOBAL_REPLICATION
-  {"REPLICATION", helpTextRep},
-  {"REP", helpTextRep},
-#endif // HAVE_GLOBAL_REPLICATION
 #ifdef VM_TRACE // DEBUG ONLY
   {"DEBUG", helpTextDebug},
 #endif //VM_TRACE
@@ -724,11 +665,6 @@
   m_event_thread= NULL;
   try_reconnect = 0;
   m_print_mutex= NdbMutex_Create();
-#ifdef HAVE_GLOBAL_REPLICATION
-  rep_host = NULL;
-  m_repserver = NULL;
-  rep_connected = false;
-#endif
 }
 
 /*
@@ -1067,14 +1003,7 @@
   else if (strcasecmp(firstToken, "PURGE") == 0) {
     m_error = executePurge(allAfterFirstToken);
     DBUG_RETURN(true);
-  } 
-#ifdef HAVE_GLOBAL_REPLICATION
-  else if(strcasecmp(firstToken, "REPLICATION") == 0 ||
-	  strcasecmp(firstToken, "REP") == 0) {
-    m_error = executeRep(allAfterFirstToken);
-    DBUG_RETURN(true);
-  }
-#endif // HAVE_GLOBAL_REPLICATION
+  }                
   else if(strcasecmp(firstToken, "ENTER") == 0 &&
 	  allAfterFirstToken != NULL &&
 	  strncasecmp(allAfterFirstToken, "SINGLE USER MODE ", 
@@ -1629,8 +1558,6 @@
       case NDB_MGM_NODE_TYPE_UNKNOWN:
         ndbout << "Error: Unknown Node Type" << endl;
         return -1;
-      case NDB_MGM_NODE_TYPE_REP:
-	abort();
       }
     }
 
@@ -2642,234 +2569,5 @@
   ndbout << "Invalid arguments: expected <BackupId>" << endl;
   return -1;
 }
-
-#ifdef HAVE_GLOBAL_REPLICATION
-/*****************************************************************************
- * Global Replication
- *
- * For information about the different commands, see
- * GrepReq::Request in file signaldata/grepImpl.cpp.
- *
- * Below are commands as of 2003-07-05 (may change!):
- * START = 0,            ///< Start Global Replication (all phases)
- * START_METALOG = 1,    ///< Start Global Replication (all phases)
- * START_METASCAN = 2,   ///< Start Global Replication (all phases)
- * START_DATALOG = 3,    ///< Start Global Replication (all phases)
- * START_DATASCAN = 4,   ///< Start Global Replication (all phases)
- * START_REQUESTOR = 5,  ///< Start Global Replication (all phases)
- * ABORT = 6,            ///< Immediate stop (removes subscription)
- * SLOW_STOP = 7,        ///< Stop after finishing applying current GCI epoch
- * FAST_STOP = 8,        ///< Stop after finishing applying all PS GCI epochs
- * START_TRANSFER = 9,   ///< Start SS-PS transfer
- * STOP_TRANSFER = 10,   ///< Stop SS-PS transfer
- * START_APPLY = 11,     ///< Start applying GCI epochs in SS
- * STOP_APPLY = 12,      ///< Stop applying GCI epochs in SS
- * STATUS = 13,           ///< Status
- * START_SUBSCR = 14,
- * REMOVE_BUFFERS = 15,
- * DROP_TABLE = 16
-
- *****************************************************************************/
-
-int
-CommandInterpreter::executeRep(char* parameters) 
-{
-  if (emptyString(parameters)) {
-    ndbout << helpTextRep;
-    return 0;
-  }
-
-  char * line = my_strdup(parameters,MYF(MY_WME));
-  My_auto_ptr<char> ap1((char*)line);
-  char * firstToken = strtok(line, " ");
-  
-  struct ndb_rep_reply  reply;
-  unsigned int          repId;
-
-
-  if (!strcasecmp(firstToken, "CONNECT")) {
-    char * host = strtok(NULL, "\0");
-    for (unsigned int i = 0; i < strlen(host); ++i) {
-      host[i] = tolower(host[i]);
-    }
-    
-    if(host == NULL)
-    {
-      ndbout_c("host:port must be specified.");
-      return -1;
-    }
-    
-    if(rep_connected) {
-      if(m_repserver != NULL) {
-	ndb_rep_disconnect(m_repserver);
-	rep_connected = false;
-      }       
-    }
-          
-    if(m_repserver == NULL)
-      m_repserver = ndb_rep_create_handle();
-    if(ndb_rep_connect(m_repserver, host) < 0){
-      ndbout_c("Failed to connect to %s", host);
-      return -1;
-    } 
-    else
-      rep_connected=true;
-    return 0;
-    
-    if(!rep_connected) {
-      ndbout_c("Not connected to REP server");
-      return -1;
-    }
-  }
-    
-  /********
-   * START 
-   ********/
-  if (!strcasecmp(firstToken, "START")) {
-    
-    unsigned int          req;
-    char *startType = strtok(NULL, "\0");
-    
-    if (startType == NULL) {                
-      req = GrepReq::START;
-    } else if (!strcasecmp(startType, "SUBSCRIPTION")) {  
-      req = GrepReq::START_SUBSCR;
-    } else if (!strcasecmp(startType, "METALOG")) { 
-      req = GrepReq::START_METALOG;
-    } else if (!strcasecmp(startType, "METASCAN")) {
-      req = GrepReq::START_METASCAN;
-    } else if (!strcasecmp(startType, "DATALOG")) {
-      req = GrepReq::START_DATALOG;
-    } else if (!strcasecmp(startType, "DATASCAN")) {
-      req = GrepReq::START_DATASCAN;
-    } else if (!strcasecmp(startType, "REQUESTOR")) {
-      req = GrepReq::START_REQUESTOR;
-    } else if (!strcasecmp(startType, "TRANSFER")) {
-      req = GrepReq::START_TRANSFER;
-    } else if (!strcasecmp(startType, "APPLY")) {
-      req = GrepReq::START_APPLY;
-    } else if (!strcasecmp(startType, "DELETE")) {
-      req = GrepReq::START_DELETE;
-    } else {
-      ndbout_c("Illegal argument to command 'REPLICATION START'");
-      return -1;
-    }
-
-    int result = ndb_rep_command(m_repserver, req, &repId, &reply);
-    
-    if (result != 0) {
-      ndbout << "Start of Global Replication failed" << endl;
-      return -1;
-    } else {
-      ndbout << "Start of Global Replication ordered" << endl;
-    }
-    return 0;
-  }
-
-  /********
-   * STOP
-   ********/
-  if (!strcasecmp(firstToken, "STOP")) {    
-    unsigned int          req;
-    char *startType = strtok(NULL, " ");
-    unsigned int epoch = 0;
-    
-    if (startType == NULL) {                 
-      /**
-       * Stop immediately
-       */
-      req = GrepReq::STOP;
-    } else if (!strcasecmp(startType, "EPOCH")) {  
-      char *strEpoch = strtok(NULL, "\0");
-      if(strEpoch == NULL) {
-	ndbout_c("Epoch expected!");
-	return -1;
-      }
-      req = GrepReq::STOP;
-      epoch=atoi(strEpoch);      
-    } else if (!strcasecmp(startType, "SUBSCRIPTION")) {  
-      req = GrepReq::STOP_SUBSCR;
-    } else if (!strcasecmp(startType, "METALOG")) { 
-      req = GrepReq::STOP_METALOG;
-    } else if (!strcasecmp(startType, "METASCAN")) {
-      req = GrepReq::STOP_METASCAN;
-    } else if (!strcasecmp(startType, "DATALOG")) {
-      req = GrepReq::STOP_DATALOG;
-    } else if (!strcasecmp(startType, "DATASCAN")) {
-      req = GrepReq::STOP_DATASCAN;
-    } else if (!strcasecmp(startType, "REQUESTOR")) {
-      req = GrepReq::STOP_REQUESTOR;
-    } else if (!strcasecmp(startType, "TRANSFER")) {
-      req = GrepReq::STOP_TRANSFER;
-    } else if (!strcasecmp(startType, "APPLY")) {
-      req = GrepReq::STOP_APPLY;
-    } else if (!strcasecmp(startType, "DELETE")) {
-      req = GrepReq::STOP_DELETE;
-    } else {
-      ndbout_c("Illegal argument to command 'REPLICATION STOP'");
-      return -1;
-    }
-    int result = ndb_rep_command(m_repserver, req, &repId, &reply, epoch);
-    
-    if (result != 0) {
-      ndbout << "Stop command failed" << endl;
-      return -1;
-    } else {
-      ndbout << "Stop ordered" << endl;
-    }
-    return 0;
-  }
-
-  /*********
-   * STATUS
-   *********/
-  if (!strcasecmp(firstToken, "STATUS")) {
-    struct rep_state repstate;
-    int result = 
-      ndb_rep_get_status(m_repserver, &repId, &reply, &repstate);
-    
-    if (result != 0) {
-      ndbout << "Status request of Global Replication failed" << endl;
-      return -1;
-    } else {
-      ndbout << "Status request of Global Replication ordered" << endl;
-      ndbout << "See printout at one of the DB nodes" << endl;
-      ndbout << "(Better status report is under development.)" << endl;
-      ndbout << " SubscriptionId " << repstate.subid 
-	     << " SubscriptionKey " << repstate.subkey << endl;
-    }
-    return 0;
-  }
-
-  /*********
-   * QUERY (see repapi.h for querable counters)
-   *********/
-  if (!strcasecmp(firstToken, "QUERY")) {
-    char *query = strtok(NULL, "\0");
-    int queryCounter=-1;
-    if(query != NULL) {
-      queryCounter = atoi(query);
-    }
-    struct rep_state repstate;
-    unsigned repId = 0;
-    int result = ndb_rep_query(m_repserver, (QueryCounter)queryCounter,
-			       &repId, &reply, &repstate);
-    
-    if (result != 0) {
-      ndbout << "Query repserver failed" << endl;
-      return -1;
-    } else {
-      ndbout << "Query repserver sucessful" << endl;
-      ndbout_c("repstate : QueryCounter %d, f=%d l=%d"
-	       " nodegroups %d" , 
-	       repstate.queryCounter,
-	       repstate.first[0], repstate.last[0],
-	       repstate.no_of_nodegroups );
-    }
-    return 0;
-  }
-  return 0;
-}
-#endif // HAVE_GLOBAL_REPLICATION
 
 template class Vector<char const*>;

--- 1.66.13.1/ndb/src/ndbapi/NdbScanOperation.cpp	2006-09-19 18:08:20 +00:00
+++ 1.94/storage/ndb/src/ndbapi/NdbScanOperation.cpp	2006-09-19 18:08:20 +00:00
@@ -50,6 +50,7 @@
   m_receivers = 0;
   m_array = new Uint32[1]; // skip if on delete in fix_receivers
   theSCAN_TABREQ = 0;
+  m_executed = false;
 }
 
 NdbScanOperation::~NdbScanOperation()
@@ -111,6 +112,7 @@
   theNdbCon->theMagicNumber = 0xFE11DF;
   theNoOfTupKeyLeft = tab->m_noOfDistributionKeys;
   m_read_range_no = 0;
+  m_executed = false;
   return 0;
 }
 
@@ -162,6 +164,16 @@
   }
 
   m_keyInfo = ((scan_flags & SF_KeyInfo) || lockExcl) ? 1 : 0;
+  bool tupScan = (scan_flags & SF_TupScan);
+
+#if 1 // XXX temp for testing
+  { char* p = getenv("NDB_USE_TUPSCAN");
+    if (p != 0) {
+      unsigned n = atoi(p); // 0-10
+      if ((unsigned int) (::time(0) % 10) < n) tupScan = true;
+    }
+  }
+#endif
 
   bool rangeScan = false;
   if (m_accessTable->m_indexType == NdbDictionary::Index::OrderedIndex)
@@ -177,12 +189,9 @@
     theStatus = GetValue;
     theOperationType  = OpenRangeScanRequest;
     rangeScan = true;
-  }
-
-  bool tupScan = (scan_flags & SF_TupScan);
-  if (tupScan && rangeScan)
     tupScan = false;
-
+  }
+  
   if (rangeScan && (scan_flags & SF_OrderBy))
     parallel = fragCount;
   
@@ -202,7 +211,7 @@
   theSCAN_TABREQ->setSignal(GSN_SCAN_TABREQ);
   ScanTabReq * req = CAST_PTR(ScanTabReq, theSCAN_TABREQ->getDataPtrSend());
   req->apiConnectPtr = theNdbCon->theTCConPtr;
-  req->tableId = m_accessTable->m_tableId;
+  req->tableId = m_accessTable->m_id;
   req->tableSchemaVersion = m_accessTable->m_version;
   req->storedProcId = 0xFFFF;
   req->buddyConPtr = theNdbCon->theBuddyConPtr;
@@ -363,7 +372,7 @@
 int
 NdbScanOperation::executeCursor(int nodeId){
   NdbTransaction * tCon = theNdbCon;
-  TransporterFacade* tp = TransporterFacade::instance();
+  TransporterFacade* tp = theNdb->theImpl->m_transporter_facade;
   Guard guard(tp->theMutexPtr);
 
   Uint32 magic = tCon->theMagicNumber;
@@ -385,6 +394,7 @@
     if (doSendScan(nodeId) == -1)
       return -1;
 
+    m_executed= true; // Mark operation as executed
     return 0;
   } else {
     if (!(tp->get_node_stopping(nodeId) &&
@@ -464,17 +474,29 @@
   }
   
   Uint32 nodeId = theNdbCon->theDBnode;
-  TransporterFacade* tp = TransporterFacade::instance();
-  Guard guard(tp->theMutexPtr);
-  if(theError.code)
-    return -1;
+  TransporterFacade* tp = theNdb->theImpl->m_transporter_facade;
+  /*
+    The PollGuard has an implicit call of unlock_and_signal through the
+    ~PollGuard method. This method is called implicitly by the compiler
+    in all places where the object is out of context due to a return,
+    break, continue or simply end of statement block
+  */
+  PollGuard poll_guard(tp, &theNdb->theImpl->theWaiter,
+                       theNdb->theNdbBlockNumber);
 
-  Uint32 seq = theNdbCon->theNodeSequence;
-  if(seq == tp->getNodeSequence(nodeId) && send_next_scan(idx, false,
-							  forceSend) == 0){
+  const Uint32 seq = theNdbCon->theNodeSequence;
+
+  if(theError.code)
+  {
+    goto err4;
+  }
+  
+  if(seq == tp->getNodeSequence(nodeId) && send_next_scan(idx, false) == 0)
+  {
       
     idx = m_current_api_receiver;
     last = m_api_receivers_count;
+    Uint32 timeout = tp->m_waitfor_timeout;
       
     do {
       if(theError.code){
@@ -500,10 +522,8 @@
 	/**
 	 * No completed...
 	 */
-	theNdb->theImpl->theWaiter.m_node = nodeId;
-	theNdb->theImpl->theWaiter.m_state = WAIT_SCAN;
-	int return_code = theNdb->receiveResponse(WAITFOR_SCAN_TIMEOUT);
-	if (return_code == 0 && seq == tp->getNodeSequence(nodeId)) {
+        int ret_code= poll_guard.wait_scan(3*timeout, nodeId, forceSend);
+	if (ret_code == 0 && seq == tp->getNodeSequence(nodeId)) {
 	  continue;
 	} else if(return_code == -1){
 	  retVal = -1;
@@ -555,6 +575,10 @@
     if(theError.code == 0)
       setErrorCode(4028); // seq changed = Node fail
     break;
+  case -4:
+err4:
+    setErrorCode(theError.code);
+    break;
   }
     
   theNdbCon->theTransactionIsStarted = false;
@@ -564,8 +588,8 @@
 }
 
 int
-NdbScanOperation::send_next_scan(Uint32 cnt, bool stopScanFlag,
-				 bool forceSend){  
+NdbScanOperation::send_next_scan(Uint32 cnt, bool stopScanFlag)
+{
   if(cnt > 0){
     NdbApiSignal tSignal(theNdb->theMyRef);
     tSignal.setSignal(GSN_SCAN_NEXTREQ);
@@ -600,7 +624,7 @@
     if(sent)
     {
       Uint32 nodeId = theNdbCon->theDBnode;
-      TransporterFacade * tp = TransporterFacade::instance();
+      TransporterFacade * tp = theNdb->theImpl->m_transporter_facade;
       if(cnt > 21){
 	tSignal.setLength(4);
 	LinearSectionPtr ptr[3];
@@ -612,9 +636,6 @@
 	ret = tp->sendSignal(&tSignal, nodeId);
       }
     }
-    
-    if (!ret) checkForceSend(forceSend);
-
     m_sent_receivers_count = last + sent;
     m_api_receivers_count -= cnt;
     m_current_api_receiver = 0;
@@ -624,15 +645,6 @@
   return 0;
 }
 
-void NdbScanOperation::checkForceSend(bool forceSend)
-{
-  if (forceSend) {
-    TransporterFacade::instance()->forceSend(theNdb->theNdbBlockNumber);
-  } else {
-    TransporterFacade::instance()->checkForceSend(theNdb->theNdbBlockNumber);
-  }//if
-}
-
 int 
 NdbScanOperation::prepareSend(Uint32  TC_ConnectPtr, Uint64  TransactionId)
 {
@@ -667,10 +679,16 @@
 	       m_conf_receivers_count,
 	       m_sent_receivers_count);
     
-    TransporterFacade* tp = TransporterFacade::instance();
-    Guard guard(tp->theMutexPtr);
-    close_impl(tp, forceSend);
-    
+    TransporterFacade* tp = theNdb->theImpl->m_transporter_facade;
+    /*
+      The PollGuard has an implicit call of unlock_and_signal through the
+      ~PollGuard method. This method is called implicitly by the compiler
+      in all places where the object is out of context due to a return,
+      break, continue or simply end of statement block
+    */
+    PollGuard poll_guard(tp, &theNdb->theImpl->theWaiter,
+                         theNdb->theNdbBlockNumber);
+    close_impl(tp, forceSend, &poll_guard);
   }
 
   NdbConnection* tCon = theNdbCon;
@@ -680,7 +698,7 @@
 
   if (releaseOp && tTransCon) {
     NdbIndexScanOperation* tOp = (NdbIndexScanOperation*)this;
-    tTransCon->releaseExecutedScanOperation(tOp);
+    tTransCon->releaseScanOperation(tOp);
   }
   
   tCon->theScanningOp = 0;
@@ -775,6 +793,7 @@
    */
   Uint32 reqInfo = req->requestInfo;
   ScanTabReq::setKeyinfoFlag(reqInfo, keyInfo);
+  ScanTabReq::setNoDiskFlag(reqInfo, m_no_disk_flag);
   req->requestInfo = reqInfo;
   
   for(Uint32 i = 0; i<theParallelism; i++){
@@ -825,7 +844,7 @@
   req->requestInfo = tmp;
   tSignal->setLength(ScanTabReq::StaticLength + theDistrKeyIndicator_);
 
-  TransporterFacade *tp = TransporterFacade::instance();
+  TransporterFacade *tp = theNdb->theImpl->m_transporter_facade;
   LinearSectionPtr ptr[3];
   ptr[0].p = m_prepared_receivers;
   ptr[0].sz = theParallelism;
@@ -909,13 +928,20 @@
  *     the scan process. 
  ****************************************************************************/
 int
-NdbScanOperation::getKeyFromKEYINFO20(Uint32* data, unsigned size)
+NdbScanOperation::getKeyFromKEYINFO20(Uint32* data, Uint32 & size)
 {
   NdbRecAttr * tRecAttr = m_curr_row;
   if(tRecAttr)
   {
     const Uint32 * src = (Uint32*)tRecAttr->aRef();
-    memcpy(data, src, 4*size);
+
+    assert(tRecAttr->get_size_in_bytes() > 0);
+    assert(tRecAttr->get_size_in_bytes() < 65536);
+    const Uint32 len = (tRecAttr->get_size_in_bytes() + 3)/4-1;
+
+    assert(size >= len);
+    memcpy(data, src, 4*len);
+    size = len;
     return 0;
   }
   return -1;
@@ -940,8 +966,10 @@
     }
     pTrans->theSimpleState = 0;
     
-    const Uint32 len = (tRecAttr->attrSize() * tRecAttr->arraySize() + 3)/4-1;
-
+    assert(tRecAttr->get_size_in_bytes() > 0);
+    assert(tRecAttr->get_size_in_bytes() < 65536);
+    const Uint32 len = (tRecAttr->get_size_in_bytes() + 3)/4-1;
+    
     newOp->theTupKeyLen = len;
     newOp->theOperationType = opType;
     switch (opType) {
@@ -1039,23 +1067,23 @@
 
 int
 NdbIndexScanOperation::setBound(const char* anAttrName, int type, 
-				const void* aValue, Uint32 len)
+				const void* aValue)
 {
-  return setBound(m_accessTable->getColumn(anAttrName), type, aValue, len);
+  return setBound(m_accessTable->getColumn(anAttrName), type, aValue);
 }
 
 int
 NdbIndexScanOperation::setBound(Uint32 anAttrId, int type, 
-				const void* aValue, Uint32 len)
+				const void* aValue)
 {
-  return setBound(m_accessTable->getColumn(anAttrId), type, aValue, len);
+  return setBound(m_accessTable->getColumn(anAttrId), type, aValue);
 }
 
 int
 NdbIndexScanOperation::equal_impl(const NdbColumnImpl* anAttrObject, 
-				  const char* aValue, 
-				  Uint32 len){
-  return setBound(anAttrObject, BoundEQ, aValue, len);
+				  const char* aValue)
+{
+  return setBound(anAttrObject, BoundEQ, aValue);
 }
 
 NdbRecAttr*
@@ -1065,7 +1093,7 @@
     return NdbScanOperation::getValue_impl(attrInfo, aValue);
   }
   
-  int id = attrInfo->m_attrId;                // In "real" table
+  int id = attrInfo->getColumnNo();                // In "real" table
   assert(m_accessTable->m_index);
   int sz = (int)m_accessTable->m_index->m_key_ids.size();
   if(id >= sz || (id = m_accessTable->m_index->m_key_ids[id]) == -1){
@@ -1102,7 +1130,7 @@
  */
 int
 NdbIndexScanOperation::setBound(const NdbColumnImpl* tAttrInfo, 
-				int type, const void* aValue, Uint32 len)
+				int type, const void* aValue)
 {
   if (!tAttrInfo)
   {
@@ -1110,24 +1138,23 @@
     return -1;
   }
   if (theOperationType == OpenRangeScanRequest &&
-      (0 <= type && type <= 4) &&
-      len <= 8000) {
+      (0 <= type && type <= 4)) {
     // insert bound type
     Uint32 currLen = theTotalNrOfKeyWordInSignal;
     Uint32 remaining = KeyInfo::DataLength - currLen;
-    Uint32 sizeInBytes = tAttrInfo->m_attrSize * tAttrInfo->m_arraySize;
     bool tDistrKey = tAttrInfo->m_distributionKey;
 
-    len = aValue != NULL ? sizeInBytes : 0;
-    if (len != sizeInBytes && (len != 0)) {
-      setErrorCodeAbort(4209);
-      return -1;
-    }
+    Uint32 len = 0;
+    if (aValue != NULL)
+      if (! tAttrInfo->get_var_length(aValue, len)) {
+        setErrorCodeAbort(4209);
+        return -1;
+      }
 
     // insert attribute header
     Uint32 tIndexAttrId = tAttrInfo->m_attrId;
     Uint32 sizeInWords = (len + 3) / 4;
-    AttributeHeader ah(tIndexAttrId, sizeInWords);
+    AttributeHeader ah(tIndexAttrId, sizeInWords << 2);
     const Uint32 ahValue = ah.m_value;
 
     const Uint32 align = (UintPtr(aValue) & 7);
@@ -1221,6 +1248,31 @@
   return -1;
 }
 
+Uint32
+NdbIndexScanOperation::getKeyFromSCANTABREQ(Uint32* data, Uint32 size)
+{
+  DBUG_ENTER("NdbIndexScanOperation::getKeyFromSCANTABREQ");
+  assert(size >= theTotalNrOfKeyWordInSignal);
+  size = theTotalNrOfKeyWordInSignal;
+  NdbApiSignal* tSignal = theSCAN_TABREQ->next();
+  Uint32 pos = 0;
+  while (pos < size) {
+    assert(tSignal != NULL);
+    Uint32* tData = tSignal->getDataPtrSend();
+    Uint32 rem = size - pos;
+    if (rem > KeyInfo::DataLength)
+      rem = KeyInfo::DataLength;
+    Uint32 i = 0;
+    while (i < rem) {
+      data[pos + i] = tData[KeyInfo::HeaderLength + i];
+      i++;
+    }
+    pos += rem;
+  }
+  DBUG_DUMP("key", (char*)data, size << 2);
+  DBUG_RETURN(size);
+}
+
 int
 NdbIndexScanOperation::readTuples(LockMode lm,
 				  Uint32 scan_flags,
@@ -1320,10 +1372,11 @@
       return (r1_null ? -1 : 1) * jdir;
     }
     const NdbColumnImpl & col = NdbColumnImpl::getImpl(* r1->m_column);
-    Uint32 len = r1->theAttrSize * r1->theArraySize;
+    Uint32 len1 = r1->get_size_in_bytes();
+    Uint32 len2 = r2->get_size_in_bytes();
     if(!r1_null){
       const NdbSqlUtil::Type& sqlType = NdbSqlUtil::getType(col.m_type);
-      int r = (*sqlType.m_cmp)(col.m_cs, d1, len, d2, len, true);
+      int r = (*sqlType.m_cmp)(col.m_cs, d1, len1, d2, len2, true);
       if(r){
 	assert(r != NdbSqlUtil::CmpUnknown);
 	return r * jdir;
@@ -1361,21 +1414,27 @@
   if(fetchNeeded){
     if(fetchAllowed){
       if(DEBUG_NEXT_RESULT) ndbout_c("performing fetch...");
-      TransporterFacade* tp = TransporterFacade::instance();
-      Guard guard(tp->theMutexPtr);
+      TransporterFacade* tp = theNdb->theImpl->m_transporter_facade;
+      /*
+        The PollGuard has an implicit call of unlock_and_signal through the
+        ~PollGuard method. This method is called implicitly by the compiler
+        in all places where the object is out of context due to a return,
+        break, continue or simply end of statement block
+      */
+      PollGuard poll_guard(tp, &theNdb->theImpl->theWaiter,
+                           theNdb->theNdbBlockNumber);
       if(theError.code)
 	return -1;
       Uint32 seq = theNdbCon->theNodeSequence;
       Uint32 nodeId = theNdbCon->theDBnode;
+      Uint32 timeout = tp->m_waitfor_timeout;
       if(seq == tp->getNodeSequence(nodeId) &&
-	 !send_next_scan_ordered(s_idx, forceSend)){
+	 !send_next_scan_ordered(s_idx)){
 	Uint32 tmp = m_sent_receivers_count;
 	s_idx = m_current_api_receiver; 
 	while(m_sent_receivers_count > 0 && !theError.code){
-	  theNdb->theImpl->theWaiter.m_node = nodeId;
-	  theNdb->theImpl->theWaiter.m_state = WAIT_SCAN;
-	  int return_code = theNdb->receiveResponse(WAITFOR_SCAN_TIMEOUT);
-	  if (return_code == 0 && seq == tp->getNodeSequence(nodeId)) {
+          int ret_code= poll_guard.wait_scan(3*timeout, nodeId, forceSend);
+	  if (ret_code == 0 && seq == tp->getNodeSequence(nodeId)) {
 	    continue;
 	  }
 	  if(DEBUG_NEXT_RESULT) ndbout_c("return -1");
@@ -1466,7 +1525,8 @@
 }
 
 int
-NdbIndexScanOperation::send_next_scan_ordered(Uint32 idx, bool forceSend){  
+NdbIndexScanOperation::send_next_scan_ordered(Uint32 idx)
+{
   if(idx == theParallelism)
     return 0;
   
@@ -1501,15 +1561,16 @@
   m_sent_receivers_count = last + 1;
   
   Uint32 nodeId = theNdbCon->theDBnode;
-  TransporterFacade * tp = TransporterFacade::instance();
+  TransporterFacade * tp = theNdb->theImpl->m_transporter_facade;
   tSignal.setLength(4+1);
   int ret= tp->sendSignal(&tSignal, nodeId);
-  if (!ret) checkForceSend(forceSend);
   return ret;
 }
 
 int
-NdbScanOperation::close_impl(TransporterFacade* tp, bool forceSend){
+NdbScanOperation::close_impl(TransporterFacade* tp, bool forceSend,
+                             PollGuard *poll_guard)
+{
   Uint32 seq = theNdbCon->theNodeSequence;
   Uint32 nodeId = theNdbCon->theDBnode;
   
@@ -1519,14 +1580,13 @@
     return -1;
   }
   
+  Uint32 timeout = tp->m_waitfor_timeout;
   /**
    * Wait for outstanding
    */
   while(theError.code == 0 && m_sent_receivers_count)
   {
-    theNdb->theImpl->theWaiter.m_node = nodeId;
-    theNdb->theImpl->theWaiter.m_state = WAIT_SCAN;
-    int return_code = theNdb->receiveResponse(WAITFOR_SCAN_TIMEOUT);
+    int return_code= poll_guard->wait_scan(3*timeout, nodeId, forceSend);
     switch(return_code){
     case 0:
       break;
@@ -1583,7 +1643,7 @@
   }
   
   // Send close scan
-  if(send_next_scan(api+conf, true, forceSend) == -1)
+  if(send_next_scan(api+conf, true) == -1)
   {
     theNdbCon->theReleaseOnClose = true;
     return -1;
@@ -1594,9 +1654,7 @@
    */
   while(m_sent_receivers_count+m_api_receivers_count+m_conf_receivers_count)
   {
-    theNdb->theImpl->theWaiter.m_node = nodeId;
-    theNdb->theImpl->theWaiter.m_state = WAIT_SCAN;
-    int return_code = theNdb->receiveResponse(WAITFOR_SCAN_TIMEOUT);
+    int return_code= poll_guard->wait_scan(3*timeout, nodeId, forceSend);
     switch(return_code){
     case 0:
       break;
@@ -1635,13 +1693,20 @@
 NdbScanOperation::restart(bool forceSend)
 {
   
-  TransporterFacade* tp = TransporterFacade::instance();
-  Guard guard(tp->theMutexPtr);
+  TransporterFacade* tp = theNdb->theImpl->m_transporter_facade;
+  /*
+    The PollGuard has an implicit call of unlock_and_signal through the
+    ~PollGuard method. This method is called implicitly by the compiler
+    in all places where the object is out of context due to a return,
+    break, continue or simply end of statement block
+  */
+  PollGuard poll_guard(tp, &theNdb->theImpl->theWaiter,
+                       theNdb->theNdbBlockNumber);
   Uint32 nodeId = theNdbCon->theDBnode;
   
   {
     int res;
-    if((res= close_impl(tp, forceSend)))
+    if((res= close_impl(tp, forceSend, &poll_guard)))
     {
       return res;
     }
@@ -1655,7 +1720,6 @@
   theError.code = 0;
   if (doSendScan(nodeId) == -1)
     return -1;
-  
   return 0;
 }
 
@@ -1664,9 +1728,16 @@
   int res;
   
   {
-    TransporterFacade* tp = TransporterFacade::instance();
-    Guard guard(tp->theMutexPtr);
-    res= close_impl(tp, forceSend);
+    TransporterFacade* tp = theNdb->theImpl->m_transporter_facade;
+    /*
+      The PollGuard has an implicit call of unlock_and_signal through the
+      ~PollGuard method. This method is called implicitly by the compiler
+      in all places where the object is out of context due to a return,
+      break, continue or simply end of statement block
+    */
+    PollGuard poll_guard(tp, &theNdb->theImpl->theWaiter,
+                         theNdb->theNdbBlockNumber);
+    res= close_impl(tp, forceSend, &poll_guard);
   }
 
   if(!res)

--- 1.30.28.2/ndb/src/ndbapi/ndberror.c	2006-09-19 18:08:20 +00:00
+++ 1.74/storage/ndb/src/ndbapi/ndberror.c	2006-09-19 18:08:20 +00:00
@@ -16,11 +16,13 @@
 
 
 #include <ndb_global.h>
+#include <my_base.h>
 #include <ndberror.h>
 #include <m_string.h>
 
 typedef struct ErrorBundle {
   int code;
+  int mysql_code;
   ndberror_classification classification;
   const char * message;
 } ErrorBundle;
@@ -57,6 +59,11 @@
 
 #define OE ndberror_cl_schema_object_already_exists
 
+#define IT ndberror_cl_internal_temporary
+
+/* default mysql error code for unmapped codes */
+#define DMEC -1
+
 static const char* empty_string = "";
 
 /*
@@ -71,6 +78,10 @@
  *  900 - TUX
  * 1200 - LQH
  * 1300 - BACKUP
+ * 1400 - SUMA
+ * 1500 - LGMAN
+ * 1600 - TSMAN
+ * 1700 - QMGR
  * 4000 - API
  * 4100 - ""
  * 4200 - ""
@@ -88,442 +99,519 @@
   /**
    * No error
    */
-  { 0,    NE, "No error" },
+  { 0,    0, NE, "No error" },
   
   /**
    * NoDataFound
    */
-  { 626,  ND, "Tuple did not exist" },
+  { 626,  HA_ERR_KEY_NOT_FOUND, ND, "Tuple did not exist" },
 
   /**
    * ConstraintViolation 
    */
-  { 630,  CV, "Tuple already existed when attempting to insert" },
-  { 840,  CV, "Trying to set a NOT NULL attribute to NULL" },
-  { 893,  CV, "Constraint violation e.g. duplicate value in unique index" },
+  { 630,  HA_ERR_FOUND_DUPP_KEY, CV, "Tuple already existed when attempting to insert" },
+  { 839,  DMEC, CV, "Illegal null attribute" },
+  { 840,  DMEC, CV, "Trying to set a NOT NULL attribute to NULL" },
+  { 893,  HA_ERR_FOUND_DUPP_KEY, CV, "Constraint violation e.g. duplicate value in unique index" },
 
   /**
    * Node recovery errors
    */
-  {  286, NR, "Node failure caused abort of transaction" }, 
-  {  250, NR, "Node where lock was held crashed, restart scan transaction" },
-  {  499, NR, "Scan take over error, restart scan transaction" },  
-  { 1204, NR, "Temporary failure, distribution changed" },
-  { 4002, NR, "Send to NDB failed" },
-  { 4010, NR, "Node failure caused abort of transaction" }, 
-  { 4025, NR, "Node failure caused abort of transaction" }, 
-  { 4027, NR, "Node failure caused abort of transaction" },
-  { 4028, NR, "Node failure caused abort of transaction" },
-  { 4029, NR, "Node failure caused abort of transaction" },
-  { 4031, NR, "Node failure caused abort of transaction" },
-  { 4033, NR, "Send to NDB failed" },
-  { 4115, NR, 
+  {  286, DMEC, NR, "Node failure caused abort of transaction" }, 
+  {  250, DMEC, NR, "Node where lock was held crashed, restart scan transaction" },
+  {  499, DMEC, NR, "Scan take over error, restart scan transaction" },  
+  { 1204, DMEC, NR, "Temporary failure, distribution changed" },
+  { 4002, DMEC, NR, "Send to NDB failed" },
+  { 4010, DMEC, NR, "Node failure caused abort of transaction" }, 
+  { 4025, DMEC, NR, "Node failure caused abort of transaction" }, 
+  { 4027, DMEC, NR, "Node failure caused abort of transaction" },
+  { 4028, DMEC, NR, "Node failure caused abort of transaction" },
+  { 4029, DMEC, NR, "Node failure caused abort of transaction" },
+  { 4031, DMEC, NR, "Node failure caused abort of transaction" },
+  { 4033, DMEC, NR, "Send to NDB failed" },
+  { 4115, DMEC, NR, 
     "Transaction was committed but all read information was not "
     "received due to node crash" },
-  { 4119, NR, "Simple/dirty read failed due to node failure" },
+  { 4119, DMEC, NR, "Simple/dirty read failed due to node failure" },
   
   /**
    * Node shutdown
    */
-  {  280, NS, "Transaction aborted due to node shutdown" },
+  {  280, DMEC, NS, "Transaction aborted due to node shutdown" },
   /* This scan trans had an active fragment scan in a LQH which have crashed */
-  {  270, NS, "Transaction aborted due to node shutdown" }, 
-  { 1223, NS, "Read operation aborted due to node shutdown" },
-  { 4023, NS, "Transaction aborted due to node shutdown" },
-  { 4030, NS, "Transaction aborted due to node shutdown" },
-  { 4034, NS, "Transaction aborted due to node shutdown" },
+  {  270, DMEC, NS, "Transaction aborted due to node shutdown" }, 
+  { 1223, DMEC, NS, "Read operation aborted due to node shutdown" },
+  { 4023, DMEC, NS, "Transaction aborted due to node shutdown" },
+  { 4030, DMEC, NS, "Transaction aborted due to node shutdown" },
+  { 4034, DMEC, NS, "Transaction aborted due to node shutdown" },
 
 
   
   /**
    * Unknown result
    */
-  { 4008, UR, "Receive from NDB failed" },
-  { 4009, UR, "Cluster Failure" },
-  { 4012, UR, 
+  { 4008, DMEC, UR, "Receive from NDB failed" },
+  { 4009, DMEC, UR, "Cluster Failure" },
+  { 4012, DMEC, UR, 
     "Request ndbd time-out, maybe due to high load or communication problems"}, 
-  { 4024, UR, 
+  { 4024, DMEC, UR, 
     "Time-out, most likely caused by simple read or cluster failure" }, 
   
   /**
    * TemporaryResourceError
    */
-  { 217,  TR, "217" },
-  { 218,  TR, "218" },
-  { 219,  TR, "219" },
-  { 233,  TR,
+  { 217,  DMEC, TR, "217" },
+  { 218,  DMEC, TR, "218" },
+  { 219,  DMEC, TR, "219" },
+  { 233,  DMEC, TR,
     "Out of operation records in transaction coordinator (increase MaxNoOfConcurrentOperations)" },
-  { 275,  TR, "275" },
-  { 279,  TR, "Out of transaction markers in transaction coordinator" },
-  { 414,  TR, "414" },
-  { 418,  TR, "Out of transaction buffers in LQH" },
-  { 419,  TR, "419" },
-  { 245,  TR, "Too many active scans" },
-  { 488,  TR, "Too many active scans" },
-  { 490,  TR, "Too many active scans" },
-  { 805,  TR, "Out of attrinfo records in tuple manager" },
-  { 830,  TR, "Out of add fragment operation records" },
-  { 873,  TR, "Out of attrinfo records for scan in tuple manager" },
-  { 1217, TR, "Out of operation records in local data manager (increase MaxNoOfLocalOperations)" },
-  { 1220, TR, "REDO log files overloaded, consult online manual (decrease TimeBetweenLocalCheckpoints, and|or increase NoOfFragmentLogFiles)" },
-  { 1222, TR, "Out of transaction markers in LQH" },
-  { 1224, TR, "Out of Send Buffer space in LQH" },
-  { 4021, TR, "Out of Send Buffer space in NDB API" },
-  { 4022, TR, "Out of Send Buffer space in NDB API" },
-  { 4032, TR, "Out of Send Buffer space in NDB API" },
-  {  288, TR, "Out of index operations in transaction coordinator (increase MaxNoOfConcurrentIndexOperations)" },
+  { 275,  DMEC, TR, "275" },
+  { 279,  DMEC, TR, "Out of transaction markers in transaction coordinator" },
+  { 414,  DMEC, TR, "414" },
+  { 418,  DMEC, TR, "Out of transaction buffers in LQH" },
+  { 419,  DMEC, TR, "419" },
+  { 245,  DMEC, TR, "Too many active scans" },
+  { 488,  DMEC, TR, "Too many active scans" },
+  { 490,  DMEC, TR, "Too many active scans" },
+  { 805,  DMEC, TR, "Out of attrinfo records in tuple manager" },
+  { 830,  DMEC, TR, "Out of add fragment operation records" },
+  { 873,  DMEC, TR, "Out of attrinfo records for scan in tuple manager" },
+  { 899,  DMEC, TR, "Rowid already allocated" },
+  { 1217, DMEC, TR, "Out of operation records in local data manager (increase MaxNoOfLocalOperations)" },
+  { 1220, DMEC, TR, "REDO log files overloaded, consult online manual (decrease TimeBetweenLocalCheckpoints, and|or increase NoOfFragmentLogFiles)" },
+  { 1222, DMEC, TR, "Out of transaction markers in LQH" },
+  { 4021, DMEC, TR, "Out of Send Buffer space in NDB API" },
+  { 4022, DMEC, TR, "Out of Send Buffer space in NDB API" },
+  { 4032, DMEC, TR, "Out of Send Buffer space in NDB API" },
+  { 1501, DMEC, TR, "Out of undo space" },
+  {  288, DMEC, TR, "Out of index operations in transaction coordinator (increase MaxNoOfConcurrentIndexOperations)" },
+
   /**
    * InsufficientSpace
    */
-  { 623,  IS, "623" },
-  { 624,  IS, "624" },
-  { 625,  IS, "Out of memory in Ndb Kernel, hash index part (increase IndexMemory)" },
-  { 640,  IS, "Too many hash indexes (should not happen)" },
-  { 826,  IS, "Too many tables and attributes (increase MaxNoOfAttributes or MaxNoOfTables)" },
-  { 827,  IS, "Out of memory in Ndb Kernel, table data (increase DataMemory)" },
-  { 902,  IS, "Out of memory in Ndb Kernel, ordered index data (increase DataMemory)" },
-  { 903,  IS, "Too many ordered indexes (increase MaxNoOfOrderedIndexes)" },
-  { 904,  IS, "Out of fragment records (increase MaxNoOfOrderedIndexes)" },
-  { 905,  IS, "Out of attribute records (increase MaxNoOfAttributes)" },
-
+  { 623,  HA_ERR_RECORD_FILE_FULL, IS, "623" },
+  { 624,  HA_ERR_RECORD_FILE_FULL, IS, "624" },
+  { 625,  HA_ERR_INDEX_FILE_FULL, IS, "Out of memory in Ndb Kernel, hash index part (increase IndexMemory)" },
+  { 640,  DMEC, IS, "Too many hash indexes (should not happen)" },
+  { 826,  HA_ERR_RECORD_FILE_FULL, IS, "Too many tables and attributes (increase MaxNoOfAttributes or MaxNoOfTables)" },
+  { 827,  HA_ERR_RECORD_FILE_FULL, IS, "Out of memory in Ndb Kernel, table data (increase DataMemory)" },
+  { 902,  HA_ERR_RECORD_FILE_FULL, IS, "Out of memory in Ndb Kernel, ordered index data (increase DataMemory)" },
+  { 903,  HA_ERR_INDEX_FILE_FULL, IS, "Too many ordered indexes (increase MaxNoOfOrderedIndexes)" },
+  { 904,  HA_ERR_INDEX_FILE_FULL, IS, "Out of fragment records (increase MaxNoOfOrderedIndexes)" },
+  { 905,  DMEC, IS, "Out of attribute records (increase MaxNoOfAttributes)" },
+  { 1601, HA_ERR_RECORD_FILE_FULL, IS, "Out extents, tablespace full" },
+  
   /**
    * TimeoutExpired 
    */
-  { 266,  TO, "Time-out in NDB, probably caused by deadlock" },
-  { 274,  TO, "Time-out in NDB, probably caused by deadlock" }, /* Scan trans timeout */
-  { 296,  TO, "Time-out in NDB, probably caused by deadlock" }, /* Scan trans timeout */
-  { 297,  TO, "Time-out in NDB, probably caused by deadlock" }, /* Scan trans timeout, temporary!! */
-  { 237,  TO, "Transaction had timed out when trying to commit it" },
+  { 266,  HA_ERR_LOCK_WAIT_TIMEOUT, TO, "Time-out in NDB, probably caused by deadlock" },
+  { 274,  HA_ERR_LOCK_WAIT_TIMEOUT, TO, "Time-out in NDB, probably caused by deadlock" }, /* Scan trans timeout */
+  { 296,  HA_ERR_LOCK_WAIT_TIMEOUT, TO, "Time-out in NDB, probably caused by deadlock" }, /* Scan trans timeout */
+  { 297,  HA_ERR_LOCK_WAIT_TIMEOUT, TO, "Time-out in NDB, probably caused by deadlock" }, /* Scan trans timeout, temporary!! */
+  { 237,  HA_ERR_LOCK_WAIT_TIMEOUT, TO, "Transaction had timed out when trying to commit it" },
   
   /**
    * OverloadError
    */
-  { 410,  OL, "REDO log files overloaded, consult online manual (decrease TimeBetweenLocalCheckpoints, and|or increase NoOfFragmentLogFiles)" },
-  { 677,  OL, "Index UNDO buffers overloaded (increase UndoIndexBuffer)" },
-  { 891,  OL, "Data UNDO buffers overloaded (increase UndoDataBuffer)" },
-  { 1221, OL, "REDO buffers overloaded, consult online manual (increase RedoBuffer)" },
-  { 4006, OL, "Connect failure - out of connection objects (increase MaxNoOfConcurrentTransactions)" }, 
+  { 701,  DMEC, OL, "System busy with other schema operation" },
+  { 711,  DMEC, OL, "System busy with node restart, schema operations not allowed" },
+  { 410,  DMEC, OL, "REDO log files overloaded, consult online manual (decrease TimeBetweenLocalCheckpoints, and|or increase NoOfFragmentLogFiles)" },
+  { 677,  DMEC, OL, "Index UNDO buffers overloaded (increase UndoIndexBuffer)" },
+  { 891,  DMEC, OL, "Data UNDO buffers overloaded (increase UndoDataBuffer)" },
+  { 1221, DMEC, OL, "REDO buffers overloaded, consult online manual (increase RedoBuffer)" },
+  { 4006, DMEC, OL, "Connect failure - out of connection objects (increase MaxNoOfConcurrentTransactions)" }, 
 
 
+  /*
+   * Internal Temporary
+   */
+  { 702,  DMEC, IT, "Request to non-master" },
   
   /**
    * Internal errors
    */
-  { 892,  IE, "Inconsistent hash index. The index needs to be dropped and recreated" },
-  { 896,  IE, "Tuple corrupted - wrong checksum or column data in invalid format" },
-  { 901,  IE, "Inconsistent ordered index. The index needs to be dropped and recreated" },
-  { 202,  IE, "202" },
-  { 203,  IE, "203" },
-  { 207,  IE, "207" },
-  { 208,  IE, "208" },
-  { 209,  IE, "Communication problem, signal error" },
-  { 220,  IE, "220" },
-  { 230,  IE, "230" },
-  { 232,  IE, "232" },
-  { 238,  IE, "238" },
-  { 271,  IE, "Simple Read transaction without any attributes to read" },
-  { 272,  IE, "Update operation without any attributes to update" },
-  { 276,  IE, "276" },
-  { 277,  IE, "277" },
-  { 278,  IE, "278" },
-  { 287,  IE, "Index corrupted" },
-  { 290,  IE, "Corrupt key in TC, unable to xfrm" },
-  { 631,  IE, "631" },
-  { 632,  IE, "632" },
-  { 702,  IE, "Request to non-master" },
-  { 706,  IE, "Inconsistency during table creation" },
-  { 809,  IE, "809" },
-  { 812,  IE, "812" },
-  { 829,  IE, "829" },
-  { 833,  IE, "833" },
-  { 839,  IE, "Illegal null attribute" },
-  { 871,  IE, "871" },
-  { 882,  IE, "882" },
-  { 883,  IE, "883" },
-  { 887,  IE, "887" },
-  { 888,  IE, "888" },
-  { 890,  IE, "890" },
-  { 4000, IE, "MEMORY ALLOCATION ERROR" },
-  { 4001, IE, "Signal Definition Error" },
-  { 4005, IE, "Internal Error in NdbApi" },
-  { 4011, IE, "Internal Error in NdbApi" }, 
-  { 4107, IE, "Simple Transaction and Not Start" },
-  { 4108, IE, "Faulty operation type" },
-  { 4109, IE, "Faulty primary key attribute length" },
-  { 4110, IE, "Faulty length in ATTRINFO signal" },
-  { 4111, IE, "Status Error in NdbConnection" },
-  { 4113, IE, "Too many operations received" },
-  { 4320, IE, "Cannot use the same object twice to create table" },
-  { 4321, IE, "Trying to start two schema transactions" },
-  { 4344, IE, "Only DBDICT and TRIX can send requests to TRIX" },
-  { 4345, IE, "TRIX block is not available yet, probably due to node failure" },
-  { 4346, IE, "Internal error at index create/build" },
-  { 4347, IE, "Bad state at alter index" },
-  { 4348, IE, "Inconsistency detected at alter index" },
-  { 4349, IE, "Inconsistency detected at index usage" },
-  { 4350, IE, "Transaction already aborted" },
+  { 892,  DMEC, IE, "Inconsistent hash index. The index needs to be dropped and recreated" },
+  { 896,  DMEC, IE, "Tuple corrupted - wrong checksum or column data in invalid format" },
+  { 901,  DMEC, IE, "Inconsistent ordered index. The index needs to be dropped and recreated" },
+  { 202,  DMEC, IE, "202" },
+  { 203,  DMEC, IE, "203" },
+  { 207,  DMEC, IE, "207" },
+  { 208,  DMEC, IE, "208" },
+  { 209,  DMEC, IE, "Communication problem, signal error" },
+  { 220,  DMEC, IE, "220" },
+  { 230,  DMEC, IE, "230" },
+  { 232,  DMEC, IE, "232" },
+  { 238,  DMEC, IE, "238" },
+  { 271,  DMEC, IE, "Simple Read transaction without any attributes to read" },
+  { 272,  DMEC, IE, "Update operation without any attributes to update" },
+  { 276,  DMEC, IE, "276" },
+  { 277,  DMEC, IE, "277" },
+  { 278,  DMEC, IE, "278" },
+  { 287,  DMEC, IE, "Index corrupted" },
+  { 290,  DMEC, IE, "Corrupt key in TC, unable to xfrm" },
+  { 631,  DMEC, IE, "631" },
+  { 632,  DMEC, IE, "632" },
+  { 706,  DMEC, IE, "Inconsistency during table creation" },
+  { 809,  DMEC, IE, "809" },
+  { 812,  DMEC, IE, "812" },
+  { 829,  DMEC, IE, "829" },
+  { 833,  DMEC, IE, "833" },
+  { 871,  DMEC, IE, "871" },
+  { 882,  DMEC, IE, "882" },
+  { 883,  DMEC, IE, "883" },
+  { 887,  DMEC, IE, "887" },
+  { 888,  DMEC, IE, "888" },
+  { 890,  DMEC, IE, "890" },
+  { 4000, DMEC, IE, "MEMORY ALLOCATION ERROR" },
+  { 4001, DMEC, IE, "Signal Definition Error" },
+  { 4005, DMEC, IE, "Internal Error in NdbApi" },
+  { 4011, DMEC, IE, "Internal Error in NdbApi" }, 
+  { 4107, DMEC, IE, "Simple Transaction and Not Start" },
+  { 4108, DMEC, IE, "Faulty operation type" },
+  { 4109, DMEC, IE, "Faulty primary key attribute length" },
+  { 4110, DMEC, IE, "Faulty length in ATTRINFO signal" },
+  { 4111, DMEC, IE, "Status Error in NdbConnection" },
+  { 4113, DMEC, IE, "Too many operations received" },
+  { 4320, DMEC, IE, "Cannot use the same object twice to create table" },
+  { 4321, DMEC, IE, "Trying to start two schema transactions" },
+  { 4344, DMEC, IE, "Only DBDICT and TRIX can send requests to TRIX" },
+  { 4345, DMEC, IE, "TRIX block is not available yet, probably due to node failure" },
+  { 4346, DMEC, IE, "Internal error at index create/build" },
+  { 4347, DMEC, IE, "Bad state at alter index" },
+  { 4348, DMEC, IE, "Inconsistency detected at alter index" },
+  { 4349, DMEC, IE, "Inconsistency detected at index usage" },
+  { 4350, DMEC, IE, "Transaction already aborted" },
 
   /**
    * Application error
    */
-  { 763,  AE, "Alter table requires cluster nodes to have exact same version" },
-  { 823,  AE, "Too much attrinfo from application in tuple manager" },
-  { 831,  AE, "Too many nullable/bitfields in table definition" },
-  { 876,  AE, "876" },
-  { 877,  AE, "877" },
-  { 878,  AE, "878" },
-  { 879,  AE, "879" },
-  { 880,  AE, "Tried to read too much - too many getValue calls" },
-  { 884,  AE, "Stack overflow in interpreter" },
-  { 885,  AE, "Stack underflow in interpreter" },
-  { 886,  AE, "More than 65535 instructions executed in interpreter" },
-  { 897,  AE, "Update attempt of primary key via ndbcluster internal api (if this occurs via the MySQL server it is a bug, please report)" },
-  { 4256, AE, "Must call Ndb::init() before this function" },
-  { 4257, AE, "Tried to read too much - too many getValue calls" },
-  
+  { 763,  DMEC, AE, "Alter table requires cluster nodes to have exact same version" },
+  { 823,  DMEC, AE, "Too much attrinfo from application in tuple manager" },
+  { 831,  DMEC, AE, "Too many nullable/bitfields in table definition" },
+  { 876,  DMEC, AE, "876" },
+  { 877,  DMEC, AE, "877" },
+  { 878,  DMEC, AE, "878" },
+  { 879,  DMEC, AE, "879" },
+  { 880,  DMEC, AE, "Tried to read too much - too many getValue calls" },
+  { 884,  DMEC, AE, "Stack overflow in interpreter" },
+  { 885,  DMEC, AE, "Stack underflow in interpreter" },
+  { 886,  DMEC, AE, "More than 65535 instructions executed in interpreter" },
+  { 897,  DMEC, AE, "Update attempt of primary key via ndbcluster internal api (if this occurs via the MySQL server it is a bug, please report)" },
+  { 4256, DMEC, AE, "Must call Ndb::init() before this function" },
+  { 4257, DMEC, AE, "Tried to read too much - too many getValue calls" },
+
   /** 
    * Scan application errors
    */
-  { 242,  AE, "Zero concurrency in scan"},
-  { 244,  AE, "Too high concurrency in scan"},
-  { 269,  AE, "No condition and attributes to read in scan"},
-  { 4600, AE, "Transaction is already started"},
-  { 4601, AE, "Transaction is not started"},
-  { 4602, AE, "You must call getNdbOperation before executeScan" },
-  { 4603, AE, "There can only be ONE operation in a scan transaction" },
-  { 4604, AE, "takeOverScanOp, to take over a scanned row one must explicitly request keyinfo in readTuples call" },
-  { 4605, AE, "You may only call openScanRead or openScanExclusive once for each operation"},
-  { 4607, AE, "There may only be one operation in a scan transaction"},
-  { 4608, AE, "You can not takeOverScan unless you have used openScanExclusive"},
-  { 4609, AE, "You must call nextScanResult before trying to takeOverScan"},
-  { 4232, AE, "Parallelism can only be between 1 and 240" },
+  { 242,  DMEC, AE, "Zero concurrency in scan"},
+  { 244,  DMEC, AE, "Too high concurrency in scan"},
+  { 269,  DMEC, AE, "No condition and attributes to read in scan"},
+  { 4600, DMEC, AE, "Transaction is already started"},
+  { 4601, DMEC, AE, "Transaction is not started"},
+  { 4602, DMEC, AE, "You must call getNdbOperation before executeScan" },
+  { 4603, DMEC, AE, "There can only be ONE operation in a scan transaction" },
+  { 4604, DMEC, AE, "takeOverScanOp, to take over a scanned row one must explicitly request keyinfo on readTuples call" },
+  { 4605, DMEC, AE, "You may only call openScanRead or openScanExclusive once for each operation"},
+  { 4607, DMEC, AE, "There may only be one operation in a scan transaction"},
+  { 4608, DMEC, AE, "You can not takeOverScan unless you have used openScanExclusive"},
+  { 4609, DMEC, AE, "You must call nextScanResult before trying to takeOverScan"},
+  { 4232, DMEC, AE, "Parallelism can only be between 1 and 240" },
 
   /** 
    * Event schema errors
    */
 
-  { 4713,  SE, "Column defined in event does not exist in table"},
+  { 4713,  DMEC, SE, "Column defined in event does not exist in table"},
   
   /** 
    * Event application errors
    */
 
-  { 4707,  AE, "Too many event have been defined"},
-  { 4708,  AE, "Event name is too long"},
-  { 4709,  AE, "Can't accept more subscribers"},
-  {  746,  OE, "Event name already exists"},
-  { 4710,  AE, "Event not found"},
-  { 4711,  AE, "Creation of event failed"},
-  { 4712,  AE, "Stopped event operation does not exist. Already stopped?"},
+  { 4707,  DMEC, AE, "Too many event have been defined"},
+  { 4708,  DMEC, AE, "Event name is too long"},
+  { 4709,  DMEC, AE, "Can't accept more subscribers"},
+  {  746,  DMEC, OE, "Event name already exists"},
+  {  747,  DMEC, IS, "Out of event records"},
+  {  748,  DMEC, TR, "Busy during read of event table"},
+  { 4710,  DMEC, AE, "Event not found"},
+  { 4711,  DMEC, AE, "Creation of event failed"},
+  { 4712,  DMEC, AE, "Stopped event operation does not exist. Already stopped?"},
 
   /** 
    * Event internal errors
    */
 
-  { 4731,  IE, "Event not found"},
+  { 4731,  DMEC, IE, "Event not found"},
 
   /**
    * SchemaError
    */
-  { 701,  SE, "System busy with other schema operation" },
-  { 711,  SE, "System busy with node restart, schema operations not allowed" },
-  { 703,  SE, "Invalid table format" },
-  { 704,  SE, "Attribute name too long" },
-  { 705,  SE, "Table name too long" },
-  { 707,  SE, "No more table metadata records (increase MaxNoOfTables)" },  
-  { 708,  SE, "No more attribute metadata records (increase MaxNoOfAttributes)" },
-  { 709,  SE, "No such table existed" },
-  { 721,  OE, "Table or index with given name already exists" },
-  { 723,  SE, "No such table existed" },
-  { 736,  SE, "Unsupported array size" },
-  { 737,  SE, "Attribute array size too big" },
-  { 738,  SE, "Record too big" },
-  { 739,  SE, "Unsupported primary key length" },
-  { 740,  SE, "Nullable primary key not supported" },
-  { 741,  SE, "Unsupported alter table" },
-  { 743,  SE, "Unsupported character set in table or index" },
-  { 744,  SE, "Character string is invalid for given character set" },
-  { 745,  SE, "Distribution key not supported for char attribute (use binary attribute)" },
-  { 761,  SE, "Unable to drop table as backup is in progress" },
-  { 762,  SE, "Unable to alter table as backup is in progress" },
-  { 241,  SE, "Invalid schema object version" },
-  { 283,  SE, "Table is being dropped" },
-  { 284,  SE, "Table not defined in transaction coordinator" },
-  { 285,  SE, "Unknown table error in transaction coordinator" },
-  { 881,  SE, "Unable to create table, out of data pages (increase DataMemory) " },
-  { 906,  SE, "Unsupported attribute type in index" },
-  { 907,  SE, "Unsupported character set in table or index" },
-  { 908,  IS, "Invalid ordered index tree node size" },
-  { 1225, SE, "Table not defined in local query handler" },
-  { 1226, SE, "Table is being dropped" },
-  { 1228, SE, "Cannot use drop table for drop index" },
-  { 1229, SE, "Too long frm data supplied" },
-  { 1231, SE, "Invalid table or index to scan" },
-  { 1232, SE, "Invalid table or index to scan" },
-
+  { 311,  DMEC, AE, "Undefined partition used in setPartitionId" },
+  { 703,  DMEC, SE, "Invalid table format" },
+  { 704,  DMEC, SE, "Attribute name too long" },
+  { 705,  DMEC, SE, "Table name too long" },
+  { 707,  DMEC, SE, "No more table metadata records (increase MaxNoOfTables)" },  
+  { 708,  DMEC, SE, "No more attribute metadata records (increase MaxNoOfAttributes)" },
+  { 709,  HA_ERR_NO_SUCH_TABLE, SE, "No such table existed" },
+  { 710,  DMEC, SE, "Internal: Get by table name not supported, use table id." },
+  { 721,  HA_ERR_TABLE_EXIST,   OE, "Table or index with given name already exists" },
+  { 723,  HA_ERR_NO_SUCH_TABLE, SE, "No such table existed" },
+  { 736,  DMEC, SE, "Unsupported array size" },
+  { 737,  HA_WRONG_CREATE_OPTION, SE, "Attribute array size too big" },
+  { 738,  HA_WRONG_CREATE_OPTION, SE, "Record too big" },
+  { 739,  HA_WRONG_CREATE_OPTION, SE, "Unsupported primary key length" },
+  { 740,  HA_WRONG_CREATE_OPTION, SE, "Nullable primary key not supported" },
+  { 741,  DMEC, SE, "Unsupported alter table" },
+  { 743,  HA_WRONG_CREATE_OPTION, SE, "Unsupported character set in table or index" },
+  { 744,  DMEC, SE, "Character string is invalid for given character set" },
+  { 745,  HA_WRONG_CREATE_OPTION, SE, "Distribution key not supported for char attribute (use binary attribute)" },
+  { 771,  HA_WRONG_CREATE_OPTION, AE, "Given NODEGROUP doesn't exist in this cluster" },
+  { 772,  HA_WRONG_CREATE_OPTION, IE, "Given fragmentType doesn't exist" },
+  { 749,  HA_WRONG_CREATE_OPTION, IE, "Primary Table in wrong state" },
+  { 763,  HA_WRONG_CREATE_OPTION, SE, "Invalid undo buffer size" },
+  { 764,  HA_WRONG_CREATE_OPTION, SE, "Invalid extent size" },
+  { 765,  DMEC, SE, "Out of filegroup records" },
+  { 750,  IE, SE, "Invalid file type" },
+  { 751,  DMEC, SE, "Out of file records" },
+  { 752,  DMEC, SE, "Invalid file format" },
+  { 753,  IE, SE, "Invalid filegroup for file" },
+  { 754,  IE, SE, "Invalid filegroup version when creating file" },
+  { 755,  HA_WRONG_CREATE_OPTION, SE, "Invalid tablespace" },
+  { 756,  DMEC, SE, "Index on disk column is not supported" },
+  { 757,  DMEC, SE, "Varsize bitfield not supported" },
+  { 758,  DMEC, SE, "Tablespace has changed" },
+  { 759,  DMEC, SE, "Invalid tablespace version " },
+  { 760,  DMEC, SE, "File already exists", },
+  { 761,  DMEC, SE, "Unable to drop table as backup is in progress" },
+  { 762,  DMEC, SE, "Unable to alter table as backup is in progress" },
+  { 766,  DMEC, SE, "Cant drop file, no such file" },
+  { 767,  DMEC, SE, "Cant drop filegroup, no such filegroup" },
+  { 768,  DMEC, SE, "Cant drop filegroup, filegroup is used" },
+  { 769,  DMEC, SE, "Drop undofile not supported, drop logfile group instead" },
+  { 770,  DMEC, SE, "Cant drop file, file is used" },
+  { 774,  DMEC, SE, "Invalid schema object for drop" },
+  { 241,  HA_ERR_TABLE_DEF_CHANGED, SE, "Invalid schema object version" },
+  { 283,  HA_ERR_NO_SUCH_TABLE, SE, "Table is being dropped" },
+  { 284,  HA_ERR_TABLE_DEF_CHANGED, SE, "Table not defined in transaction coordinator" },
+  { 285,  DMEC, SE, "Unknown table error in transaction coordinator" },
+  { 881,  DMEC, SE, "Unable to create table, out of data pages (increase DataMemory) " },
+  { 906,  DMEC, SE, "Unsupported attribute type in index" },
+  { 907,  DMEC, SE, "Unsupported character set in table or index" },
+  { 908,  DMEC, IS, "Invalid ordered index tree node size" },
+  { 1225, DMEC, SE, "Table not defined in local query handler" },
+  { 1226, DMEC, SE, "Table is being dropped" },
+  { 1228, DMEC, SE, "Cannot use drop table for drop index" },
+  { 1229, DMEC, SE, "Too long frm data supplied" },
+  { 1231, DMEC, SE, "Invalid table or index to scan" },
+  { 1232, DMEC, SE, "Invalid table or index to scan" },
+
+  { 1502, DMEC, IE, "Filegroup already exists" },
+  { 1503, DMEC, SE, "Out of filegroup records" },
+  { 1504, DMEC, SE, "Out of logbuffer memory" },
+  { 1505, DMEC, IE, "Invalid filegroup" },
+  { 1506, DMEC, IE, "Invalid filegroup version" },
+  { 1507, DMEC, IE, "File no already inuse" },
+  { 1508, DMEC, SE, "Out of file records" },
+  { 1509, DMEC, SE, "File system error, check if path,permissions etc" },
+  { 1510, DMEC, IE, "File meta data error" },
+  { 1511, DMEC, IE, "Out of memory" },
+  { 1512, DMEC, SE, "File read error" },
+  { 1513, DMEC, IE, "Filegroup not online" },
+  { 1514, DMEC, SE, "Currently there is a limit of one logfile group" },
+  
+  { 773,  DMEC, SE, "Out of string memory, please modify StringMemory config parameter" },
+  { 775,  DMEC, SE, "Create file is not supported when Diskless=1" },
+  
   /**
    * FunctionNotImplemented
    */
-  { 4003, NI, "Function not implemented yet" },
+  { 4003, DMEC, NI, "Function not implemented yet" },
 
   /**
    * Backup error codes
    */ 
 
-  { 1300, IE, "Undefined error" },
-  { 1301, IE, "Backup issued to not master (reissue command to master)" },
-  { 1302, IE, "Out of backup record" },
-  { 1303, IS, "Out of resources" },
-  { 1304, IE, "Sequence failure" },
-  { 1305, IE, "Backup definition not implemented" },
-  { 1306, AE, "Backup not supported in diskless mode (change Diskless)" },
-
-  { 1321, UD, "Backup aborted by user request" },
-  { 1322, IE, "Backup already completed" },
-  { 1323, IE, "1323" },
-  { 1324, IE, "Backup log buffer full" },
-  { 1325, IE, "File or scan error" },
-  { 1326, IE, "Backup abortet due to node failure" },
-  { 1327, IE, "1327" },
-  
-  { 1340, IE, "Backup undefined error" },
-  { 1342, AE, "Backup failed to allocate buffers (check configuration)" },
-  { 1343, AE, "Backup failed to setup fs buffers (check configuration)" },
-  { 1344, AE, "Backup failed to allocate tables (check configuration)" },
-  { 1345, AE, "Backup failed to insert file header (check configuration)" },
-  { 1346, AE, "Backup failed to insert table list (check configuration)" },
-  { 1347, AE, "Backup failed to allocate table memory (check configuration)" },
-  { 1348, AE, "Backup failed to allocate file record (check configuration)" },
-  { 1349, AE, "Backup failed to allocate attribute record (check configuration)" },
-  { 1329, AE, "Backup during software upgrade not supported" },
+  { 1300, DMEC, IE, "Undefined error" },
+  { 1301, DMEC, IE, "Backup issued to not master (reissue command to master)" },
+  { 1302, DMEC, IE, "Out of backup record" },
+  { 1303, DMEC, IS, "Out of resources" },
+  { 1304, DMEC, IE, "Sequence failure" },
+  { 1305, DMEC, IE, "Backup definition not implemented" },
+  { 1306, DMEC, AE, "Backup not supported in diskless mode (change Diskless)" },
+
+  { 1321, DMEC, UD, "Backup aborted by user request" },
+  { 1322, DMEC, IE, "Backup already completed" },
+  { 1323, DMEC, IE, "1323" },
+  { 1324, DMEC, IE, "Backup log buffer full" },
+  { 1325, DMEC, IE, "File or scan error" },
+  { 1326, DMEC, IE, "Backup abortet due to node failure" },
+  { 1327, DMEC, IE, "1327" },
+  
+  { 1340, DMEC, IE, "Backup undefined error" },
+  { 1342, DMEC, AE, "Backup failed to allocate buffers (check configuration)" },
+  { 1343, DMEC, AE, "Backup failed to setup fs buffers (check configuration)" },
+  { 1344, DMEC, AE, "Backup failed to allocate tables (check configuration)" },
+  { 1345, DMEC, AE, "Backup failed to insert file header (check configuration)" },
+  { 1346, DMEC, AE, "Backup failed to insert table list (check configuration)" },
+  { 1347, DMEC, AE, "Backup failed to allocate table memory (check configuration)" },
+  { 1348, DMEC, AE, "Backup failed to allocate file record (check configuration)" },
+  { 1349, DMEC, AE, "Backup failed to allocate attribute record (check configuration)" },
+  { 1329, DMEC, AE, "Backup during software upgrade not supported" },
+
+  /**
+   * Node id allocation error codes
+   */ 
+
+  { 1700, DMEC, IE, "Undefined error" },
+  { 1701, DMEC, AE, "Node already reserved" },
+  { 1702, DMEC, AE, "Node already connected" },
+  { 1703, DMEC, AE, "Node failure handling not completed" },
+  { 1704, DMEC, AE, "Node type mismatch" },
   
   /**
    * Still uncategorized
    */
-  { 720,  AE, "Attribute name reused in table definition" },
-  { 4004, AE, "Attribute name not found in the Table" },
-  
-  { 4100, AE, "Status Error in NDB" },
-  { 4101, AE, "No connections to NDB available and connect failed" },
-  { 4102, AE, "Type in NdbTamper not correct" },
-  { 4103, AE, "No schema connections to NDB available and connect failed" },
-  { 4104, AE, "Ndb Init in wrong state, destroy Ndb object and create a new" },
-  { 4105, AE, "Too many Ndb objects" },
-  { 4106, AE, "All Not NULL attribute have not been defined" },
-  { 4114, AE, "Transaction is already completed" },
-  { 4116, AE, "Operation was not defined correctly, probably missing a key" },
-  { 4117, AE, "Could not start transporter, configuration error"}, 
-  { 4118, AE, "Parameter error in API call" },
-  { 4300, AE, "Tuple Key Type not correct" },
-  { 4301, AE, "Fragment Type not correct" },
-  { 4302, AE, "Minimum Load Factor not correct" },
-  { 4303, AE, "Maximum Load Factor not correct" },
-  { 4304, AE, "Maximum Load Factor smaller than Minimum" },
-  { 4305, AE, "K value must currently be set to 6" },
-  { 4306, AE, "Memory Type not correct" },
-  { 4307, AE, "Invalid table name" },
-  { 4308, AE, "Attribute Size not correct" },
-  { 4309, AE, "Fixed array too large, maximum 64000 bytes" },
-  { 4310, AE, "Attribute Type not correct" },
-  { 4311, AE, "Storage Mode not correct" },
-  { 4312, AE, "Null Attribute Type not correct" },
-  { 4313, AE, "Index only storage for non-key attribute" },
-  { 4314, AE, "Storage Type of attribute not correct" },
-  { 4315, AE, "No more key attributes allowed after defining variable length key attribute" },
-  { 4316, AE, "Key attributes are not allowed to be NULL attributes" },
-  { 4317, AE, "Too many primary keys defined in table" },
-  { 4318, AE, "Invalid attribute name" },
-  { 4319, AE, "createAttribute called at erroneus place" },
-  { 4322, AE, "Attempt to define distribution key when not prepared to" },
-  { 4323, AE, "Distribution Key set on table but not defined on first attribute" },
-  { 4324, AE, "Attempt to define distribution group when not prepared to" },
-  { 4325, AE, "Distribution Group set on table but not defined on first attribute" },
-  { 4326, AE, "Distribution Group with erroneus number of bits" },
-  { 4327, AE, "Distribution Group with 1 byte attribute is not allowed" },
-  { 4328, AE, "Disk memory attributes not yet supported" },
-  { 4329, AE, "Variable stored attributes not yet supported" },
-
-  { 4400, AE, "Status Error in NdbSchemaCon" },
-  { 4401, AE, "Only one schema operation per schema transaction" },
-  { 4402, AE, "No schema operation defined before calling execute" },
-
-  { 4501, AE, "Insert in hash table failed when getting table information from Ndb" },
-  { 4502, AE, "GetValue not allowed in Update operation" },
-  { 4503, AE, "GetValue not allowed in Insert operation" },
-  { 4504, AE, "SetValue not allowed in Read operation" },
-  { 4505, AE, "NULL value not allowed in primary key search" },
-  { 4506, AE, "Missing getValue/setValue when calling execute" },
-  { 4507, AE, "Missing operation request when calling execute" },
-
-  { 4200, AE, "Status Error when defining an operation" },
-  { 4201, AE, "Variable Arrays not yet supported" },
-  { 4202, AE, "Set value on tuple key attribute is not allowed" },
-  { 4203, AE, "Trying to set a NOT NULL attribute to NULL" },
-  { 4204, AE, "Set value and Read/Delete Tuple is incompatible" },
-  { 4205, AE, "No Key attribute used to define tuple" },
-  { 4206, AE, "Not allowed to equal key attribute twice" },
-  { 4207, AE, "Key size is limited to 4092 bytes" },
-  { 4208, AE, "Trying to read a non-stored attribute" },
-  { 4209, AE, "Length parameter in equal/setValue is incorrect" },
-  { 4210, AE, "Ndb sent more info than the length he specified" },
-  { 4211, AE, "Inconsistency in list of NdbRecAttr-objects" },
-  { 4212, AE, "Ndb reports NULL value on Not NULL attribute" },
-  { 4213, AE, "Not all data of an attribute has been received" },
-  { 4214, AE, "Not all attributes have been received" },
-  { 4215, AE, "More data received than reported in TCKEYCONF message" },
-  { 4216, AE, "More than 8052 bytes in setValue cannot be handled" },
-  { 4217, AE, "It is not allowed to increment any other than unsigned ints" },
-  { 4218, AE, "Currently not allowed to increment NULL-able attributes" },
-  { 4219, AE, "Maximum size of interpretative attributes are 64 bits" },
-  { 4220, AE, "Maximum size of interpretative attributes are 64 bits" },
-  { 4221, AE, "Trying to jump to a non-defined label" },
-  { 4222, AE, "Label was not found, internal error" },
-  { 4223, AE, "Not allowed to create jumps to yourself" },
-  { 4224, AE, "Not allowed to jump to a label in a different subroutine" },
-  { 4225, AE, "All primary keys defined, call setValue/getValue"},
-  { 4226, AE, "Bad number when defining a label" },
-  { 4227, AE, "Bad number when defining a subroutine" },
-  { 4228, AE, "Illegal interpreter function in scan definition" },
-  { 4229, AE, "Illegal register in interpreter function definition" },
-  { 4230, AE, "Illegal state when calling getValue, probably not a read" },
-  { 4231, AE, "Illegal state when calling interpreter routine" },
-  { 4233, AE, "Calling execute (synchronous) when already prepared asynchronous transaction exists" },
-  { 4234, AE, "Illegal to call setValue in this state" },
-  { 4235, AE, "No callback from execute" },
-  { 4236, AE, "Trigger name too long" },
-  { 4237, AE, "Too many triggers" },
-  { 4238, AE, "Trigger not found" },
-  { 4239, AE, "Trigger with given name already exists"},
-  { 4240, AE, "Unsupported trigger type"},
-  { 4241, AE, "Index name too long" },
-  { 4242, AE, "Too many indexes" },
-  { 4243, AE, "Index not found" },
-  { 4244, OE, "Index or table with given name already exists" },
-  { 4247, AE, "Illegal index/trigger create/drop/alter request" },
-  { 4248, AE, "Trigger/index name invalid" },
-  { 4249, AE, "Invalid table" },
-  { 4250, AE, "Invalid index type or index logging option" },
-  { 4251, AE, "Cannot create unique index, duplicate keys found" },
-  { 4252, AE, "Failed to allocate space for index" },
-  { 4253, AE, "Failed to create index table" },
-  { 4254, AE, "Table not an index table" },
-  { 4255, AE, "Hash index attributes must be specified in same order as table attributes" },
-  { 4258, AE, "Cannot create unique index, duplicate attributes found in definition" },
-  { 4259, AE, "Invalid set of range scan bounds" },
-  { 4260, UD, "NdbScanFilter: Operator is not defined in NdbScanFilter::Group"},
-  { 4261, UD, "NdbScanFilter: Column is NULL"},
-  { 4262, UD, "NdbScanFilter: Condition is out of bounds"},
-  { 4263, IE, "Invalid blob attributes or invalid blob parts table" },
-  { 4264, AE, "Invalid usage of blob attribute" },
-  { 4265, AE, "The blob method is not valid in current blob state" },
-  { 4266, AE, "Invalid blob seek position" },
-  { 4267, IE, "Corrupted blob value" },
-  { 4268, IE, "Error in blob head update forced rollback of transaction" },
-  { 4269, IE, "No connection to ndb management server" },
-  { 4270, IE, "Unknown blob error" },
-  { 4335, AE, "Only one autoincrement column allowed per table. Having a table without primary key uses an autoincremented hidden key, i.e. a table without a primary key can not have an autoincremented column" },
-  { 4271, AE, "Invalid index object, not retrieved via getIndex()" },
-  { 4275, AE, "The blob method is incompatible with operation type or lock mode" }
+  { 720,  DMEC, AE, "Attribute name reused in table definition" },
+  { 1405, DMEC, NR, "Subscriber manager busy with node recovery" },
+  { 1407, DMEC, SE, "Subscription not found in subscriber manager" },
+  { 1411, DMEC, TR, "Subscriber manager busy with adding/removing a subscriber" },
+  { 1412, DMEC, IS, "Can't accept more subscribers, out of space in pool" },
+  { 1413, DMEC, TR, "Subscriber manager busy with adding the subscription" },
+  { 1414, DMEC, TR, "Subscriber manager has subscribers on this subscription" },
+  { 1415, DMEC, SE, "Subscription not unique in subscriber manager" },
+  { 1416, DMEC, IS, "Can't accept more subscriptions, out of space in pool" },
+  { 1417, DMEC, SE, "Table in suscription not defined, probably dropped" },
+  { 1418, DMEC, SE, "Subscription dropped, no new subscribers allowed" },
+  { 1419, DMEC, SE, "Subscription already dropped" },
+
+  { 1420, DMEC, TR, "Subscriber manager busy with adding/removing a table" },
+
+  { 4004, DMEC, AE, "Attribute name not found in the Table" },
+  
+  { 4100, DMEC, AE, "Status Error in NDB" },
+  { 4101, DMEC, AE, "No connections to NDB available and connect failed" },
+  { 4102, DMEC, AE, "Type in NdbTamper not correct" },
+  { 4103, DMEC, AE, "No schema connections to NDB available and connect failed" },
+  { 4104, DMEC, AE, "Ndb Init in wrong state, destroy Ndb object and create a new" },
+  { 4105, DMEC, AE, "Too many Ndb objects" },
+  { 4106, DMEC, AE, "All Not NULL attribute have not been defined" },
+  { 4114, DMEC, AE, "Transaction is already completed" },
+  { 4116, DMEC, AE, "Operation was not defined correctly, probably missing a key" },
+  { 4117, DMEC, AE, "Could not start transporter, configuration error"}, 
+  { 4118, DMEC, AE, "Parameter error in API call" },
+  { 4300, DMEC, AE, "Tuple Key Type not correct" },
+  { 4301, DMEC, AE, "Fragment Type not correct" },
+  { 4302, DMEC, AE, "Minimum Load Factor not correct" },
+  { 4303, DMEC, AE, "Maximum Load Factor not correct" },
+  { 4304, DMEC, AE, "Maximum Load Factor smaller than Minimum" },
+  { 4305, DMEC, AE, "K value must currently be set to 6" },
+  { 4306, DMEC, AE, "Memory Type not correct" },
+  { 4307, DMEC, AE, "Invalid table name" },
+  { 4308, DMEC, AE, "Attribute Size not correct" },
+  { 4309, DMEC, AE, "Fixed array too large, maximum 64000 bytes" },
+  { 4310, DMEC, AE, "Attribute Type not correct" },
+  { 4311, DMEC, AE, "Storage Mode not correct" },
+  { 4312, DMEC, AE, "Null Attribute Type not correct" },
+  { 4313, DMEC, AE, "Index only storage for non-key attribute" },
+  { 4314, DMEC, AE, "Storage Type of attribute not correct" },
+  { 4315, DMEC, AE, "No more key attributes allowed after defining variable length key attribute" },
+  { 4316, DMEC, AE, "Key attributes are not allowed to be NULL attributes" },
+  { 4317, DMEC, AE, "Too many primary keys defined in table" },
+  { 4318, DMEC, AE, "Invalid attribute name or number" },
+  { 4319, DMEC, AE, "createAttribute called at erroneus place" },
+  { 4322, DMEC, AE, "Attempt to define distribution key when not prepared to" },
+  { 4323, DMEC, AE, "Distribution Key set on table but not defined on first attribute" },
+  { 4324, DMEC, AE, "Attempt to define distribution group when not prepared to" },
+  { 4325, DMEC, AE, "Distribution Group set on table but not defined on first attribute" },
+  { 4326, DMEC, AE, "Distribution Group with erroneus number of bits" },
+  { 4327, DMEC, AE, "Distribution Group with 1 byte attribute is not allowed" },
+  { 4328, DMEC, AE, "Disk memory attributes not yet supported" },
+  { 4329, DMEC, AE, "Variable stored attributes not yet supported" },
+
+  { 4400, DMEC, AE, "Status Error in NdbSchemaCon" },
+  { 4401, DMEC, AE, "Only one schema operation per schema transaction" },
+  { 4402, DMEC, AE, "No schema operation defined before calling execute" },
+
+  { 4501, DMEC, AE, "Insert in hash table failed when getting table information from Ndb" },
+  { 4502, DMEC, AE, "GetValue not allowed in Update operation" },
+  { 4503, DMEC, AE, "GetValue not allowed in Insert operation" },
+  { 4504, DMEC, AE, "SetValue not allowed in Read operation" },
+  { 4505, DMEC, AE, "NULL value not allowed in primary key search" },
+  { 4506, DMEC, AE, "Missing getValue/setValue when calling execute" },
+  { 4507, DMEC, AE, "Missing operation request when calling execute" },
+
+  { 4200, DMEC, AE, "Status Error when defining an operation" },
+  { 4201, DMEC, AE, "Variable Arrays not yet supported" },
+  { 4202, DMEC, AE, "Set value on tuple key attribute is not allowed" },
+  { 4203, DMEC, AE, "Trying to set a NOT NULL attribute to NULL" },
+  { 4204, DMEC, AE, "Set value and Read/Delete Tuple is incompatible" },
+  { 4205, DMEC, AE, "No Key attribute used to define tuple" },
+  { 4206, DMEC, AE, "Not allowed to equal key attribute twice" },
+  { 4207, DMEC, AE, "Key size is limited to 4092 bytes" },
+  { 4208, DMEC, AE, "Trying to read a non-stored attribute" },
+  { 4209, DMEC, AE, "Length parameter in equal/setValue is incorrect" },
+  { 4210, DMEC, AE, "Ndb sent more info than the length he specified" },
+  { 4211, DMEC, AE, "Inconsistency in list of NdbRecAttr-objects" },
+  { 4212, DMEC, AE, "Ndb reports NULL value on Not NULL attribute" },
+  { 4213, DMEC, AE, "Not all data of an attribute has been received" },
+  { 4214, DMEC, AE, "Not all attributes have been received" },
+  { 4215, DMEC, AE, "More data received than reported in TCKEYCONF message" },
+  { 4216, DMEC, AE, "More than 8052 bytes in setValue cannot be handled" },
+  { 4217, DMEC, AE, "It is not allowed to increment any other than unsigned ints" },
+  { 4218, DMEC, AE, "Currently not allowed to increment NULL-able attributes" },
+  { 4219, DMEC, AE, "Maximum size of interpretative attributes are 64 bits" },
+  { 4220, DMEC, AE, "Maximum size of interpretative attributes are 64 bits" },
+  { 4221, DMEC, AE, "Trying to jump to a non-defined label" },
+  { 4222, DMEC, AE, "Label was not found, internal error" },
+  { 4223, DMEC, AE, "Not allowed to create jumps to yourself" },
+  { 4224, DMEC, AE, "Not allowed to jump to a label in a different subroutine" },
+  { 4225, DMEC, AE, "All primary keys defined, call setValue/getValue"},
+  { 4226, DMEC, AE, "Bad number when defining a label" },
+  { 4227, DMEC, AE, "Bad number when defining a subroutine" },
+  { 4228, DMEC, AE, "Illegal interpreter function in scan definition" },
+  { 4229, DMEC, AE, "Illegal register in interpreter function definition" },
+  { 4230, DMEC, AE, "Illegal state when calling getValue, probably not a read" },
+  { 4231, DMEC, AE, "Illegal state when calling interpreter routine" },
+  { 4233, DMEC, AE, "Calling execute (synchronous) when already prepared asynchronous transaction exists" },
+  { 4234, DMEC, AE, "Illegal to call setValue in this state" },
+  { 4235, DMEC, AE, "No callback from execute" },
+  { 4236, DMEC, AE, "Trigger name too long" },
+  { 4237, DMEC, AE, "Too many triggers" },
+  { 4238, DMEC, AE, "Trigger not found" },
+  { 4239, DMEC, AE, "Trigger with given name already exists"},
+  { 4240, DMEC, AE, "Unsupported trigger type"},
+  { 4241, DMEC, AE, "Index name too long" },
+  { 4242, DMEC, AE, "Too many indexes" },
+  { 4243, DMEC, AE, "Index not found" },
+  { 4244, HA_ERR_TABLE_EXIST, OE, "Index or table with given name already exists" },
+  { 4247, DMEC, AE, "Illegal index/trigger create/drop/alter request" },
+  { 4248, DMEC, AE, "Trigger/index name invalid" },
+  { 4249, DMEC, AE, "Invalid table" },
+  { 4250, DMEC, AE, "Invalid index type or index logging option" },
+  { 4251, HA_ERR_FOUND_DUPP_UNIQUE, AE, "Cannot create unique index, duplicate keys found" },
+  { 4252, DMEC, AE, "Failed to allocate space for index" },
+  { 4253, DMEC, AE, "Failed to create index table" },
+  { 4254, DMEC, AE, "Table not an index table" },
+  { 4255, DMEC, AE, "Hash index attributes must be specified in same order as table attributes" },
+  { 4258, DMEC, AE, "Cannot create unique index, duplicate attributes found in definition" },
+  { 4259, DMEC, AE, "Invalid set of range scan bounds" },
+  { 4260, DMEC, UD, "NdbScanFilter: Operator is not defined in NdbScanFilter::Group"},
+  { 4261, DMEC, UD, "NdbScanFilter: Column is NULL"},
+  { 4262, DMEC, UD, "NdbScanFilter: Condition is out of bounds"},
+  { 4263, DMEC, IE, "Invalid blob attributes or invalid blob parts table" },
+  { 4264, DMEC, AE, "Invalid usage of blob attribute" },
+  { 4265, DMEC, AE, "The method is not valid in current blob state" },
+  { 4266, DMEC, AE, "Invalid blob seek position" },
+  { 4267, DMEC, IE, "Corrupted blob value" },
+  { 4268, DMEC, IE, "Error in blob head update forced rollback of transaction" },
+  { 4269, DMEC, IE, "No connection to ndb management server" },
+  { 4270, DMEC, IE, "Unknown blob error" },
+  { 4335, DMEC, AE, "Only one autoincrement column allowed per table. Having a table without primary key uses an autoincremented hidden key, i.e. a table without a primary key can not have an autoincremented column" },
+  { 4271, DMEC, AE, "Invalid index object, not retrieved via getIndex()" },
+  { 4272, DMEC, AE, "Table definition has undefined column" },
+  { 4273, DMEC, IE, "No blob table in dict cache" },
+  { 4274, DMEC, IE, "Corrupted main table PK in blob operation" },
+  { 4275, DMEC, AE, "The blob method is incompatible with operation type or lock mode" }
 };
 
 static
@@ -574,6 +662,7 @@
   { ST_T, OL, "Overload error"},
   { ST_T, TO, "Timeout expired"},
   { ST_T, NS, "Node shutdown"},
+  { ST_T, IT, "Internal temporary"},
   
   { ST_U , UR, "Unknown result error"},
   { ST_U , UE, "Unknown error code"},
@@ -614,6 +703,7 @@
     if(ErrorCodes[i].code == error->code){
       error->classification = ErrorCodes[i].classification;
       error->message        = ErrorCodes[i].message;
+      error->mysql_code     = ErrorCodes[i].mysql_code;
       found = 1;
       break;
     }
@@ -622,6 +712,7 @@
   if(!found){
     error->classification = UE;
     error->message        = "Unknown error code";
+    error->mysql_code     = DMEC;
   }
 
   found = 0;
@@ -639,6 +730,7 @@
   error->details = 0;
 }
 
+#if CHECK_ERRORCODES
 int
 checkErrorCodes(){
   int i, j;
@@ -655,7 +747,6 @@
 
 /*static const int a = checkErrorCodes();*/
 
-#if CHECK_ERRORCODES
 int main(void){
   checkErrorCodes();
   return 0;
Thread
bk commit into 5.1 tree (lzhou:1.2291)lzhou19 Sep