From: Date: January 19 2006 2:08pm Subject: bk commit into 5.1 tree (jonas:1.1972) BUG#16455 List-Archive: http://lists.mysql.com/commits/1343 X-Bug: 16455 Message-Id: <20060119130811.097B42A24DC@perch.ndb.mysql.com> Below is the list of changes that have just been committed into a local 5.1 repository of jonas. When jonas 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 1.1972 06/01/19 14:08:05 jonas@stripped +5 -0 bug#16455 - ndb crash when running of of rope pool storage/ndb/src/ndbapi/ndberror.c 1.46 06/01/19 14:08:02 jonas@stripped +2 -1 New error code for rope pool storage/ndb/src/mgmsrv/ConfigInfo.cpp 1.71 06/01/19 14:08:02 jonas@stripped +12 -0 New error code for rope pool storage/ndb/src/kernel/blocks/dbdict/Dbdict.cpp 1.63 06/01/19 14:08:02 jonas@stripped +36 -6 New error code for rope pool storage/ndb/include/mgmapi/mgmapi_config_parameters.h 1.23 06/01/19 14:08:02 jonas@stripped +2 -0 New error code for rope pool storage/ndb/include/kernel/signaldata/CreateTable.hpp 1.6 06/01/19 14:08:02 jonas@stripped +2 -1 New error code for rope pool # 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: jonas # Host: perch.ndb.mysql.com # Root: /home/jonas/src/mysql-5.1.4 --- 1.22/storage/ndb/include/mgmapi/mgmapi_config_parameters.h 2005-11-04 21:09:58 +01:00 +++ 1.23/storage/ndb/include/mgmapi/mgmapi_config_parameters.h 2006-01-19 14:08:02 +01:00 @@ -85,6 +85,8 @@ #define CFG_DB_MAX_OPEN_FILES 159 +#define CFG_DB_STRING_MEMORY 161 + #define CFG_NODE_ARBIT_RANK 200 #define CFG_NODE_ARBIT_DELAY 201 --- 1.5/storage/ndb/include/kernel/signaldata/CreateTable.hpp 2005-11-07 12:19:05 +01:00 +++ 1.6/storage/ndb/include/kernel/signaldata/CreateTable.hpp 2006-01-19 14:08:02 +01:00 @@ -95,7 +95,8 @@ InvalidTablespace = 755, VarsizeBitfieldNotSupported = 757, NotATablespace = 758, - InvalidTablespaceVersion = 759 + InvalidTablespaceVersion = 759, + OutOfStringBuffer = 773 }; private: --- 1.70/storage/ndb/src/mgmsrv/ConfigInfo.cpp 2005-11-04 21:09:59 +01:00 +++ 1.71/storage/ndb/src/mgmsrv/ConfigInfo.cpp 2006-01-19 14:08:02 +01:00 @@ -1202,6 +1202,18 @@ "0", STR_VALUE(MAX_INT_RNIL) }, + { + CFG_DB_STRING_MEMORY, + "StringMemory", + DB_TOKEN, + "Default size of string memory (0 -> 5% of max 1-100 -> %of max, >100 -> actual bytes)", + ConfigInfo::CI_USED, + false, + ConfigInfo::CI_INT, + "0", + "0", + STR_VALUE(MAX_INT_RNIL) }, + /*************************************************************************** * API ***************************************************************************/ --- 1.62/storage/ndb/src/kernel/blocks/dbdict/Dbdict.cpp 2005-12-02 20:07:08 +01:00 +++ 1.63/storage/ndb/src/kernel/blocks/dbdict/Dbdict.cpp 2006-01-19 14:08:02 +01:00 @@ -2016,8 +2016,30 @@ c_schemaOp.setSize(8); //c_opDropObj.setSize(8); c_Trans.setSize(8); - c_rope_pool.setSize(100000/28); + Uint32 rps = 0; + rps += tablerecSize * (MAX_TAB_NAME_SIZE + MAX_FRM_DATA_SIZE); + rps += attributesize * (MAX_ATTR_NAME_SIZE + MAX_ATTR_DEFAULT_VALUE_SIZE); + rps += c_maxNoOfTriggers * MAX_TAB_NAME_SIZE; + rps += (10 + 10) * MAX_TAB_NAME_SIZE; + + Uint32 sm = 5; + ndb_mgm_get_int_parameter(p, CFG_DB_STRING_MEMORY, &sm); + if (sm == 0) + sm = 5; + + Uint32 sb = 0; + if (sm < 100) + { + sb = (rps * sm) / 100; + } + else + { + sb = sm; + } + + c_rope_pool.setSize(sb/28 + 100); + // Initialize BAT for interface to file system NewVARIABLE* bat = allocateBat(2); bat[0].WA = &c_schemaPageRecordArray.getPtr(0)->word[0]; @@ -5795,7 +5817,8 @@ { Rope name(c_rope_pool, tablePtr.p->tableName); - ndbrequire(name.assign(tableDesc.TableName, tableNameLength, name_hash)); + tabRequire(name.assign(tableDesc.TableName, tableNameLength, name_hash), + CreateTableRef::OutOfStringBuffer); } Ptr obj_ptr; @@ -5827,7 +5850,8 @@ { Rope frm(c_rope_pool, tablePtr.p->frmData); - ndbrequire(frm.assign(tableDesc.FrmData, tableDesc.FrmLen)); + tabRequire(frm.assign(tableDesc.FrmData, tableDesc.FrmLen), + CreateTableRef::OutOfStringBuffer); } tablePtr.p->ngLen = tableDesc.FragmentDataLen; @@ -5942,7 +5966,13 @@ */ { Rope name(c_rope_pool, attrPtr.p->attributeName); - name.assign(attrDesc.AttributeName, len, name_hash); + if (!name.assign(attrDesc.AttributeName, len, name_hash)) + { + jam(); + parseP->errorCode = CreateTableRef::OutOfStringBuffer; + parseP->errorLine = __LINE__; + return; + } } attrPtr.p->attributeId = i; //attrPtr.p->attributeId = attrDesc.AttributeId; @@ -14568,7 +14598,7 @@ { Rope name(c_rope_pool, obj_ptr.p->m_name); if(!name.assign(fg.FilegroupName, len, hash)){ - op->m_errorCode = CreateTableRef::TableNameTooLong; + op->m_errorCode = CreateTableRef::OutOfStringBuffer; c_obj_pool.release(obj_ptr); c_filegroup_pool.release(fg_ptr); break; @@ -14774,7 +14804,7 @@ { Rope name(c_rope_pool, obj_ptr.p->m_name); if(!name.assign(f.FileName, len, hash)){ - op->m_errorCode = CreateTableRef::TableNameTooLong; + op->m_errorCode = CreateTableRef::OutOfStringBuffer; c_obj_pool.release(obj_ptr); c_file_pool.release(filePtr); break; --- 1.45/storage/ndb/src/ndbapi/ndberror.c 2005-12-14 11:06:38 +01:00 +++ 1.46/storage/ndb/src/ndbapi/ndberror.c 2006-01-19 14:08:02 +01:00 @@ -391,7 +391,8 @@ { 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" }, - + { 773, DMEC, SE, "Out of string memory, please modify StringMemory config parameter" }, + /** * FunctionNotImplemented */