mirror of
https://github.com/MariaDB/server.git
synced 2025-01-18 13:02:28 +01:00
e2513bf07f
Fixes the following bugs: Bug #30706: SQL thread on slave is allowed to block client queries when slave load is high Add (innodb|innobase|srv)_replication_delay MySQL config parameter. Bug #30888: Innodb table + stored procedure + row deletion = server crash While adding code for the low level read of the AUTOINC value from the index, the case for MEDIUM ints which are 3 bytes was missed triggering an assertion. Bug #30907: Regression: "--innodb_autoinc_lock_mode=0" (off) not same as older releases We don't rely on *first_value to be 0 when checking whether get_auto_increment() has been invoked for the first time in a multi-row INSERT. We instead use trx_t::n_autoinc_rows. Initialize trx::n_autoinc_rows inside ha_innobase::start_stmt() too. Bug #31444: "InnoDB: Error: MySQL is freeing a thd" in innodb_mysql.test ha_innobase::external_lock(): Update prebuilt->mysql_has_locked and trx->n_mysql_tables_in_use only after row_lock_table_for_mysql() returns DB_SUCCESS. A timeout on LOCK TABLES would lead to an inconsistent state, which would cause trx_free() to print a warning. Bug #31494: innodb + 5.1 + read committed crash, assertion Set an error code when a deadlock occurs in semi-consistent read. mysql-test/r/innodb.result: Apply snapshot innodb-5.1-ss1989 Also, a test is moved into the new innodb_autoinc_lock_mode_zero test, because it depends on a non-default setting for a read-only variable. Revision r1821: Merge a change from MySQL AB: ChangeSet@1.2536.50.1 2007-08-02 12:45:56-07:00 igor@mysql.com Fixed bug#28404. This patch adds cost estimation for the queries with ORDER BY / GROUP BY and LIMIT. If there was a ref/range access to the table whose rows were required to be ordered in the result set the optimizer always employed this access though a scan by a different index that was compatible with the required order could be cheaper to produce the first L rows of the result set. Now for such queries the optimizer makes a choice between the cheapest ref/range accesses not compatible with the given order and index scans compatible with it. innodb.result: Adjusted results for test cases affected fy the fix for bug #28404. Revision r1781: Fix a test case that was broken after Bug#16979 fix. See r1645 and r1735. The variable used in the tests below was introduced in r1735. Revision r1792: innodb.result: Revert r1655, which should have been reverted as part of r1781. Revision r1843: Add test for Bug# 21409, the actual bug was fixed in r1334. mysql-test/t/innodb.test: Apply snapshot innodb-5.1-ss1989 Also, a test is moved into the new innodb_autoinc_lock_mode_zero test, because it depends on a non-default setting for a read-only variable. Revision r1781: Fix a test case that was broken after Bug#16979 fix. See r1645 and r1735. The variable used in the tests below was introduced in r1735. Revision r1843: Add test for Bug# 21409, the actual bug was fixed in r1334. storage/innobase/buf/buf0lru.c: Apply snapshot innodb-5.1-ss1989 Revision r1819: Merge r1815:1817 from branches/zip: Improve Valgrind instrumentation. UNIV_MEM_ASSERT_RW(): New macro, to check that the contents of a memory area is defined. UNIV_MEM_ASSERT_W(): New macro, to check that a memory area is writable. UNIV_MEM_ASSERT_AND_FREE(): New macro, to check that the memory is writable before declaring it free (unwritable). This replaces UNIV_MEM_FREE() in many places. mem_init_buf(): Check that the memory is writable, and declare it undefined. mem_erase_buf(): Check that the memory is writable, and declare it freed. storage/innobase/dict/dict0dict.c: Apply snapshot innodb-5.1-ss1989 Revision r1894: Add debug lock checks to autoinc functions. Add lock guards around an invocation of dict_table_autoinc_initialize(). storage/innobase/dict/dict0load.c: Apply snapshot innodb-5.1-ss1989 Revision r1974: Prevent loading of tables that have unsupported features most notably FTS indexes. storage/innobase/handler/ha_innodb.cc: Apply snapshot innodb-5.1-ss1989 Revision r1850: Implement this feature request: http://bugs.mysql.com/30706 * Add a function that returns the number of microseconds since epoch - ut_time_us(). * Add (innodb|innobase|srv)_replication_delay MySQL config parameter. * Add UT_WAIT_FOR() macro that waits for a specified condition to occur until a timeout elapses. * Using all of the above, handle the replication thread specially in srv_conc_enter_innodb(). Approved by: Heikki Revision r1887: Merge changes from MySQL AB: ChangeSet@1.2528.115.25 2007-08-27 18:18:14-06:00 tsmith@hindu.god Fix some Windows compiler warnings. dict0mem.c: Fix compiler warning with a cast. ha_innodb.cc: Change type to fix a compiler warning. Revision r1809: ha_innobase::external_lock(): Update prebuilt->mysql_has_locked and trx->n_mysql_tables_in_use only after row_lock_table_for_mysql() returns DB_SUCCESS. A timeout on LOCK TABLES would lead to an inconsistent state, which would cause trx_free() to print a warning. This was later reported as Bug #31444. Revision r1833: Add /*== ... === */ decoration that was missing around some auto-inc functions. Add a missing comment, fix the length of a decoration. Initialize the *value out parameter in ha_innobase::innobase_get_auto_increment(). Revision r1866: Revert r1850 as MySQL did not approve the addition. log for r1850: Implement this feature request: http://bugs.mysql.com/30706 * Add a function that returns the number of microseconds since epoch - ut_time_us(). * Add (innodb|innobase|srv)_replication_delay MySQL config parameter. * Add UT_WAIT_FOR() macro that waits for a specified condition to occur until a timeout elapses. * Using all of the above, handle the replication thread specially in srv_conc_enter_innodb(). Revision r1846: Add config option innodb_use_adaptive_hash_indexes to enable/disable adaptive hash indexes. It is enabled by default (no change in default behavior). Approved by: Marko Revision r1974: Prevent loading of tables that have unsupported features most notably FTS indexes. Revision r1829: Add assertion to enforce check of an implicit invariant and add comment about retry of autoinc read semantics. We always reread the table's autoinc counter after attempting to initialize it i.e., we want to guarantee that a read of autoinc valus that is returned to the caller is always covered by the AUTOINC locking mechanism. Revision r1787: Move the prototype of innobase_print_identifier() from ut0ut.c to ha_prototypes.h. Enclose the definitions in ha_prototypes.h in #ifndef UNIV_HOTBACKUP. Revision r1888: Merge a change from MySQL AB: ChangeSet@1.2528.115.30 2007-08-28 10:17:15-06:00 tsmith@hindu.god Fix another compiler warning on Windows in InnoDB. ha_innodb.cc: Fix compiler warning: ::get_auto_increment takes a ulonglong for nb_desired_values, but InnoDB's trx struct stores it as a ulint (unsigned long). Probably harmless, as a single statement won't be asking for more than 2^32 rows. Revision r1987: Bug fix: The problem was that when write_row() attempted to update the max autoinc value, and if it was rolled back because of a deadlock, the deadlock error (transaction rollback) was not being propagated back to MySQL. Revision r1889: Merge a change from MySQL AB: ChangeSet@1.2560 2007-09-21 10:15:16+02:00 gkodinov@local ha_innodb.cc: fixed type conversion warnings revealed by bug 30639 Revision r1989: Suppress printing of deadlock errors while reading the autoinc value. DB_DEADLOCK errors are part of normal processing and excessive printing of these error messages could be disconcerting for users. Revision r1828: Fix two bugs: Bug# 30907: We don't rely on *first_value to be 0 when checking whether get_auto_increment() has been invoked for the first time in a multi-row INSERT. We instead use trx_t::n_autoinc_rows. Initialize trx::n_autoinc_rows inside ha_innobase::start_stmt() too. Bug# 30888: While adding code for the low level read of the AUTOINC value from the index, the case for MEDIUM ints which are 3 bytes was missed triggering an assertion. storage/innobase/handler/ha_innodb.h: Apply snapshot innodb-5.1-ss1989 Revision r1844: Remove the prototypes of some functions inside #if 0. The function definitions were removed in r1746. storage/innobase/ibuf/ibuf0ibuf.c: Apply snapshot innodb-5.1-ss1989 Revision r1965: ibuf_insert_to_index_page(): Fix typos in diagnostic output. storage/innobase/include/db0err.h: Apply snapshot innodb-5.1-ss1989 Revision r1974: Prevent loading of tables that have unsupported features most notably FTS indexes. storage/innobase/include/ha_prototypes.h: Apply snapshot innodb-5.1-ss1989 Revision r1787: Move the prototype of innobase_print_identifier() from ut0ut.c to ha_prototypes.h. Enclose the definitions in ha_prototypes.h in #ifndef UNIV_HOTBACKUP. storage/innobase/include/mach0data.h: Apply snapshot innodb-5.1-ss1989 Revision r1779: Fix a bug that handles the case where the host specific byte order matches the InnoDB storage byte order, which is big-endian. storage/innobase/include/mach0data.ic: Apply snapshot innodb-5.1-ss1989 Revision r1779: Fix a bug that handles the case where the host specific byte order matches the InnoDB storage byte order, which is big-endian. storage/innobase/include/mem0dbg.h: Apply snapshot innodb-5.1-ss1989 Revision r1830: Improve memory debugging. This is follow-up to r1819. mem_heap_validate(): Compile this function also if UNIV_MEM_DEBUG is defined. Previously, this function was only compiled with UNIV_DEBUG. mem_heap_free_heap_top(): Flag the memory allocated, not freed, for Valgrind. Otherwise, Valgrind would complain on the second call of mem_heap_empty(). UNIV_MEM_ASSERT_RW(), UNIV_MEM_ASSERT_W(): Display additional diagnostics for failed Valgrind checks. storage/innobase/include/mem0mem.ic: Apply snapshot innodb-5.1-ss1989 Revision r1830: Improve memory debugging. This is follow-up to r1819. mem_heap_validate(): Compile this function also if UNIV_MEM_DEBUG is defined. Previously, this function was only compiled with UNIV_DEBUG. mem_heap_free_heap_top(): Flag the memory allocated, not freed, for Valgrind. Otherwise, Valgrind would complain on the second call of mem_heap_empty(). UNIV_MEM_ASSERT_RW(), UNIV_MEM_ASSERT_W(): Display additional diagnostics for failed Valgrind checks. Revision r1937: mem_heap_free_top(): Remove a bogus Valgrind warning. Revision r1819: Merge r1815:1817 from branches/zip: Improve Valgrind instrumentation. UNIV_MEM_ASSERT_RW(): New macro, to check that the contents of a memory area is defined. UNIV_MEM_ASSERT_W(): New macro, to check that a memory area is writable. UNIV_MEM_ASSERT_AND_FREE(): New macro, to check that the memory is writable before declaring it free (unwritable). This replaces UNIV_MEM_FREE() in many places. mem_init_buf(): Check that the memory is writable, and declare it undefined. mem_erase_buf(): Check that the memory is writable, and declare it freed. storage/innobase/include/rem0rec.ic: Apply snapshot innodb-5.1-ss1989 Revision r1918: Improve Valgrind instrumentation. rec_offs_set_n_alloc(): Use UNIV_MEM_ASSERT_AND_ALLOC(). UNIV_MEM_ASSERT_AND_ALLOC(): New directive, similar to UNIV_MEM_ASSERT_AND_FREE(). storage/innobase/include/row0mysql.h: Apply snapshot innodb-5.1-ss1989 Revision r1783: Correct the function comments of row_create_table_for_mysql() and row_drop_table_for_mysql(). storage/innobase/include/sync0rw.h: Apply snapshot innodb-5.1-ss1989 Revision r1757: Enclose rw_lock_validate() in #ifdef UNIV_DEBUG. It is only called by debug assertions. storage/innobase/include/univ.i: Apply snapshot innodb-5.1-ss1989 Revision r1827: Merge r1826 from branches/zip: UNIV_MEM_ASSERT_AND_FREE(): Use UNIV_MEM_ASSERT_W() instead of UNIV_MEM_ASSERT_RW(). The memory area need not be initialized. This mistake was made in r1815. Revision r1918: Improve Valgrind instrumentation. rec_offs_set_n_alloc(): Use UNIV_MEM_ASSERT_AND_ALLOC(). UNIV_MEM_ASSERT_AND_ALLOC(): New directive, similar to UNIV_MEM_ASSERT_AND_FREE(). Revision r1830: Improve memory debugging. This is follow-up to r1819. mem_heap_validate(): Compile this function also if UNIV_MEM_DEBUG is defined. Previously, this function was only compiled with UNIV_DEBUG. mem_heap_free_heap_top(): Flag the memory allocated, not freed, for Valgrind. Otherwise, Valgrind would complain on the second call of mem_heap_empty(). UNIV_MEM_ASSERT_RW(), UNIV_MEM_ASSERT_W(): Display additional diagnostics for failed Valgrind checks. Revision r1819: Merge r1815:1817 from branches/zip: Improve Valgrind instrumentation. UNIV_MEM_ASSERT_RW(): New macro, to check that the contents of a memory area is defined. UNIV_MEM_ASSERT_W(): New macro, to check that a memory area is writable. UNIV_MEM_ASSERT_AND_FREE(): New macro, to check that the memory is writable before declaring it free (unwritable). This replaces UNIV_MEM_FREE() in many places. mem_init_buf(): Check that the memory is writable, and declare it undefined. mem_erase_buf(): Check that the memory is writable, and declare it freed. Revision r1948: UNIV_MEM_ASSERT_RW(), UNIV_MEM_ASSERT_W(): Display also __FILE__ and __LINE__ when these Valgrind checks fail. storage/innobase/include/ut0ut.h: Apply snapshot innodb-5.1-ss1989 Revision r1850: Implement this feature request: http://bugs.mysql.com/30706 * Add a function that returns the number of microseconds since epoch - ut_time_us(). * Add (innodb|innobase|srv)_replication_delay MySQL config parameter. * Add UT_WAIT_FOR() macro that waits for a specified condition to occur until a timeout elapses. * Using all of the above, handle the replication thread specially in srv_conc_enter_innodb(). Approved by: Heikki Revision r1862: Add ut_snprintf() function. On Windows this needs to be implemented using auxiliary functions because there is no snprintf-variant on Windows that behaves exactly as specified in the standard: * Always return the number of characters that would have been printed if the size were unlimited (not including the final `\0'). * Always '\0'-terminate the result * Do not touch the buffer if size=0, only return the number of characters that would have been printed. Can be used to estimate the size needed and to allocate it dynamically. See http://www.freebsd.org/cgi/query-pr.cgi?pr=87260 for the reason why 2 ap variables are used. Approved by: Heikki Revision r1866: Revert r1850 as MySQL did not approve the addition. log for r1850: Implement this feature request: http://bugs.mysql.com/30706 * Add a function that returns the number of microseconds since epoch - ut_time_us(). * Add (innodb|innobase|srv)_replication_delay MySQL config parameter. * Add UT_WAIT_FOR() macro that waits for a specified condition to occur until a timeout elapses. * Using all of the above, handle the replication thread specially in srv_conc_enter_innodb(). storage/innobase/mem/mem0dbg.c: Apply snapshot innodb-5.1-ss1989 Revision r1830: Improve memory debugging. This is follow-up to r1819. mem_heap_validate(): Compile this function also if UNIV_MEM_DEBUG is defined. Previously, this function was only compiled with UNIV_DEBUG. mem_heap_free_heap_top(): Flag the memory allocated, not freed, for Valgrind. Otherwise, Valgrind would complain on the second call of mem_heap_empty(). UNIV_MEM_ASSERT_RW(), UNIV_MEM_ASSERT_W(): Display additional diagnostics for failed Valgrind checks. Revision r1819: Merge r1815:1817 from branches/zip: Improve Valgrind instrumentation. UNIV_MEM_ASSERT_RW(): New macro, to check that the contents of a memory area is defined. UNIV_MEM_ASSERT_W(): New macro, to check that a memory area is writable. UNIV_MEM_ASSERT_AND_FREE(): New macro, to check that the memory is writable before declaring it free (unwritable). This replaces UNIV_MEM_FREE() in many places. mem_init_buf(): Check that the memory is writable, and declare it undefined. mem_erase_buf(): Check that the memory is writable, and declare it freed. storage/innobase/mem/mem0mem.c: Apply snapshot innodb-5.1-ss1989 Revision r1819: Merge r1815:1817 from branches/zip: Improve Valgrind instrumentation. UNIV_MEM_ASSERT_RW(): New macro, to check that the contents of a memory area is defined. UNIV_MEM_ASSERT_W(): New macro, to check that a memory area is writable. UNIV_MEM_ASSERT_AND_FREE(): New macro, to check that the memory is writable before declaring it free (unwritable). This replaces UNIV_MEM_FREE() in many places. mem_init_buf(): Check that the memory is writable, and declare it undefined. mem_erase_buf(): Check that the memory is writable, and declare it freed. storage/innobase/row/row0mysql.c: Apply snapshot innodb-5.1-ss1989 Revision r1786: row_create_table_for_mysql(), row_truncate_table_for_mysql(), row_drop_table_for_mysql(): Do not mention innodb_force_recovery when newraw is set. Revision r1790: row_drop_table_for_mysql(): Before calling dict_table_remove_from_cache(table) and thus freeing the memory allocated for the table, copy the table name. This avoids reading freed memory when name == table->name. Approved by Sunny. Revision r1783: Correct the function comments of row_create_table_for_mysql() and row_drop_table_for_mysql(). Revision r1894: Add debug lock checks to autoinc functions. Add lock guards around an invocation of dict_table_autoinc_initialize(). storage/innobase/row/row0sel.c: Apply snapshot innodb-5.1-ss1989 Revision r1782: Add comment that the variable dest should be word aligned. After discussion on IM with Heikki. Revision r1988: Set an error code when a deadlock occurs in semi-consistent read. (Bug #31494) innodb-semi-consistent: New tests for InnoDB semi-consistent reads. Unfortunately, these will not trigger Bug #31494, because there merely occur lock wait timeouts, not deadlocks. Revision r1820: Use the clustered index and not the one selected by the optimizer in the plan, when building a previous version of the row. This bug is triggered when running queries via InnoDB's internal SQL parser; when InnoDB's optimizer selects a secondary index for the plan. Revision r1828: Fix two bugs: Bug# 30907: We don't rely on *first_value to be 0 when checking whether get_auto_increment() has been invoked for the first time in a multi-row INSERT. We instead use trx_t::n_autoinc_rows. Initialize trx::n_autoinc_rows inside ha_innobase::start_stmt() too. Bug# 30888: While adding code for the low level read of the AUTOINC value from the index, the case for MEDIUM ints which are 3 bytes was missed triggering an assertion. Revision r1779: Fix a bug that handles the case where the host specific byte order matches the InnoDB storage byte order, which is big-endian. storage/innobase/sync/sync0rw.c: Apply snapshot innodb-5.1-ss1989 Revision r1757: Enclose rw_lock_validate() in #ifdef UNIV_DEBUG. It is only called by debug assertions. storage/innobase/ut/ut0ut.c: Apply snapshot innodb-5.1-ss1989 Revision r1850: Implement this feature request: http://bugs.mysql.com/30706 * Add a function that returns the number of microseconds since epoch - ut_time_us(). * Add (innodb|innobase|srv)_replication_delay MySQL config parameter. * Add UT_WAIT_FOR() macro that waits for a specified condition to occur until a timeout elapses. * Using all of the above, handle the replication thread specially in srv_conc_enter_innodb(). Approved by: Heikki Revision r1873: snprintf() should always return non-negative result. According to Microsoft documentation about _vscprintf(): If format is a null pointer, the invalid parameter handler is invoked, as described in Parameter Validation. If execution is allowed to continue, the functions return -1 and set errno to EINVAL. The UNIX variant of snprintf() segfaults if format is a NULL pointer (similar to strlen(NULL) for example), so it is better to conform to this behavior and crash our custom Windows version instead of returning -1. Noone would expect -1 to be returned from snprintf(). Cosmetic: Add a space after typecast. Approved by: Marko Revision r1862: Add ut_snprintf() function. On Windows this needs to be implemented using auxiliary functions because there is no snprintf-variant on Windows that behaves exactly as specified in the standard: * Always return the number of characters that would have been printed if the size were unlimited (not including the final `\0'). * Always '\0'-terminate the result * Do not touch the buffer if size=0, only return the number of characters that would have been printed. Can be used to estimate the size needed and to allocate it dynamically. See http://www.freebsd.org/cgi/query-pr.cgi?pr=87260 for the reason why 2 ap variables are used. Approved by: Heikki Revision r1866: Revert r1850 as MySQL did not approve the addition. log for r1850: Implement this feature request: http://bugs.mysql.com/30706 * Add a function that returns the number of microseconds since epoch - ut_time_us(). * Add (innodb|innobase|srv)_replication_delay MySQL config parameter. * Add UT_WAIT_FOR() macro that waits for a specified condition to occur until a timeout elapses. * Using all of the above, handle the replication thread specially in srv_conc_enter_innodb(). Revision r1787: Move the prototype of innobase_print_identifier() from ut0ut.c to ha_prototypes.h. Enclose the definitions in ha_prototypes.h in #ifndef UNIV_HOTBACKUP. Revision r1789: ut_print_namel(): Do not assume that all '/' are separators between database and table names. Approved by Heikki. Revision r1936: ut_print_buf(): Add a Valgrind check that the buffer is wholly defined. mysql-test/r/innodb-semi-consistent.result: Apply snapshot innodb-5.1-ss1989 Revision r1988: Set an error code when a deadlock occurs in semi-consistent read. (Bug #31494) innodb-semi-consistent: New tests for InnoDB semi-consistent reads. Unfortunately, these will not trigger Bug #31494, because there merely occur lock wait timeouts, not deadlocks. mysql-test/r/innodb_autoinc_lock_mode_zero.result: New test, using read-only setting --innodb-autoinc-lock-mode=0 mysql-test/t/innodb-semi-consistent-master.opt: Apply snapshot innodb-5.1-ss1989 Revision r1988: Set an error code when a deadlock occurs in semi-consistent read. (Bug #31494) innodb-semi-consistent: New tests for InnoDB semi-consistent reads. Unfortunately, these will not trigger Bug #31494, because there merely occur lock wait timeouts, not deadlocks. mysql-test/t/innodb-semi-consistent.test: Apply snapshot innodb-5.1-ss1989 Revision r1988: Set an error code when a deadlock occurs in semi-consistent read. (Bug #31494) innodb-semi-consistent: New tests for InnoDB semi-consistent reads. Unfortunately, these will not trigger Bug #31494, because there merely occur lock wait timeouts, not deadlocks. mysql-test/t/innodb_autoinc_lock_mode_zero-master.opt: New test, using read-only setting --innodb-autoinc-lock-mode=0 mysql-test/t/innodb_autoinc_lock_mode_zero.test: New test, using read-only setting --innodb-autoinc-lock-mode=0
984 lines
22 KiB
C
984 lines
22 KiB
C
/************************************************************************
|
|
The memory management: the debug code. This is not a compilation module,
|
|
but is included in mem0mem.* !
|
|
|
|
(c) 1994, 1995 Innobase Oy
|
|
|
|
Created 6/9/1994 Heikki Tuuri
|
|
*************************************************************************/
|
|
|
|
#ifdef UNIV_MEM_DEBUG
|
|
mutex_t mem_hash_mutex; /* The mutex which protects in the
|
|
debug version the hash table containing
|
|
the list of live memory heaps, and
|
|
also the global variables below. */
|
|
|
|
/* The following variables contain information about the
|
|
extent of memory allocations. Only used in the debug version.
|
|
Protected by mem_hash_mutex above. */
|
|
|
|
static ulint mem_n_created_heaps = 0;
|
|
static ulint mem_n_allocations = 0;
|
|
static ulint mem_total_allocated_memory = 0;
|
|
ulint mem_current_allocated_memory = 0;
|
|
static ulint mem_max_allocated_memory = 0;
|
|
static ulint mem_last_print_info = 0;
|
|
|
|
/* Size of the hash table for memory management tracking */
|
|
#define MEM_HASH_SIZE 997
|
|
|
|
/* The node of the list containing currently allocated memory heaps */
|
|
|
|
typedef struct mem_hash_node_struct mem_hash_node_t;
|
|
struct mem_hash_node_struct {
|
|
UT_LIST_NODE_T(mem_hash_node_t)
|
|
list; /* hash list node */
|
|
mem_heap_t* heap; /* memory heap */
|
|
const char* file_name;/* file where heap was created*/
|
|
ulint line; /* file line of creation */
|
|
ulint nth_heap;/* this is the nth heap created */
|
|
UT_LIST_NODE_T(mem_hash_node_t)
|
|
all_list;/* list of all created heaps */
|
|
};
|
|
|
|
typedef UT_LIST_BASE_NODE_T(mem_hash_node_t) mem_hash_cell_t;
|
|
|
|
/* The hash table of allocated heaps */
|
|
static mem_hash_cell_t mem_hash_table[MEM_HASH_SIZE];
|
|
|
|
/* The base node of the list of all allocated heaps */
|
|
static mem_hash_cell_t mem_all_list_base;
|
|
|
|
static ibool mem_hash_initialized = FALSE;
|
|
|
|
|
|
UNIV_INLINE
|
|
mem_hash_cell_t*
|
|
mem_hash_get_nth_cell(ulint i);
|
|
|
|
/* Accessor function for the hash table. Returns a pointer to the
|
|
table cell. */
|
|
UNIV_INLINE
|
|
mem_hash_cell_t*
|
|
mem_hash_get_nth_cell(ulint i)
|
|
{
|
|
ut_a(i < MEM_HASH_SIZE);
|
|
|
|
return(&(mem_hash_table[i]));
|
|
}
|
|
|
|
/* Accessor functions for a memory field in the debug version */
|
|
|
|
void
|
|
mem_field_header_set_len(byte* field, ulint len)
|
|
{
|
|
mach_write_to_4(field - 2 * sizeof(ulint), len);
|
|
}
|
|
|
|
ulint
|
|
mem_field_header_get_len(byte* field)
|
|
{
|
|
return(mach_read_from_4(field - 2 * sizeof(ulint)));
|
|
}
|
|
|
|
void
|
|
mem_field_header_set_check(byte* field, ulint check)
|
|
{
|
|
mach_write_to_4(field - sizeof(ulint), check);
|
|
}
|
|
|
|
ulint
|
|
mem_field_header_get_check(byte* field)
|
|
{
|
|
return(mach_read_from_4(field - sizeof(ulint)));
|
|
}
|
|
|
|
void
|
|
mem_field_trailer_set_check(byte* field, ulint check)
|
|
{
|
|
mach_write_to_4(field + mem_field_header_get_len(field), check);
|
|
}
|
|
|
|
ulint
|
|
mem_field_trailer_get_check(byte* field)
|
|
{
|
|
return(mach_read_from_4(field
|
|
+ mem_field_header_get_len(field)));
|
|
}
|
|
#endif /* UNIV_MEM_DEBUG */
|
|
|
|
/**********************************************************************
|
|
Initializes the memory system. */
|
|
|
|
void
|
|
mem_init(
|
|
/*=====*/
|
|
ulint size) /* in: common pool size in bytes */
|
|
{
|
|
#ifdef UNIV_MEM_DEBUG
|
|
|
|
ulint i;
|
|
|
|
/* Initialize the hash table */
|
|
ut_a(FALSE == mem_hash_initialized);
|
|
|
|
mutex_create(&mem_hash_mutex, SYNC_MEM_HASH);
|
|
|
|
for (i = 0; i < MEM_HASH_SIZE; i++) {
|
|
UT_LIST_INIT(*mem_hash_get_nth_cell(i));
|
|
}
|
|
|
|
UT_LIST_INIT(mem_all_list_base);
|
|
|
|
mem_hash_initialized = TRUE;
|
|
#endif
|
|
|
|
mem_comm_pool = mem_pool_create(size);
|
|
}
|
|
|
|
#ifdef UNIV_MEM_DEBUG
|
|
/**********************************************************************
|
|
Initializes an allocated memory field in the debug version. */
|
|
|
|
void
|
|
mem_field_init(
|
|
/*===========*/
|
|
byte* buf, /* in: memory field */
|
|
ulint n) /* in: how many bytes the user requested */
|
|
{
|
|
ulint rnd;
|
|
byte* usr_buf;
|
|
|
|
usr_buf = buf + MEM_FIELD_HEADER_SIZE;
|
|
|
|
/* In the debug version write the length field and the
|
|
check fields to the start and the end of the allocated storage.
|
|
The field header consists of a length field and
|
|
a random number field, in this order. The field trailer contains
|
|
the same random number as a check field. */
|
|
|
|
mem_field_header_set_len(usr_buf, n);
|
|
|
|
rnd = ut_rnd_gen_ulint();
|
|
|
|
mem_field_header_set_check(usr_buf, rnd);
|
|
mem_field_trailer_set_check(usr_buf, rnd);
|
|
|
|
/* Update the memory allocation information */
|
|
|
|
mutex_enter(&mem_hash_mutex);
|
|
|
|
mem_total_allocated_memory += n;
|
|
mem_current_allocated_memory += n;
|
|
mem_n_allocations++;
|
|
|
|
if (mem_current_allocated_memory > mem_max_allocated_memory) {
|
|
mem_max_allocated_memory = mem_current_allocated_memory;
|
|
}
|
|
|
|
mutex_exit(&mem_hash_mutex);
|
|
|
|
/* In the debug version set the buffer to a random
|
|
combination of 0xBA and 0xBE */
|
|
|
|
mem_init_buf(usr_buf, n);
|
|
}
|
|
|
|
/**********************************************************************
|
|
Erases an allocated memory field in the debug version. */
|
|
|
|
void
|
|
mem_field_erase(
|
|
/*============*/
|
|
byte* buf, /* in: memory field */
|
|
ulint n __attribute__((unused)))
|
|
/* in: how many bytes the user requested */
|
|
{
|
|
byte* usr_buf;
|
|
|
|
usr_buf = buf + MEM_FIELD_HEADER_SIZE;
|
|
|
|
mutex_enter(&mem_hash_mutex);
|
|
mem_current_allocated_memory -= n;
|
|
mutex_exit(&mem_hash_mutex);
|
|
|
|
/* Check that the field lengths agree */
|
|
ut_ad(n == (ulint)mem_field_header_get_len(usr_buf));
|
|
|
|
/* In the debug version, set the freed space to a random
|
|
combination of 0xDE and 0xAD */
|
|
|
|
mem_erase_buf(buf, MEM_SPACE_NEEDED(n));
|
|
}
|
|
|
|
/*******************************************************************
|
|
Initializes a buffer to a random combination of hex BA and BE.
|
|
Used to initialize allocated memory. */
|
|
|
|
void
|
|
mem_init_buf(
|
|
/*=========*/
|
|
byte* buf, /* in: pointer to buffer */
|
|
ulint n) /* in: length of buffer */
|
|
{
|
|
byte* ptr;
|
|
|
|
UNIV_MEM_ASSERT_W(buf, n);
|
|
|
|
for (ptr = buf; ptr < buf + n; ptr++) {
|
|
|
|
if (ut_rnd_gen_ibool()) {
|
|
*ptr = 0xBA;
|
|
} else {
|
|
*ptr = 0xBE;
|
|
}
|
|
}
|
|
|
|
UNIV_MEM_INVALID(buf, n);
|
|
}
|
|
|
|
/*******************************************************************
|
|
Initializes a buffer to a random combination of hex DE and AD.
|
|
Used to erase freed memory.*/
|
|
|
|
void
|
|
mem_erase_buf(
|
|
/*==========*/
|
|
byte* buf, /* in: pointer to buffer */
|
|
ulint n) /* in: length of buffer */
|
|
{
|
|
byte* ptr;
|
|
|
|
UNIV_MEM_ASSERT_W(buf, n);
|
|
|
|
for (ptr = buf; ptr < buf + n; ptr++) {
|
|
if (ut_rnd_gen_ibool()) {
|
|
*ptr = 0xDE;
|
|
} else {
|
|
*ptr = 0xAD;
|
|
}
|
|
}
|
|
|
|
UNIV_MEM_FREE(buf, n);
|
|
}
|
|
|
|
/*******************************************************************
|
|
Inserts a created memory heap to the hash table of current allocated
|
|
memory heaps. */
|
|
|
|
void
|
|
mem_hash_insert(
|
|
/*============*/
|
|
mem_heap_t* heap, /* in: the created heap */
|
|
const char* file_name, /* in: file name of creation */
|
|
ulint line) /* in: line where created */
|
|
{
|
|
mem_hash_node_t* new_node;
|
|
ulint cell_no ;
|
|
|
|
ut_ad(mem_heap_check(heap));
|
|
|
|
mutex_enter(&mem_hash_mutex);
|
|
|
|
cell_no = ut_hash_ulint((ulint)heap, MEM_HASH_SIZE);
|
|
|
|
/* Allocate a new node to the list */
|
|
new_node = ut_malloc(sizeof(mem_hash_node_t));
|
|
|
|
new_node->heap = heap;
|
|
new_node->file_name = file_name;
|
|
new_node->line = line;
|
|
new_node->nth_heap = mem_n_created_heaps;
|
|
|
|
/* Insert into lists */
|
|
UT_LIST_ADD_FIRST(list, *mem_hash_get_nth_cell(cell_no), new_node);
|
|
|
|
UT_LIST_ADD_LAST(all_list, mem_all_list_base, new_node);
|
|
|
|
mem_n_created_heaps++;
|
|
|
|
mutex_exit(&mem_hash_mutex);
|
|
}
|
|
|
|
/*******************************************************************
|
|
Removes a memory heap (which is going to be freed by the caller)
|
|
from the list of live memory heaps. Returns the size of the heap
|
|
in terms of how much memory in bytes was allocated for the user of
|
|
the heap (not the total space occupied by the heap).
|
|
Also validates the heap.
|
|
NOTE: This function does not free the storage occupied by the
|
|
heap itself, only the node in the list of heaps. */
|
|
|
|
void
|
|
mem_hash_remove(
|
|
/*============*/
|
|
mem_heap_t* heap, /* in: the heap to be freed */
|
|
const char* file_name, /* in: file name of freeing */
|
|
ulint line) /* in: line where freed */
|
|
{
|
|
mem_hash_node_t* node;
|
|
ulint cell_no;
|
|
ibool error;
|
|
ulint size;
|
|
|
|
ut_ad(mem_heap_check(heap));
|
|
|
|
mutex_enter(&mem_hash_mutex);
|
|
|
|
cell_no = ut_hash_ulint((ulint)heap, MEM_HASH_SIZE);
|
|
|
|
/* Look for the heap in the hash table list */
|
|
node = UT_LIST_GET_FIRST(*mem_hash_get_nth_cell(cell_no));
|
|
|
|
while (node != NULL) {
|
|
if (node->heap == heap) {
|
|
|
|
break;
|
|
}
|
|
|
|
node = UT_LIST_GET_NEXT(list, node);
|
|
}
|
|
|
|
if (node == NULL) {
|
|
fprintf(stderr,
|
|
"Memory heap or buffer freed in %s line %lu"
|
|
" did not exist.\n",
|
|
file_name, (ulong) line);
|
|
ut_error;
|
|
}
|
|
|
|
/* Remove from lists */
|
|
UT_LIST_REMOVE(list, *mem_hash_get_nth_cell(cell_no), node);
|
|
|
|
UT_LIST_REMOVE(all_list, mem_all_list_base, node);
|
|
|
|
/* Validate the heap which will be freed */
|
|
mem_heap_validate_or_print(node->heap, NULL, FALSE, &error, &size,
|
|
NULL, NULL);
|
|
if (error) {
|
|
fprintf(stderr,
|
|
"Inconsistency in memory heap or"
|
|
" buffer n:o %lu created\n"
|
|
"in %s line %lu and tried to free in %s line %lu.\n"
|
|
"Hex dump of 400 bytes around memory heap"
|
|
" first block start:\n",
|
|
node->nth_heap, node->file_name, (ulong) node->line,
|
|
file_name, (ulong) line);
|
|
ut_print_buf(stderr, (byte*)node->heap - 200, 400);
|
|
fputs("\nDump of the mem heap:\n", stderr);
|
|
mem_heap_validate_or_print(node->heap, NULL, TRUE, &error,
|
|
&size, NULL, NULL);
|
|
ut_error;
|
|
}
|
|
|
|
/* Free the memory occupied by the node struct */
|
|
ut_free(node);
|
|
|
|
mem_current_allocated_memory -= size;
|
|
|
|
mutex_exit(&mem_hash_mutex);
|
|
}
|
|
#endif /* UNIV_MEM_DEBUG */
|
|
|
|
#if defined UNIV_MEM_DEBUG || defined UNIV_DEBUG
|
|
/*******************************************************************
|
|
Checks a memory heap for consistency and prints the contents if requested.
|
|
Outputs the sum of sizes of buffers given to the user (only in
|
|
the debug version), the physical size of the heap and the number of
|
|
blocks in the heap. In case of error returns 0 as sizes and number
|
|
of blocks. */
|
|
|
|
void
|
|
mem_heap_validate_or_print(
|
|
/*=======================*/
|
|
mem_heap_t* heap, /* in: memory heap */
|
|
byte* top __attribute__((unused)),
|
|
/* in: calculate and validate only until
|
|
this top pointer in the heap is reached,
|
|
if this pointer is NULL, ignored */
|
|
ibool print, /* in: if TRUE, prints the contents
|
|
of the heap; works only in
|
|
the debug version */
|
|
ibool* error, /* out: TRUE if error */
|
|
ulint* us_size,/* out: allocated memory
|
|
(for the user) in the heap,
|
|
if a NULL pointer is passed as this
|
|
argument, it is ignored; in the
|
|
non-debug version this is always -1 */
|
|
ulint* ph_size,/* out: physical size of the heap,
|
|
if a NULL pointer is passed as this
|
|
argument, it is ignored */
|
|
ulint* n_blocks) /* out: number of blocks in the heap,
|
|
if a NULL pointer is passed as this
|
|
argument, it is ignored */
|
|
{
|
|
mem_block_t* block;
|
|
ulint total_len = 0;
|
|
ulint block_count = 0;
|
|
ulint phys_len = 0;
|
|
#ifdef UNIV_MEM_DEBUG
|
|
ulint len;
|
|
byte* field;
|
|
byte* user_field;
|
|
ulint check_field;
|
|
#endif
|
|
|
|
/* Pessimistically, we set the parameters to error values */
|
|
if (us_size != NULL) {
|
|
*us_size = 0;
|
|
}
|
|
if (ph_size != NULL) {
|
|
*ph_size = 0;
|
|
}
|
|
if (n_blocks != NULL) {
|
|
*n_blocks = 0;
|
|
}
|
|
*error = TRUE;
|
|
|
|
block = heap;
|
|
|
|
if (block->magic_n != MEM_BLOCK_MAGIC_N) {
|
|
return;
|
|
}
|
|
|
|
if (print) {
|
|
fputs("Memory heap:", stderr);
|
|
}
|
|
|
|
while (block != NULL) {
|
|
phys_len += mem_block_get_len(block);
|
|
|
|
if ((block->type == MEM_HEAP_BUFFER)
|
|
&& (mem_block_get_len(block) > UNIV_PAGE_SIZE)) {
|
|
|
|
fprintf(stderr,
|
|
"InnoDB: Error: mem block %p"
|
|
" length %lu > UNIV_PAGE_SIZE\n",
|
|
(void*) block,
|
|
(ulong) mem_block_get_len(block));
|
|
/* error */
|
|
|
|
return;
|
|
}
|
|
|
|
#ifdef UNIV_MEM_DEBUG
|
|
/* We can trace the fields of the block only in the debug
|
|
version */
|
|
if (print) {
|
|
fprintf(stderr, " Block %ld:", block_count);
|
|
}
|
|
|
|
field = (byte*)block + mem_block_get_start(block);
|
|
|
|
if (top && (field == top)) {
|
|
|
|
goto completed;
|
|
}
|
|
|
|
while (field < (byte*)block + mem_block_get_free(block)) {
|
|
|
|
/* Calculate the pointer to the storage
|
|
which was given to the user */
|
|
|
|
user_field = field + MEM_FIELD_HEADER_SIZE;
|
|
|
|
len = mem_field_header_get_len(user_field);
|
|
|
|
if (print) {
|
|
ut_print_buf(stderr, user_field, len);
|
|
}
|
|
|
|
total_len += len;
|
|
check_field = mem_field_header_get_check(user_field);
|
|
|
|
if (check_field
|
|
!= mem_field_trailer_get_check(user_field)) {
|
|
/* error */
|
|
|
|
fprintf(stderr,
|
|
"InnoDB: Error: block %lx mem"
|
|
" field %lx len %lu\n"
|
|
"InnoDB: header check field is"
|
|
" %lx but trailer %lx\n",
|
|
(ulint)block,
|
|
(ulint)field, len, check_field,
|
|
mem_field_trailer_get_check(
|
|
user_field));
|
|
|
|
return;
|
|
}
|
|
|
|
/* Move to next field */
|
|
field = field + MEM_SPACE_NEEDED(len);
|
|
|
|
if (top && (field == top)) {
|
|
|
|
goto completed;
|
|
}
|
|
|
|
}
|
|
|
|
/* At the end check that we have arrived to the first free
|
|
position */
|
|
|
|
if (field != (byte*)block + mem_block_get_free(block)) {
|
|
/* error */
|
|
|
|
fprintf(stderr,
|
|
"InnoDB: Error: block %lx end of"
|
|
" mem fields %lx\n"
|
|
"InnoDB: but block free at %lx\n",
|
|
(ulint)block, (ulint)field,
|
|
(ulint)((byte*)block
|
|
+ mem_block_get_free(block)));
|
|
|
|
return;
|
|
}
|
|
|
|
#endif
|
|
|
|
block = UT_LIST_GET_NEXT(list, block);
|
|
block_count++;
|
|
}
|
|
#ifdef UNIV_MEM_DEBUG
|
|
completed:
|
|
#endif
|
|
if (us_size != NULL) {
|
|
*us_size = total_len;
|
|
}
|
|
if (ph_size != NULL) {
|
|
*ph_size = phys_len;
|
|
}
|
|
if (n_blocks != NULL) {
|
|
*n_blocks = block_count;
|
|
}
|
|
*error = FALSE;
|
|
}
|
|
|
|
/******************************************************************
|
|
Prints the contents of a memory heap. */
|
|
static
|
|
void
|
|
mem_heap_print(
|
|
/*===========*/
|
|
mem_heap_t* heap) /* in: memory heap */
|
|
{
|
|
ibool error;
|
|
ulint us_size;
|
|
ulint phys_size;
|
|
ulint n_blocks;
|
|
|
|
ut_ad(mem_heap_check(heap));
|
|
|
|
mem_heap_validate_or_print(heap, NULL, TRUE, &error,
|
|
&us_size, &phys_size, &n_blocks);
|
|
fprintf(stderr,
|
|
"\nheap type: %lu; size: user size %lu;"
|
|
" physical size %lu; blocks %lu.\n",
|
|
(ulong) heap->type, (ulong) us_size,
|
|
(ulong) phys_size, (ulong) n_blocks);
|
|
ut_a(!error);
|
|
}
|
|
|
|
/******************************************************************
|
|
Validates the contents of a memory heap. */
|
|
|
|
ibool
|
|
mem_heap_validate(
|
|
/*==============*/
|
|
/* out: TRUE if ok */
|
|
mem_heap_t* heap) /* in: memory heap */
|
|
{
|
|
ibool error;
|
|
ulint us_size;
|
|
ulint phys_size;
|
|
ulint n_blocks;
|
|
|
|
ut_ad(mem_heap_check(heap));
|
|
|
|
mem_heap_validate_or_print(heap, NULL, FALSE, &error, &us_size,
|
|
&phys_size, &n_blocks);
|
|
if (error) {
|
|
mem_heap_print(heap);
|
|
}
|
|
|
|
ut_a(!error);
|
|
|
|
return(TRUE);
|
|
}
|
|
#endif /* UNIV_MEM_DEBUG || UNIV_DEBUG */
|
|
|
|
#ifdef UNIV_DEBUG
|
|
/******************************************************************
|
|
Checks that an object is a memory heap (or a block of it). */
|
|
|
|
ibool
|
|
mem_heap_check(
|
|
/*===========*/
|
|
/* out: TRUE if ok */
|
|
mem_heap_t* heap) /* in: memory heap */
|
|
{
|
|
ut_a(heap->magic_n == MEM_BLOCK_MAGIC_N);
|
|
|
|
return(TRUE);
|
|
}
|
|
#endif /* UNIV_DEBUG */
|
|
|
|
#ifdef UNIV_MEM_DEBUG
|
|
/*********************************************************************
|
|
TRUE if no memory is currently allocated. */
|
|
|
|
ibool
|
|
mem_all_freed(void)
|
|
/*===============*/
|
|
/* out: TRUE if no heaps exist */
|
|
{
|
|
mem_hash_node_t* node;
|
|
ulint heap_count = 0;
|
|
ulint i;
|
|
|
|
mem_validate();
|
|
|
|
mutex_enter(&mem_hash_mutex);
|
|
|
|
for (i = 0; i < MEM_HASH_SIZE; i++) {
|
|
|
|
node = UT_LIST_GET_FIRST(*mem_hash_get_nth_cell(i));
|
|
while (node != NULL) {
|
|
heap_count++;
|
|
node = UT_LIST_GET_NEXT(list, node);
|
|
}
|
|
}
|
|
|
|
mutex_exit(&mem_hash_mutex);
|
|
|
|
if (heap_count == 0) {
|
|
|
|
ut_a(mem_pool_get_reserved(mem_comm_pool) == 0);
|
|
|
|
return(TRUE);
|
|
} else {
|
|
return(FALSE);
|
|
}
|
|
}
|
|
|
|
/*********************************************************************
|
|
Validates the dynamic memory allocation system. */
|
|
|
|
ibool
|
|
mem_validate_no_assert(void)
|
|
/*========================*/
|
|
/* out: TRUE if error */
|
|
{
|
|
mem_hash_node_t* node;
|
|
ulint n_heaps = 0;
|
|
ulint allocated_mem;
|
|
ulint ph_size;
|
|
ulint total_allocated_mem = 0;
|
|
ibool error = FALSE;
|
|
ulint n_blocks;
|
|
ulint i;
|
|
|
|
mem_pool_validate(mem_comm_pool);
|
|
|
|
mutex_enter(&mem_hash_mutex);
|
|
|
|
for (i = 0; i < MEM_HASH_SIZE; i++) {
|
|
|
|
node = UT_LIST_GET_FIRST(*mem_hash_get_nth_cell(i));
|
|
|
|
while (node != NULL) {
|
|
n_heaps++;
|
|
|
|
mem_heap_validate_or_print(node->heap, NULL,
|
|
FALSE, &error,
|
|
&allocated_mem,
|
|
&ph_size, &n_blocks);
|
|
|
|
if (error) {
|
|
fprintf(stderr,
|
|
"\nERROR!!!!!!!!!!!!!!!!!!!"
|
|
"!!!!!!!!!!!!!!!!!!!!!!!\n\n"
|
|
"Inconsistency in memory heap"
|
|
" or buffer created\n"
|
|
"in %s line %lu.\n",
|
|
node->file_name, node->line);
|
|
|
|
mutex_exit(&mem_hash_mutex);
|
|
|
|
return(TRUE);
|
|
}
|
|
|
|
total_allocated_mem += allocated_mem;
|
|
node = UT_LIST_GET_NEXT(list, node);
|
|
}
|
|
}
|
|
|
|
if ((n_heaps == 0) && (mem_current_allocated_memory != 0)) {
|
|
error = TRUE;
|
|
}
|
|
|
|
if (mem_total_allocated_memory < mem_current_allocated_memory) {
|
|
error = TRUE;
|
|
}
|
|
|
|
if (mem_max_allocated_memory > mem_total_allocated_memory) {
|
|
error = TRUE;
|
|
}
|
|
|
|
if (mem_n_created_heaps < n_heaps) {
|
|
error = TRUE;
|
|
}
|
|
|
|
mutex_exit(&mem_hash_mutex);
|
|
|
|
return(error);
|
|
}
|
|
|
|
/****************************************************************
|
|
Validates the dynamic memory */
|
|
|
|
ibool
|
|
mem_validate(void)
|
|
/*==============*/
|
|
/* out: TRUE if ok */
|
|
{
|
|
ut_a(!mem_validate_no_assert());
|
|
|
|
return(TRUE);
|
|
}
|
|
#endif /* UNIV_MEM_DEBUG */
|
|
|
|
/****************************************************************
|
|
Tries to find neigboring memory allocation blocks and dumps to stderr
|
|
the neighborhood of a given pointer. */
|
|
|
|
void
|
|
mem_analyze_corruption(
|
|
/*===================*/
|
|
void* ptr) /* in: pointer to place of possible corruption */
|
|
{
|
|
byte* p;
|
|
ulint i;
|
|
ulint dist;
|
|
|
|
fputs("InnoDB: Apparent memory corruption: mem dump ", stderr);
|
|
ut_print_buf(stderr, (byte*)ptr - 250, 500);
|
|
|
|
fputs("\nInnoDB: Scanning backward trying to find"
|
|
" previous allocated mem blocks\n", stderr);
|
|
|
|
p = (byte*)ptr;
|
|
dist = 0;
|
|
|
|
for (i = 0; i < 10; i++) {
|
|
for (;;) {
|
|
if (((ulint)p) % 4 == 0) {
|
|
|
|
if (*((ulint*)p) == MEM_BLOCK_MAGIC_N) {
|
|
fprintf(stderr,
|
|
"Mem block at - %lu,"
|
|
" file %s, line %lu\n",
|
|
(ulong) dist,
|
|
(p + sizeof(ulint)),
|
|
(ulong)
|
|
(*(ulint*)(p + 8
|
|
+ sizeof(ulint))));
|
|
|
|
break;
|
|
}
|
|
|
|
if (*((ulint*)p) == MEM_FREED_BLOCK_MAGIC_N) {
|
|
fprintf(stderr,
|
|
"Freed mem block at - %lu,"
|
|
" file %s, line %lu\n",
|
|
(ulong) dist,
|
|
(p + sizeof(ulint)),
|
|
(ulong)
|
|
(*(ulint*)(p + 8
|
|
+ sizeof(ulint))));
|
|
|
|
break;
|
|
}
|
|
}
|
|
|
|
p--;
|
|
dist++;
|
|
}
|
|
|
|
p--;
|
|
dist++;
|
|
}
|
|
|
|
fprintf(stderr,
|
|
"InnoDB: Scanning forward trying to find next"
|
|
" allocated mem blocks\n");
|
|
|
|
p = (byte*)ptr;
|
|
dist = 0;
|
|
|
|
for (i = 0; i < 10; i++) {
|
|
for (;;) {
|
|
if (((ulint)p) % 4 == 0) {
|
|
|
|
if (*((ulint*)p) == MEM_BLOCK_MAGIC_N) {
|
|
fprintf(stderr,
|
|
"Mem block at + %lu, file %s,"
|
|
" line %lu\n",
|
|
(ulong) dist,
|
|
(p + sizeof(ulint)),
|
|
(ulong)
|
|
(*(ulint*)(p + 8
|
|
+ sizeof(ulint))));
|
|
|
|
break;
|
|
}
|
|
|
|
if (*((ulint*)p) == MEM_FREED_BLOCK_MAGIC_N) {
|
|
fprintf(stderr,
|
|
"Freed mem block at + %lu,"
|
|
" file %s, line %lu\n",
|
|
(ulong) dist,
|
|
(p + sizeof(ulint)),
|
|
(ulong)
|
|
(*(ulint*)(p + 8
|
|
+ sizeof(ulint))));
|
|
|
|
break;
|
|
}
|
|
}
|
|
|
|
p++;
|
|
dist++;
|
|
}
|
|
|
|
p++;
|
|
dist++;
|
|
}
|
|
}
|
|
|
|
/*********************************************************************
|
|
Prints information of dynamic memory usage and currently allocated
|
|
memory heaps or buffers. Can only be used in the debug version. */
|
|
static
|
|
void
|
|
mem_print_info_low(
|
|
/*===============*/
|
|
ibool print_all) /* in: if TRUE, all heaps are printed,
|
|
else only the heaps allocated after the
|
|
previous call of this function */
|
|
{
|
|
#ifdef UNIV_MEM_DEBUG
|
|
mem_hash_node_t* node;
|
|
ulint n_heaps = 0;
|
|
ulint allocated_mem;
|
|
ulint ph_size;
|
|
ulint total_allocated_mem = 0;
|
|
ibool error;
|
|
ulint n_blocks;
|
|
#endif
|
|
FILE* outfile;
|
|
|
|
/* outfile = fopen("ibdebug", "a"); */
|
|
|
|
outfile = stdout;
|
|
|
|
fprintf(outfile, "\n");
|
|
fprintf(outfile,
|
|
"________________________________________________________\n");
|
|
fprintf(outfile, "MEMORY ALLOCATION INFORMATION\n\n");
|
|
|
|
#ifndef UNIV_MEM_DEBUG
|
|
|
|
UT_NOT_USED(print_all);
|
|
|
|
mem_pool_print_info(outfile, mem_comm_pool);
|
|
|
|
fprintf(outfile,
|
|
"Sorry, non-debug version cannot give more memory info\n");
|
|
|
|
/* fclose(outfile); */
|
|
|
|
return;
|
|
#else
|
|
mutex_enter(&mem_hash_mutex);
|
|
|
|
fprintf(outfile, "LIST OF CREATED HEAPS AND ALLOCATED BUFFERS: \n\n");
|
|
|
|
if (!print_all) {
|
|
fprintf(outfile, "AFTER THE LAST PRINT INFO\n");
|
|
}
|
|
|
|
node = UT_LIST_GET_FIRST(mem_all_list_base);
|
|
|
|
while (node != NULL) {
|
|
n_heaps++;
|
|
|
|
if (!print_all && node->nth_heap < mem_last_print_info) {
|
|
|
|
goto next_heap;
|
|
}
|
|
|
|
mem_heap_validate_or_print(node->heap, NULL,
|
|
FALSE, &error, &allocated_mem,
|
|
&ph_size, &n_blocks);
|
|
total_allocated_mem += allocated_mem;
|
|
|
|
fprintf(outfile,
|
|
"%lu: file %s line %lu of size %lu phys.size %lu"
|
|
" with %lu blocks, type %lu\n",
|
|
node->nth_heap, node->file_name, node->line,
|
|
allocated_mem, ph_size, n_blocks,
|
|
(node->heap)->type);
|
|
next_heap:
|
|
node = UT_LIST_GET_NEXT(all_list, node);
|
|
}
|
|
|
|
fprintf(outfile, "\n");
|
|
|
|
fprintf(outfile, "Current allocated memory : %lu\n",
|
|
mem_current_allocated_memory);
|
|
fprintf(outfile, "Current allocated heaps and buffers : %lu\n",
|
|
n_heaps);
|
|
fprintf(outfile, "Cumulative allocated memory : %lu\n",
|
|
mem_total_allocated_memory);
|
|
fprintf(outfile, "Maximum allocated memory : %lu\n",
|
|
mem_max_allocated_memory);
|
|
fprintf(outfile, "Cumulative created heaps and buffers : %lu\n",
|
|
mem_n_created_heaps);
|
|
fprintf(outfile, "Cumulative number of allocations : %lu\n",
|
|
mem_n_allocations);
|
|
|
|
mem_last_print_info = mem_n_created_heaps;
|
|
|
|
mutex_exit(&mem_hash_mutex);
|
|
|
|
mem_pool_print_info(outfile, mem_comm_pool);
|
|
|
|
/* mem_validate(); */
|
|
|
|
/* fclose(outfile); */
|
|
#endif
|
|
}
|
|
|
|
/*********************************************************************
|
|
Prints information of dynamic memory usage and currently allocated memory
|
|
heaps or buffers. Can only be used in the debug version. */
|
|
|
|
void
|
|
mem_print_info(void)
|
|
/*================*/
|
|
{
|
|
mem_print_info_low(TRUE);
|
|
}
|
|
|
|
/*********************************************************************
|
|
Prints information of dynamic memory usage and currently allocated memory
|
|
heaps or buffers since the last ..._print_info or..._print_new_info. */
|
|
|
|
void
|
|
mem_print_new_info(void)
|
|
/*====================*/
|
|
{
|
|
mem_print_info_low(FALSE);
|
|
}
|