List:Commits« Previous MessageNext Message »
From:Kevin Lewis Date:July 17 2008 5:36pm
Subject:RE: bzr commit into mysql-6.0-falcon branch (lars-erik.bjork:2756) Bug#36990
View as plain text  
Lars-Erik,

I think we should also delete the references to allocationExtent,
falcon_allocation_extent & allocation_extent.  Some of them are already in
commented out sections of code.  We should delete those commented sections.

storage\falcon\Configuration.cpp(66): extern uint falcon_allocation_extent;
storage\falcon\Configuration.cpp(120):	allocationExtent =
falcon_allocation_extent;
storage\falcon\Configuration.cpp(168):	allocationExtent
= 10;
storage\falcon\Configuration.h(53):	uint64		allocationExtent;
storage\falcon\ha_falcon.cpp(88): uint		falcon_allocation_extent;
storage\falcon\ha_falcon.cpp(3644): static
MYSQL_SYSVAR_UINT(allocation_extent, falcon_allocation_extent,
storage\falcon\ha_falcon.cpp(3687):	//MYSQL_SYSVAR(allocation_extent),

Also, it looks like the comment is not being used from the server in
TableSpaceManager::bootstrap().  Chris, should that be uncommented?



>-----Original Message-----
>From: lars-erik.bjork@stripped [mailto:lars-erik.bjork@stripped]
>Sent: Thursday, July 17, 2008 8:52 AM
>To: commits@stripped
>Subject: bzr commit into mysql-6.0-falcon branch (lars-erik.bjork:2756)
>Bug#36990
>
>#At file:///home/lb200670/devel/mysql/falcon-bugs/
>
> 2756 lars-erik.bjork@stripped	2008-07-17
>      bug#36990 - Remove unsupported 'create tablespace' parameters and
>falcon_initial_allocation
>
>      * Removed all usage of falcon_initial_allocation
>      * Removed all usage of unsupported and NDB only parameters to 'create
>tablespace' statement
>      * Updated test falcon_options and falcon_options2 to reflect the
>changes
>modified:
>  mysql-test/suite/falcon/r/falcon_options.result
>  mysql-test/suite/falcon/r/falcon_options2.result
>  mysql-test/suite/falcon/t/falcon_options2.test
>  storage/falcon/BackLog.cpp
>  storage/falcon/Configuration.cpp
>  storage/falcon/Configuration.h
>  storage/falcon/Database.cpp
>  storage/falcon/DatabaseClone.cpp
>  storage/falcon/Dbb.cpp
>  storage/falcon/Dbb.h
>  storage/falcon/IO.cpp
>  storage/falcon/IOx.h
>  storage/falcon/RepositoryVolume.cpp
>  storage/falcon/SQLParse.cpp
>  storage/falcon/SRLCreateTableSpace.cpp
>  storage/falcon/SRLCreateTableSpace.h
>  storage/falcon/Statement.cpp
>  storage/falcon/StorageHandler.cpp
>  storage/falcon/StorageHandler.h
>  storage/falcon/TableSpace.cpp
>  storage/falcon/TableSpace.h
>  storage/falcon/TableSpaceManager.cpp
>  storage/falcon/ha_falcon.cpp
>
>per-file messages:
>  mysql-test/suite/falcon/r/falcon_options.result
>    Adjusted not to expect falcon_initial_allocation specific results
>  mysql-test/suite/falcon/r/falcon_options2.result
>    Adjusted not to expect falcon_initial_allocation specific results
>  mysql-test/suite/falcon/t/falcon_options2.test
>    Removed all testing of falcon_initial_allocation
>  storage/falcon/BackLog.cpp
>    Dbb::create no longer takes initial size as a parameter
>  storage/falcon/Configuration.cpp
>    Removed usage of falcon_initial_allocation and initialAllocation
>  storage/falcon/Configuration.h
>    Removed the initialAllocation variable
>  storage/falcon/Database.cpp
>    * Removed some commented-out code regarding the unsupported parameters
>    * Dbb::create no longer takes initial size as a parameter
>  storage/falcon/DatabaseClone.cpp
>    IO::createFile no longer takes initial size as a parameter
>  storage/falcon/Dbb.cpp
>    * Updated Dbb::create to no longer accept the initial allocation as a
>parameter
>    * IO::createFile no longer takes the initial size as a parameter
>  storage/falcon/Dbb.h
>    Updated Dbb::create to no longer accept the initial allocation as a
>parameter
>  storage/falcon/IO.cpp
>    * Updated IO::createFile to no longer accept the initial allocation as
a
>parameter
>    * Removed the code allocating 'initialAllocation' size of space to a
>file
>  storage/falcon/IOx.h
>    * Updated IO::createFile to no longer accept the initial allocation as
a
>parameter
>  storage/falcon/RepositoryVolume.cpp
>    * Dbb::create no longer takes initial size as a parameter
>  storage/falcon/SQLParse.cpp
>    Removed some commented-out code regarding the unsupported parameters
>  storage/falcon/SRLCreateTableSpace.cpp
>    Removed a lot of commented-out code regarding the unsupported
parameters
>  storage/falcon/SRLCreateTableSpace.h
>    Removed some commented-out code regarding the unsupported parameters
>  storage/falcon/Statement.cpp
>    Removed some commented-out code regarding the unsupported parameters
>  storage/falcon/StorageHandler.cpp
>    * Removed the extern variable falcon_initial_allocation
>    * Updated StorageHandler::genCreateTableSpace and
>StorageHandler::createTableSpace to no longer accept the unsupported
>parameters
>  storage/falcon/StorageHandler.h
>    Updated StorageHandler::genCreateTableSpace and
>StorageHandler::createTableSpace to no longer accept the unsupported
>parameters
>  storage/falcon/TableSpace.cpp
>    * Removed some variables regarding the unsupported parameters
>    * Dbb::create no longer accepts the initial size as a parameter
>    * Removed some commented-out code regarding the unsupported parameters
>  storage/falcon/TableSpace.h
>    Removed some variables regarding the unsupported parameters
>  storage/falcon/TableSpaceManager.cpp
>    Removed some commented-out code regarding the unsupported parameters
>  storage/falcon/ha_falcon.cpp
>    * StorageHandler::createTableSpace no longer accepts the unsupported
>parameters
>    * No longer create the initial allocation sysvar
>=== modified file 'mysql-test/suite/falcon/r/falcon_options.result'
>--- a/mysql-test/suite/falcon/r/falcon_options.result	2008-07-10
>19:00:14 +0000
>+++ b/mysql-test/suite/falcon/r/falcon_options.result	2008-07-17
>13:52:17 +0000
>@@ -9,7 +9,6 @@ falcon_debug_trace	0
> falcon_direct_io	1
> falcon_gopher_threads	5
> falcon_index_chill_threshold	4194304
>-falcon_initial_allocation	0
> falcon_io_threads	2
> falcon_large_blob_threshold	160000
> falcon_lock_wait_timeout	50
>@@ -92,7 +91,6 @@ FALCON_DEBUG_TRACE	0
> FALCON_DIRECT_IO	1
> FALCON_GOPHER_THREADS	5
> FALCON_INDEX_CHILL_THRESHOLD	1073741824
>-FALCON_INITIAL_ALLOCATION	0
> FALCON_IO_THREADS	2
> FALCON_LARGE_BLOB_THRESHOLD	160000
> FALCON_LOCK_WAIT_TIMEOUT	50
>
>=== modified file 'mysql-test/suite/falcon/r/falcon_options2.result'
>--- a/mysql-test/suite/falcon/r/falcon_options2.result	2008-07-10
>19:00:14 +0000
>+++ b/mysql-test/suite/falcon/r/falcon_options2.result	2008-07-17
>13:52:17 +0000
>@@ -10,7 +10,6 @@ FALCON_DEBUG_TRACE	0
> FALCON_DIRECT_IO	1
> FALCON_GOPHER_THREADS	5
> FALCON_INDEX_CHILL_THRESHOLD	4194304
>-FALCON_INITIAL_ALLOCATION	0
> FALCON_IO_THREADS	2
> FALCON_LARGE_BLOB_THRESHOLD	160000
> FALCON_LOCK_WAIT_TIMEOUT	50
>@@ -54,9 +53,6 @@ SELECT @@falcon_gopher_threads;
> SELECT @@falcon_index_chill_threshold;
> @@falcon_index_chill_threshold
> 4194304
>-SELECT @@falcon_initial_allocation;
>-@@falcon_initial_allocation
>-0
> SELECT @@falcon_io_threads;
> @@falcon_io_threads
> 2
>
>=== modified file 'mysql-test/suite/falcon/t/falcon_options2.test'
>--- a/mysql-test/suite/falcon/t/falcon_options2.test	2008-07-10
>19:00:14 +0000
>+++ b/mysql-test/suite/falcon/t/falcon_options2.test	2008-07-17
>13:52:17 +0000
>@@ -14,7 +14,6 @@ SELECT @@falcon_debug_trace;
> SELECT @@falcon_direct_io;
> SELECT @@falcon_gopher_threads;
> SELECT @@falcon_index_chill_threshold;
>-SELECT @@falcon_initial_allocation;
> SELECT @@falcon_io_threads;
> SELECT @@falcon_large_blob_threshold;
> SELECT @@falcon_lock_wait_timeout;
>
>=== modified file 'storage/falcon/BackLog.cpp'
>--- a/storage/falcon/BackLog.cpp	2008-04-12 02:22:50 +0000
>+++ b/storage/falcon/BackLog.cpp	2008-07-17 13:52:17 +0000
>@@ -38,7 +38,7 @@ BackLog::BackLog(Database *db, const cha
> 	database = db;
> 	dbb = new Dbb(database->dbb, 0);
> 	dbb->createPath(fileName);
>-	dbb->create(fileName, dbb->pageSize, 0, HdrTableSpace, 0, NULL, 0);
>+	dbb->create(fileName, dbb->pageSize, 0, HdrTableSpace, 0, NULL);
> 	dbb->noLog = true;
> 	dbb->tableSpaceId = -1;
> 	int32 sectionId = Section::createSection (dbb, NO_TRANSACTION);
>
>=== modified file 'storage/falcon/Configuration.cpp'
>--- a/storage/falcon/Configuration.cpp	2008-07-10 09:01:32 +0000
>+++ b/storage/falcon/Configuration.cpp	2008-07-17 13:52:17 +0000
>@@ -62,7 +62,6 @@
> extern uint64		max_memory_address;
>
> extern uint64		falcon_record_memory_max;
>-extern uint64		falcon_initial_allocation;
> extern uint			falcon_allocation_extent;
> extern uint64		falcon_page_cache_size;
> //extern uint		falcon_debug_mask;
>@@ -116,7 +115,6 @@ Configuration::Configuration(const char
> 	recordMemoryMax				= falcon_record_memory_max;
> 	recordScavengeThresholdPct	= falcon_record_scavenge_threshold;
> 	recordScavengeFloorPct		= falcon_record_scavenge_floor;
>-	initialAllocation			= falcon_initial_allocation;
> 	allocationExtent			= falcon_allocation_extent;
> 	serialLogWindows			= falcon_serial_log_buffers;
> 	pageCacheSize				= falcon_page_cache_size;
>@@ -164,7 +162,6 @@ Configuration::Configuration(const char
> 	recordScavengeThreshold		= (recordMemoryMax * 100) /
>recordScavengeThresholdPct;
> 	recordScavengeFloor			= (recordMemoryMax * 100) /
>recordScavengeFloorPct;
> 	serialLogWindows			= 10;
>-	initialAllocation			= 0;
> 	allocationExtent			= 10;
> 	pageCacheSize				=
>getMemorySize(PAGE_CACHE_MEMORY);
> 	indexChillThreshold			= 4 * ONE_MB;
>
>=== modified file 'storage/falcon/Configuration.h'
>--- a/storage/falcon/Configuration.h	2008-03-11 16:15:47 +0000
>+++ b/storage/falcon/Configuration.h	2008-07-17 13:52:17 +0000
>@@ -49,7 +49,6 @@ public:
> 	uint64		recordScavengeFloor;
> 	int			recordScavengeThresholdPct;
> 	int			recordScavengeFloorPct;
>-	uint64		initialAllocation;
> 	uint64		allocationExtent;
> 	uint64		pageCacheSize;
> 	int64		javaInitialAllocation;
>
>=== modified file 'storage/falcon/Database.cpp'
>--- a/storage/falcon/Database.cpp	2008-07-15 18:57:27 +0000
>+++ b/storage/falcon/Database.cpp	2008-07-17 13:52:17 +0000
>@@ -323,14 +323,6 @@ static const char *createTableSpaces =
> 		"tablespace_id int not null,"
> 		"filename varchar(512) not null,"
> 		"type int,"
>-		/***
>-		"initial_size bigint,"
>-		"extent_size bigint,"
>-		"autoextend_size bigint,"
>-		"max_size bigint,"
>-		"nodegroup int,"
>-		"wait int,"
>-		***/
> 		"comment text)";
>
> static const char *createTableSpaceSequence =
>@@ -634,7 +626,7 @@ void Database::createDatabase(const char
> 	int page_size = PAGE_SIZE;
> #endif
>
>-	cache = dbb->create(filename, page_size,
configuration->pageCacheSize,
>HdrDatabaseFile, 0, "", 0);
>+	cache = dbb->create(filename, page_size,
configuration->pageCacheSize,
>HdrDatabaseFile, 0, "");
>
> 	try
> 		{
>
>=== modified file 'storage/falcon/DatabaseClone.cpp'
>--- a/storage/falcon/DatabaseClone.cpp	2008-07-15 18:57:27 +0000
>+++ b/storage/falcon/DatabaseClone.cpp	2008-07-17 13:52:17 +0000
>@@ -50,7 +50,7 @@ void DatabaseClone::createFile(const cha
> 	shadow = new IO;
> 	shadow->pageSize = dbb->pageSize;
> 	shadow->dbb = dbb;
>-	shadow->createFile(fileName, 0);
>+	shadow->createFile(fileName);
> }
>
> const char* DatabaseClone::getFileName(void)
>
>=== modified file 'storage/falcon/Dbb.cpp'
>--- a/storage/falcon/Dbb.cpp	2008-07-15 18:57:27 +0000
>+++ b/storage/falcon/Dbb.cpp	2008-07-17 13:52:17 +0000
>@@ -147,7 +147,7 @@ Dbb::~Dbb()
> 		dbb->close();
> }
>
>-Cache* Dbb::create(const char * fileName, int pageSz, int64 cacheSize,
>FileType fileType, TransId transId, const char *logRoot, uint64
>initialAllocation)
>+Cache* Dbb::create(const char * fileName, int pageSz, int64 cacheSize,
>FileType fileType, TransId transId, const char *logRoot)
> {
> 	serialLog = database->serialLog;
> 	odsVersion = ODS_VERSION;
>@@ -155,7 +155,7 @@ Cache* Dbb::create(const char * fileName
> 	sequence = 1;
>
> 	init(pageSz, (int) ((cacheSize + pageSz - 1) / pageSz));
>-	createFile(fileName, initialAllocation);
>+	createFile(fileName);
> 	try
> 		{
> 		Hdr::create(this, fileType, transId, logRoot);
>
>=== modified file 'storage/falcon/Dbb.h'
>--- a/storage/falcon/Dbb.h	2008-03-27 06:09:29 +0000
>+++ b/storage/falcon/Dbb.h	2008-07-17 13:52:17 +0000
>@@ -168,7 +168,7 @@ public:
> 	Bdb*	fakePage (int32 pageNumber, PageType pageType, TransId
transId);
> 	Bdb*	trialFetch(int32 pageNumber, PageType pageType, LockType
>lockType);
> 	void	init(int pageSz, int cacheSize);
>-	Cache*	create (const char *fileName, int pageSize, int64 cacheSize,
>FileType fileType, TransId transId, const char *logRoot, uint64
>initialAllocation);
>+	Cache*	create (const char *fileName, int pageSize, int64 cacheSize,
>FileType fileType, TransId transId, const char *logRoot);
> 	void	validateCache(void);
> 	void	logUpdatedRecords(Transaction* transaction, RecordVersion*
>records, bool chill = false);
> 	void	logIndexUpdates(DeferredIndex* deferredIndex);
>
>=== modified file 'storage/falcon/IO.cpp'
>--- a/storage/falcon/IO.cpp	2008-07-08 21:36:34 +0000
>+++ b/storage/falcon/IO.cpp	2008-07-17 13:52:17 +0000
>@@ -184,7 +184,7 @@ bool IO::openFile(const char * name, boo
> 	return fileId != -1;
> }
>
>-bool IO::createFile(const char *name, uint64 initialAllocation)
>+bool IO::createFile(const char *name)
> {
> 	Log::debug("IO::createFile: creating file \"%s\"\n", name);
>
>@@ -218,26 +218,6 @@ bool IO::createFile(const char *name, ui
> #endif
> #endif
>
>-	if (initialAllocation)
>-		{
>-		UCHAR *raw = new UCHAR[8192 * 257];
>-		UCHAR *aligned = (UCHAR*) (((UIPTR) raw + 8191) / 8192 *
8192);
>-		uint size = 8192 * 256;
>-		memset(aligned, 0, size);
>-		uint64 offset = 0;
>-
>-		for (uint64 remaining = initialAllocation; remaining;)
>-			{
>-			uint n = (int) MIN(remaining, size);
>-			write(offset, n, aligned);
>-			offset += n;
>-			remaining -= n;
>-			}
>-
>-		delete [] raw;
>-		sync();
>-		}
>-
> 	return fileId != -1;
> }
>
>
>=== modified file 'storage/falcon/IOx.h'
>--- a/storage/falcon/IOx.h	2008-07-07 14:00:45 +0000
>+++ b/storage/falcon/IOx.h	2008-07-17 13:52:17 +0000
>@@ -63,7 +63,7 @@ public:
> 	void	writePage (Bdb *buffer, int type);
> 	void	writePages(int32 pageNumber, int length, const UCHAR* data,
int
>type);
> 	void	readPage (Bdb *page);
>-	bool	createFile (const char *name, uint64 initialAllocation);
>+	bool	createFile (const char *name);
> 	bool	openFile (const char *name, bool readOnly);
> 	void	longSeek(int64 offset);
> 	void	read(int64 offset, int length, UCHAR* buffer);
>
>=== modified file 'storage/falcon/RepositoryVolume.cpp'
>--- a/storage/falcon/RepositoryVolume.cpp	2008-07-15 18:57:27 +0000
>+++ b/storage/falcon/RepositoryVolume.cpp	2008-07-17 13:52:17 +0000
>@@ -232,7 +232,7 @@ void RepositoryVolume::makeWritable()
> void RepositoryVolume::create()
> {
> 	IO::createPath (fileName);
>-	dbb->create(fileName, dbb->pageSize, 0, HdrRepositoryFile, 0, NULL,
>0);
>+	dbb->create(fileName, dbb->pageSize, 0, HdrRepositoryFile, 0, NULL);
> 	Sync syncDDL(&database->syncSysDDL, "RepositoryVolume::create");
> 	Transaction *transaction = database->getSystemTransaction();
> 	syncDDL.lock(Exclusive);
>
>=== modified file 'storage/falcon/SQLParse.cpp'
>--- a/storage/falcon/SQLParse.cpp	2008-04-05 22:09:17 +0000
>+++ b/storage/falcon/SQLParse.cpp	2008-07-17 13:52:17 +0000
>@@ -3298,21 +3298,6 @@ Syntax* SQLParse::parseCreateTableSpace(
>
> 	for (;;)
> 		{
>-		/***
>-		if (match("INITIAL_SIZE"))
>-			options.append (makeNode(nod_initial_size,
>parseNumber()));
>-		else if (match ("EXTENT_SIZE"))
>-			options.append (makeNode(nod_extent_size,
>parseNumber()));
>-		else if (match ("AUTOEXTEND_SIZE"))
>-			options.append (makeNode(nod_autoextend_size,
>parseNumber()));
>-		else if (match ("MAX_SIZE"))
>-			options.append (makeNode(nod_max_size,
parseNumber()));
>-		else if (match ("NODEGROUP"))
>-			options.append (makeNode(nod_nodegroup,
parseNumber()));
>-		else if (match ("WAIT"))
>-			options.append (makeNode(nod_wait, parseNumber()));
>-		else
>-		***/
> 		if (match ("COMMENT"))
> 			options.append (makeNode(nod_comment,
>parseQuotedString()));
> 		else if (match (","))
>
>=== modified file 'storage/falcon/SRLCreateTableSpace.cpp'
>--- a/storage/falcon/SRLCreateTableSpace.cpp	2008-04-05 22:09:17 +0000
>+++ b/storage/falcon/SRLCreateTableSpace.cpp	2008-07-17 13:52:17 +0000
>@@ -52,14 +52,6 @@ void SRLCreateTableSpace::append(TableSp
> 	putInt(len);
> 	putData(len, (const UCHAR*) p);
> 	putInt(tableSpace->type);
>-	/***
>-	putInt64(tableSpace->initialSize);
>-	putInt64(tableSpace->extentSize);
>-	putInt64(tableSpace->autoextendSize);
>-	putInt64(tableSpace->maxSize);
>-	putInt(tableSpace->nodegroup);
>-	putInt(tableSpace->wait);
>-	***/
> 	p = tableSpace->comment;
> 	len = (int)strlen(p);
> 	putInt(len);
>@@ -81,27 +73,11 @@ void SRLCreateTableSpace::read()
>
> 	if (control->version >= srlVersion15)
> 		{
>-		/***
>-		initialSize	= getInt64();
>-		extentSize	= getInt64();
>-		autoextendSize= getInt64();
>-		maxSize		= getInt64();
>-		nodegroup	= getInt();
>-		wait		= getInt();
>-		***/
> 		commentLength = getInt();
> 		comment = (const char*) getData(commentLength);
> 		}
> 	else
> 		{
>-		/***
>-		initialSize	= 0;
>-		extentSize	= 0;
>-		autoextendSize= 0;
>-		maxSize		= 0;
>-		nodegroup	= 0;
>-		wait		= 0;
>-		***/
> 		commentLength = 0;
> 		comment = NULL;
> 		}
>@@ -110,17 +86,7 @@ void SRLCreateTableSpace::read()
> void SRLCreateTableSpace::pass1()
> {
> 	TableSpaceInit tsInit;
>-
>-	/***
>-	tsInit.initialSize	= initialSize;
>-	tsInit.extentSize	= extentSize;
>-	tsInit.autoextendSize = autoextendSize;
>-	tsInit.maxSize		= maxSize;
>-	tsInit.nodegroup	= nodegroup;
>-	tsInit.wait			= wait;
>-	***/
> 	tsInit.comment		= comment;
>-
> 	log->database->tableSpaceManager->redoCreateTableSpace(tableSpaceId,
>nameLength, name, filenameLength, filename, type, &tsInit);
> }
>
>
>=== modified file 'storage/falcon/SRLCreateTableSpace.h'
>--- a/storage/falcon/SRLCreateTableSpace.h	2008-04-05 22:09:17 +0000
>+++ b/storage/falcon/SRLCreateTableSpace.h	2008-07-17 13:52:17 +0000
>@@ -48,14 +48,6 @@ public:
> 	int			nameLength;
> 	int			filenameLength;
> 	int			type;
>-	/***
>-	int64		initialSize;
>-	int64		extentSize;
>-	int64		autoExtendSize;
>-	int64		maxSize;
>-	int			nodegroup;
>-	int			wait;
>-	***/
> 	const char	*comment;
> 	int			commentLength;
> };
>
>=== modified file 'storage/falcon/Statement.cpp'
>--- a/storage/falcon/Statement.cpp	2008-07-15 18:57:27 +0000
>+++ b/storage/falcon/Statement.cpp	2008-07-17 13:52:17 +0000
>@@ -2965,26 +2965,6 @@ void Statement::createTableSpace(Syntax
>
> 		switch (child->type)
> 			{
>-			/***
>-			case nod_initial_size:
>-				tsInit.initial_size = child->getChild(0)-
>>getQuad();
>-				break;
>-			case nod_extent_size:
>-				tsInit.extent_size =
child->getChild(0)->getQuad();
>-				break;
>-			case nod_autoextend_size:
>-				tsInit.autoextend_size = child->getChild(0)-
>>getQuad();
>-				break;
>-			case nod_max_size:
>-				tsInit.maxSize =
child->getChild(0)->getQuad();
>-				break;
>-			case nod_nodegroup:
>-				tsInit.nodegroup =
child->getChild(0)->getNumber();
>-				break;
>-			case nod_wait:
>-				tsInit.wait =
child->getChild(0)->getNumber();
>-				break;
>-			***/
> 			case nod_comment:
> 				tsInit.comment =
child->getChild(0)->getString();
> 				break;
>
>=== modified file 'storage/falcon/StorageHandler.cpp'
>--- a/storage/falcon/StorageHandler.cpp	2008-07-15 18:57:27 +0000
>+++ b/storage/falcon/StorageHandler.cpp	2008-07-17 13:52:17 +0000
>@@ -51,7 +51,6 @@ struct StorageSavepoint {
> 	int					savepoint;
> 	};
>
>-extern uint64		falcon_initial_allocation;
>
> static const char *createTempSpace = "upgrade tablespace "
>TEMPORARY_TABLESPACE " filename '" FALCON_TEMPORARY "'";
> //static const char *dropTempSpace = "drop tablespace "
>TEMPORARY_TABLESPACE;
>@@ -464,29 +463,14 @@ Connection* StorageHandler::getDictionar
> 	return dictionaryConnection;
> }
>
>-JString StorageHandler::genCreateTableSpace(const char* tableSpaceName,
>const char* filename,
>-
>	unsigned long long initialSize,
>-
>	unsigned long long extentSize,
>-
>	unsigned long long autoextendSize,
>-
>	unsigned long long maxSize,
>-
>	int nodegroup, bool wait, const char* comment)
>+JString StorageHandler::genCreateTableSpace(const char* tableSpaceName,
>const char* filename, const char* comment)
> {
> 	CmdGen gen;
>-	/***
>-	gen.gen("create tablespace \"%s\" filename '%s' initial_size "
>I64FORMAT " extent_size " I64FORMAT
>-				" autoextend_size " I64FORMAT " max_size "
>I64FORMAT " nodegroup %d wait %d comment '%s'",
>-				tableSpaceName, filename, initialSize,
extentSize,
>autoextendSize, maxSize, nodegroup, (int)wait, comment ? comment : "");
>-	***/
> 	gen.gen("create tablespace \"%s\" filename '%s' comment '%s'",
>tableSpaceName, filename, comment ? comment : "");
> 	return (gen.getString());
> }
>
>-int StorageHandler::createTablespace(const char* tableSpaceName, const
>char* filename,
>-
unsigned
>long long initialSize,
>-
unsigned
>long long extentSize,
>-
unsigned
>long long autoextendSize,
>-
unsigned
>long long maxSize,
>-
int
>nodegroup, bool wait, const char* comment)
>+int StorageHandler::createTablespace(const char* tableSpaceName, const
>char* filename, const char* comment)
> {
> 	if (!defaultDatabase)
> 		initialize();
>@@ -499,8 +483,7 @@ int StorageHandler::createTablespace(con
>
> 	try
> 		{
>-		JString cmd = genCreateTableSpace(tableSpaceName, filename,
>initialSize, extentSize,
>-
>	autoextendSize, maxSize, nodegroup, wait, comment);
>+		JString cmd = genCreateTableSpace(tableSpaceName, filename,
>comment);
> 		Sync sync(&dictionarySyncObject,
>"StorageHandler::createTablespace");
> 		sync.lock(Exclusive);
> 		Statement *statement =
dictionaryConnection->createStatement();
>@@ -998,7 +981,7 @@ void StorageHandler::initialize(void)
> 		IO::deleteFile(FALCON_TEMPORARY);
> 		dictionaryConnection = defaultDatabase->getOpenConnection();
> 		Statement *statement =
dictionaryConnection->createStatement();
>-		JString createTableSpace =
>genCreateTableSpace(DEFAULT_TABLESPACE, FALCON_USER,
>falcon_initial_allocation);
>+		JString createTableSpace =
>genCreateTableSpace(DEFAULT_TABLESPACE, FALCON_USER);
> 		statement->executeUpdate(createTableSpace);
>
> 		for (const char **ddl = falconSchema; *ddl; ++ddl)
>
>=== modified file 'storage/falcon/StorageHandler.h'
>--- a/storage/falcon/StorageHandler.h	2008-04-05 22:09:17 +0000
>+++ b/storage/falcon/StorageHandler.h	2008-07-17 13:52:17 +0000
>@@ -85,12 +85,7 @@ public:
> 	virtual int			rollbackByXid(int xidLength, const
unsigned
>char* xis);
>
> 	virtual Connection*	getDictionaryConnection(void);
>-	virtual int			createTablespace(const char*
tableSpaceName,
>const char* filename,
>-
>	unsigned long long initialSize = 0,
>-
>	unsigned long long extentSize = 0,
>-
>	unsigned long long autoextendSize = 0,
>-
>	unsigned long long maxSize = 0,
>-
int
>nodegroup = 0, bool wait = false, const char* comment = NULL);
>+	virtual int			createTablespace(const char*
tableSpaceName,
>const char* filename, const char* comment = NULL);
> 	virtual int			deleteTablespace(const char*
>tableSpaceName);
>
> 	virtual StorageTableShare* findTable(const char* pathname);
>@@ -134,12 +129,7 @@ public:
> 	void				initialize(void);
> 	void				dropTempTables(void);
> 	void				cleanFileName(const char* pathname,
char*
>filename, int filenameLength);
>-	JString				genCreateTableSpace(const char*
>tableSpaceName, const char* filename,
>-
>	unsigned long long initialSize = 0,
>-
>	unsigned long long extentSize = 0,
>-
>	unsigned long long autoextendSize = 0,
>-
>	unsigned long long maxSize = 0,
>-
int
>nodegroup = 0, bool wait = false, const char* comment = NULL);
>+	JString				genCreateTableSpace(const char*
>tableSpaceName, const char* filename, const char* comment = NULL);
>
> 	StorageConnection	*connections[connectionHashSize];
> 	StorageDatabase		*defaultDatabase;
>
>=== modified file 'storage/falcon/TableSpace.cpp'
>--- a/storage/falcon/TableSpace.cpp	2008-04-05 22:09:17 +0000
>+++ b/storage/falcon/TableSpace.cpp	2008-07-17 13:52:17 +0000
>@@ -50,15 +50,7 @@ TableSpace::TableSpace(Database *db, con
>
> 	TableSpaceInit spaceInit;
> 	TableSpaceInit *init = (tsInit ? tsInit : &spaceInit);
>-	initialSize	= init->initialSize;
> 	comment	= init->comment;
>-	/***
>-	extentSize	= init->extentSize;
>-	autoExtendSize = init->autoExtendSize;
>-	maxSize		= init->maxSize;
>-	nodegroup	= init->nodegroup;
>-	wait		= init->wait;
>-	***/
> }
>
> TableSpace::~TableSpace()
>@@ -132,7 +124,7 @@ void TableSpace::open()
> void TableSpace::create()
> {
> 	dbb->createPath(filename);
>-	dbb->create(filename, dbb->pageSize, 0, HdrTableSpace, 0, NULL,
>initialSize);
>+	dbb->create(filename, dbb->pageSize, 0, HdrTableSpace, 0, NULL);
> 	active = true;
> 	dbb->flush();
> }
>@@ -169,14 +161,6 @@ void TableSpace::save(void)
> 	statement->setInt(n++, tableSpaceId);
> 	statement->setString(n++, filename);
> 	statement->setInt(n++, type);
>-	/***
>-	statement->setLong(n++, initialSize);
>-	statement->setLong(n++, extentSize);
>-	statement->setLong(n++, autoExtendSize);
>-	statement->setLong(n++, maxSize);
>-	statement->setInt(n++, nodegroup);
>-	statement->setInt(n++, wait);
>-	***/
> 	statement->setString(n++, comment);
> 	statement->executeUpdate();
> 	needSave = false;
>
>=== modified file 'storage/falcon/TableSpace.h'
>--- a/storage/falcon/TableSpace.h	2008-04-05 22:09:17 +0000
>+++ b/storage/falcon/TableSpace.h	2008-07-17 13:52:17 +0000
>@@ -29,17 +29,8 @@ static const int TABLESPACE_TYPE_REPOSIT
>
> struct TableSpaceInit
> {
>-	int64	initialSize;
> 	JString	comment;
>-	TableSpaceInit(): initialSize(0), comment("") {}
>-	/***
>-	int64	extentSize;
>-	int64	autoExtendSize;
>-	int64	maxSize;
>-	int		nodegroup;
>-	int		wait;
>-	TableSpaceInit(): initialSize(0), extentSize(0), autoExtendSize(0),
>maxSize(0), nodegroup(0), wait(0), comment("") {}
>-	***/
>+	TableSpaceInit(): comment("") {}
> };
>
> class Dbb;
>@@ -75,14 +66,6 @@ public:
> 	bool		active;
> 	bool		needSave;
>
>-	int64		initialSize;
>-	/***
>-	int64		extentSize;
>-	int64		autoExtendSize;
>-	int64		maxSize;
>-	int			nodegroup;
>-	int			wait;
>-	***/
> 	JString		comment;
> };
>
>
>=== modified file 'storage/falcon/TableSpaceManager.cpp'
>--- a/storage/falcon/TableSpaceManager.cpp	2008-07-15 18:57:27 +0000
>+++ b/storage/falcon/TableSpaceManager.cpp	2008-07-17 13:52:17 +0000
>@@ -117,14 +117,6 @@ TableSpace* TableSpaceManager::findTable
> 		int type = TABLESPACE_TYPE_TABLESPACE;
//
>type (forced)
>
> 		TableSpaceInit tsInit;
>-		/***
>-		tsInit.initialSize	= resultSet->getLong(n++);
>-		tsInit.extentSize	= resultSet->getLong(n++);
>-		tsInit.autoExtendSize = resultSet->getLong(n++);
>-		tsInit.maxSize		= resultSet->getLong(n++);
>-		tsInit.nodegroup	= resultSet->getInt(n++);
>-		tsInit.wait			= resultSet->getInt(n++);
>-		***/
> 		tsInit.comment		= resultSet->getString(n++);	//
>comment
>
> 		tableSpace = new TableSpace(database, name, id, fileName,
type,
>&tsInit);
>@@ -239,21 +231,9 @@ void TableSpaceManager::bootstrap(int se
> 		p = EncodedDataStream::decode(p, &fileName, true);
> 		p = EncodedDataStream::decode(p, &type, true);
> 		/***
>-		p = EncodedDataStream::decode(p, &initialSize, true);
>-		p = EncodedDataStream::decode(p, &extentSsize, true);
>-		p = EncodedDataStream::decode(p, &autoExtendSize, true);
>-		p = EncodedDataStream::decode(p, &maxSize, true);
>-		p = EncodedDataStream::decode(p, &nodegroup, true);
>-		p = EncodedDataStream::decode(p, &wait, true);
> 		p = EncodedDataStream::decode(p, &comment, true);
>
> 		TableSpaceInit tsInit;
>-		tsInit.initialSize	= initialSize.getQuad();
>-		tsInit.extentSize	= extentSize.getQuad();
>-		tsInit.autoExtendSize = autoExtendSize.getQuad();
>-		tsInit.maxSize		= maxSize.getQuad();
>-		tsInit.nodegroup	= nodegroup.getInt();
>-		tsInit.wait			= wait.getInt();
> 		tsInit.comment		= comment.getString();
> 		***/
>
>
>=== modified file 'storage/falcon/ha_falcon.cpp'
>--- a/storage/falcon/ha_falcon.cpp	2008-07-14 05:27:57 +0000
>+++ b/storage/falcon/ha_falcon.cpp	2008-07-17 13:52:17 +0000
>@@ -83,7 +83,6 @@ static StorageHandler	*storageHandler;
> #undef PARAMETER_BOOL
>
> ulonglong	falcon_record_memory_max;
>-ulonglong	falcon_initial_allocation;
> ulonglong	falcon_serial_log_file_size;
> uint		falcon_allocation_extent;
> ulonglong	falcon_page_cache_size;
>@@ -2044,16 +2043,22 @@ int StorageInterface::alter_tablespace(h
> 	/*
> 	CREATE TABLESPACE tablespace
> 		ADD DATAFILE 'file'
>-		USE LOGFILE GROUP logfile_group
>-		[EXTENT_SIZE [=] extent_size]
>-		[INITIAL_SIZE [=] initial_size]
>-		[AUTOEXTEND_SIZE [=] autoextend_size]
>-		[MAX_SIZE [=] max_size]
>-		[NODEGROUP [=] nodegroup_id]
>-		[WAIT]
>+		USE LOGFILE GROUP logfile_group         // NDB only
>+		[EXTENT_SIZE [=] extent_size]           // Not supported
>+		[INITIAL_SIZE [=] initial_size]         // Not supported
>+		[AUTOEXTEND_SIZE [=] autoextend_size]   // Not supported
>+		[MAX_SIZE [=] max_size]                 // Not supported
>+		[NODEGROUP [=] nodegroup_id]            // NDB only
>+		[WAIT]                                  // NDB only
> 		[COMMENT [=] comment_text]
> 		ENGINE [=] engine
>+
>+
>+	Parameters EXTENT_SIZE, INITIAL,SIZE, AUTOEXTEND_SIZE and MAX_SIZE
are
>+	currently not supported by Falcon. LOGFILE GROUP, NODEGROUP and WAIT
>are
>+	for NDB only.
> 	*/
>+
> 	if (ts_info->data_file_name)
> 		{
> 		char buff[FN_REFLEN];
>@@ -2071,15 +2076,7 @@ int StorageInterface::alter_tablespace(h
> 	switch (ts_info->ts_cmd_type)
> 		{
> 		case CREATE_TABLESPACE:
>-			ret = storageHandler->createTablespace(	ts_info-
>>tablespace_name,
>-
>		ts_info->data_file_name,
>-
>		ts_info->initial_size,
>-
>		ts_info->extent_size,
>-
>		ts_info->autoextend_size,
>-
>		ts_info->max_size,
>-
>		ts_info->nodegroup_id,
>-
>		ts_info->wait_until_completed,
>-
>		ts_info->ts_comment);
>+			ret = storageHandler->createTablespace(	ts_info-
>>tablespace_name, ts_info->data_file_name, ts_info->ts_comment);
> 			break;
>
> 		case DROP_TABLESPACE:
>@@ -3630,11 +3627,6 @@ static MYSQL_SYSVAR_ULONGLONG(record_mem
>   "The maximum size of the record memory cache.",
>   NULL, StorageInterface::updateRecordMemoryMax, LL(250)<<20, 0,
>(ulonglong) max_memory_address, LL(1)<<20);
>
>-static MYSQL_SYSVAR_ULONGLONG(initial_allocation,
>falcon_initial_allocation,
>-  PLUGIN_VAR_RQCMDARG, // | PLUGIN_VAR_READONLY,
>-  "Initial allocation (in bytes) of falcon user tablespace.",
>-  NULL, NULL, 0, 0, LL(4000000000), LL(1)<<20);
>-
> static MYSQL_SYSVAR_ULONGLONG(serial_log_file_size,
>falcon_serial_log_file_size,
>   PLUGIN_VAR_RQCMDARG,
>   "If serial log file grows larger than this value, it will be truncated
>when it is reused",
>@@ -3683,7 +3675,6 @@ static struct st_mysql_sys_var* falconVa
> 	MYSQL_SYSVAR(scavenge_schedule),
> 	//MYSQL_SYSVAR(debug_mask),
> 	MYSQL_SYSVAR(record_memory_max),
>-	MYSQL_SYSVAR(initial_allocation),
> 	//MYSQL_SYSVAR(allocation_extent),
> 	MYSQL_SYSVAR(page_cache_size),
> 	MYSQL_SYSVAR(consistent_read),
>
>
>--
>MySQL Code Commits Mailing List
>For list archives: http://lists.mysql.com/commits
>To unsubscribe:    http://lists.mysql.com/commits?unsub=1

Thread
bzr commit into mysql-6.0-falcon branch (lars-erik.bjork:2756) Bug#36990lars-erik.bjork17 Jul
  • RE: bzr commit into mysql-6.0-falcon branch (lars-erik.bjork:2756) Bug#36990Kevin Lewis17 Jul
    • Re: bzr commit into mysql-6.0-falcon branch (lars-erik.bjork:2756)Bug#36990Chris Powers17 Jul