mirror of
https://github.com/MariaDB/server.git
synced 2025-01-18 21:12:26 +01:00
fb84f573ad
- Reserver namespace and place in frm for TABLE_CHECKSUM and PAGE_CHECKSUM create options - Added syncing of directory when creating .frm files - Portability fixes - Added missing cast that could cause bugs - Code cleanups - Made some bit functions inline - Moved things out of myisam.h to my_handler.h to make them more accessable - Renamed some myisam variables and defines to make them more globaly usable (as they are used outside of MyISAM) - Fixed bugs in error conditions - Use compiler time asserts instead of run time - Fixed indentation HA_EXTRA_PREPARE_FOR_DELETE -> HA_EXTRA_PREPARE_FOR_DROP as the old name was wrong (Added a define for old value to ensure we don't break any old code) Added HA_EXTRA_PREPARE_FOR_RENAME as a signal for rename (before we used a DROP signal which is wrong) - Initialize error messages early to get better errors when mysqld or an engine fails to start - Fix windows bug that query_performance_frequency was not initialized if registry code failed - thread_stack -> my_thread_stack_size BitKeeper/etc/ignore: added libmysqld/scheduler.cc libmysqld/sql_connect.cc libmysqld/sql_tablespace.cc include/Makefile.am: Added my_bit.h include/m_string.h: Added bzero_if_purify() to simplify code include/my_base.h: Reserve options for the future Added HA_OPTION_NULL_FIELDS, HA_OPTION_PAGE_CHECKSUM, HA_CREATE_PAGE_CHECKSUM Added new error message HA_ERR_NEW_FILE Added optional new row type BLOCK_RECORD Renamed HA_EXTRA_PREPARE_FOR_DELETE to HA_EXTRA_PREPARE_FOR_DROP Added HA_EXTRA_PREARE_FOR_RENAME to inform handler we will do a rename (Added define to make things compatible until 6.0) Moved invalidator_by_filename form myisam.h include/my_dbug.h: Poirtablity fix include/my_global.h: Added helper macros STATIC_INLINE and MY_ERRPTR Added NEED_EXPLICIT_SYNC_DIR include/my_handler.h: Added missing casts Moved some constants and macros out from myisam.h to make these generally available Renamed mi_compare_text() to ha_compare_text() as this function is not myisam specific Renamed mi_portable_sizeof_char_ptr to portable_sizeof_char_ptr Added registering of handler messages for better error reporting during startup include/my_sys.h: Added my_sync_dir() and my_sync_dir_by_file() More comments Some indentation fixes Moved bit functions to my_bit.h Added prototype for crc32() include/myisam.h: Moved things from here to my_handler.h to make them more accessable libmysql/Makefile.shared: Added my_sync mysys/array.c: Fixed indentation and spelling errors Split set_dynamic() to two functions Added allocate_dynamic() as a new visiable function (no new code, only refactoring) mysys/mf_iocache.c: More DBUG mysys/mf_keycache.c: More explicite ASSERT Removed some casts Fixed indentation mysys/mf_tempfile.c: Fixed bug with possible dangling file descriptor mysys/my_atomic.c: Use compile time asserts instead of run time mysys/my_bit.c: Make most bit functions inline mysys/my_bitmap.c: Added my_bit.h mysys/my_compress.c: Fixed indentation mysys/my_create.c: Added my_sync_by_dir() mysys/my_delete.c: Added my_sync_by_dir() mysys/my_error.c: init_glob_errs() is now done in my_init() mysys/my_handler.c: mi_compare_text() -> ha_compare_text() as this is not MyISAM specific Added functions to initialize handler error messages Fixed indentation More clear usage of include files mysys/my_init.c: Added my_thread_stack_size to be used by other programs Ensure that global error messages are always initialized Fix windows bug that query_performance_frequency was not initialized if registry code failed mysys/my_open.c: More comments Removed duplicate code mysys/my_pread.c: Ensure that my_errno is set even if errno is 0 mysys/my_realloc.c: Added comment mysys/my_rename.c: Added syncing of directories mysys/my_symlink.c: Added my_sync_by_dir() mysys/my_sync.c: Added my_sync_dir() On recent Mac OS X, fcntl(F_FULLFSYNC) is recommended over fsync() (see "man fsync" on Mac OS X 10.3). my_sync_dir(): to sync a directory after a file creation/deletion/ renaming; can be called directly or via MY_SYNC_DIR in my_create/ my_delete/my_rename(). No-op except on Linux (see "man fsync" on Linux). my_sync_dir_from_file(): same as above, just more practical when the caller has a file name but no directory name ready. Should the #warning even be a #error? I mean do we want to release binaries which don't guarantee any durability? mysys/safemalloc.c: Added sf_malloc_report_allocated() (Debugging aid) sql/gen_lex_hash.cc: Remove inline for big function sql/ha_partition.cc: HA_EXTRA_PREPARE_FOR_DELETE -> HA_EXTRA_PREPARE_FOR_DROP prepare_for_delete -> prepare_for_rename() as this is the the time this function is called sql/ha_partition.h: prepare_for_delete -> prepare_for_rename() as this is the the time this function is called sql/handler.cc: ha_init_errors() is now called at startup before plugins This allows us to get better error messages sql/handler.h: Reserve enum value for Maria Add future proof enum for page checksums sql/item_func.cc: Include my_bit.h sql/lex.h: Added future proof CREATE table options sql/log.cc: Added comment sql/mysql_priv.h: thread_stack moved to mysys sql/mysqld.cc: thread_stack moved to mysys thread_stack -> my_thread_stack_size Initialize myisam key caches before plugins starts Initialize error to allow storage engine to give better error messages if init failes. Fixed indentation Group all MyISAM options together Added new status variable 'Opened_table_definitions' to allow one to monitor if table definition cache is too small Clarified some option help messages sql/opt_range.cc: Removed wrong usage of SAFE_MODE (this disabled key usage for UPDATES, which was never the intention) Removed print if total cost in a place where it didn't have any usable value sql/set_var.cc: thread_stack -> my_thread_stack sql/sql_class.cc: Intialize transaction object properly sql/sql_parse.cc: thread_stack -> my_thread_stack sql/sql_select.cc: Include my_bit.h mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr sql/sql_show.cc: Simplify handling of ha_choice variables Added future safe PAGE_CHECKSUM option Addid missing 'transactional=#' in information schema sql/sql_table.cc: HA_EXTRA_PREPARE_FOR_DELETE -> HA_EXTRA_FORCE_REOPEN when doing reopen HA_EXTRA_PREPARE_FOR_DELETE -> HA_EXTRA_PREPARE_FOR_RENAME when doing rename Removed not needed initialization sql/sql_test.cc: thread_stack -> my_thread_stack sql/sql_yacc.yy: Simplify handling of ha_choice variables Added future proof create table options TABLE_CHECKSUM=# & PAGE_CHECKSUM=# sql/table.cc: Save page_checksum in .frm sql/table.h: Added variable to hold create table option PAGE_CHECKSUM sql/unireg.cc: Added syncing of directories storage/myisam/ft_boolean_search.c: mi_compare_text() -> ha_compare_text() storage/myisam/ft_eval.c: mi_compare_text() -> ha_compare_text() storage/myisam/ft_nlq_search.c: mi_compare_text() -> ha_compare_text() storage/myisam/ft_parser.c: mi_compare_text() -> ha_compare_text() storage/myisam/ft_stopwords.c: mi_compare_text() -> ha_compare_text() storage/myisam/ft_test1.c: mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisam/ft_update.c: mi_compare_text() -> ha_compare_text() storage/myisam/ha_myisam.cc: Include my_bit.h storage/myisam/mi_check.c: MI_MAX_POSSIBLE_KEY_BUFF -> HA_MAX_POSSIBLE_KEY_BUFF mi_compare_text() -> ha_compare_text() Added BLOCK_RECORD to avoid compiler warnings storage/myisam/mi_checksum.c: mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisam/mi_create.c: MI_MAX_POSSIBLE_KEY -> HA_MAX_POSSIBLE_KEY MI_MAX_KEY_BLOCK_SIZE -> HA_MAX_KEY_BLOCK_SIZE mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisam/mi_dynrec.c: mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisam/mi_extra.c: HA_EXTRA_PREPARE_FOR_DELETE -> HA_EXTRA_PREPARE_FOR_DROP storage/myisam/mi_open.c: MI_MAX_POSSIBLE_KEY -> HA_MAX_POSSIBLE_KEY mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisam/mi_packrec.c: mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisam/mi_range.c: mi_compare_text -> ha_compare_text storage/myisam/mi_test1.c: mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisam/mi_test2.c: mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisam/mi_unique.c: mi_compare_text() -> ha_compare_text() storage/myisam/mi_write.c: mi_compare_text() -> ha_compare_text() storage/myisam/myisamchk.c: Include my_bit.h storage/myisam/myisamdef.h: Moved store_key_length_inc to handler.h storage/myisam/myisampack.c: mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisam/sp_test.c: mi_portable_sizeof_char_ptr -> portable_sizeof_char_ptr storage/myisammrg/ha_myisammrg.cc: HA_EXTRA_PREPARE_FOR_DELETE -> HA_EXTRA_PREPARE_FOR_DROP include/my_bit.h: New BitKeeper file ``include/my_bit.h''
563 lines
16 KiB
C
563 lines
16 KiB
C
/* Copyright (C) 2000-2003 MySQL AB
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; version 2 of the License.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License
|
|
along with this program; if not, write to the Free Software
|
|
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA */
|
|
|
|
/*
|
|
* Memory sub-system, written by Bjorn Benson
|
|
Fixed to use my_sys scheme by Michael Widenius
|
|
|
|
[This posting refers to an article entitled "oops, corrupted memory
|
|
again!" in net.lang.c. I am posting it here because it is source.]
|
|
|
|
My tool for approaching this problem is to build another level of data
|
|
abstraction on top of malloc() and free() that implements some checking.
|
|
This does a number of things for you:
|
|
- Checks for overruns and underruns on allocated data
|
|
- Keeps track of where in the program the memory was malloc'ed
|
|
- Reports on pieces of memory that were not free'ed
|
|
- Records some statistics such as maximum memory used
|
|
- Marks newly malloc'ed and newly free'ed memory with special values
|
|
You can use this scheme to:
|
|
- Find bugs such as overrun, underrun, etc because you know where
|
|
a piece of data was malloc'ed and where it was free'ed
|
|
- Find bugs where memory was not free'ed
|
|
- Find bugs where newly malloc'ed memory is used without initializing
|
|
- Find bugs where newly free'ed memory is still used
|
|
- Determine how much memory your program really uses
|
|
- and other things
|
|
|
|
To implement my scheme you must have a C compiler that has __LINE__ and
|
|
__FILE__ macros. If your compiler doesn't have these then (a) buy another:
|
|
compilers that do are available on UNIX 4.2bsd based systems and the PC,
|
|
and probably on other machines; or (b) change my scheme somehow. I have
|
|
recomendations on both these points if you would like them (e-mail please).
|
|
|
|
There are 4 functions in my package:
|
|
char *NEW( uSize ) Allocate memory of uSize bytes
|
|
(equivalent to malloc())
|
|
char *REA( pPtr, uSize) Allocate memory of uSize bytes, move data and
|
|
free pPtr.
|
|
(equivalent to realloc())
|
|
FREE( pPtr ) Free memory allocated by NEW
|
|
(equivalent to free())
|
|
TERMINATE(file,flag) End system, report errors and stats on file
|
|
I personally use two more functions, but have not included them here:
|
|
char *STRSAVE( sPtr ) Save a copy of the string in dynamic memory
|
|
char *RENEW( pPtr, uSize )
|
|
(equivalent to realloc())
|
|
|
|
*/
|
|
|
|
#ifndef SAFEMALLOC
|
|
#define SAFEMALLOC /* Get protos from my_sys */
|
|
#endif
|
|
|
|
#include "mysys_priv.h"
|
|
#include <m_string.h>
|
|
#include "my_static.h"
|
|
#include "mysys_err.h"
|
|
|
|
ulonglong sf_malloc_mem_limit= ~(ulonglong)0;
|
|
|
|
#ifndef PEDANTIC_SAFEMALLOC
|
|
/*
|
|
Set to 1 after TERMINATE() if we had to fiddle with sf_malloc_count and
|
|
the linked list of blocks so that _sanity() will not fuss when it
|
|
is not supposed to
|
|
*/
|
|
static int sf_malloc_tampered= 0;
|
|
#endif
|
|
|
|
|
|
/* Static functions prototypes */
|
|
|
|
static int check_ptr(const char *where, uchar *ptr, const char *sFile,
|
|
uint uLine);
|
|
static int _checkchunk(struct st_irem *pRec, const char *sFile, uint uLine);
|
|
|
|
/*
|
|
Note: We only fill up the allocated block. This do not include
|
|
malloc() roundoff or the extra space required by the irem
|
|
structures.
|
|
*/
|
|
|
|
/*
|
|
NEW'ed memory is filled with this value so that references to it will
|
|
end up being very strange.
|
|
*/
|
|
#define ALLOC_VAL (uchar) 0xA5
|
|
/*
|
|
FEEE'ed memory is filled with this value so that references to it will
|
|
end up being very strange.
|
|
*/
|
|
#define FREE_VAL (uchar) 0x8F
|
|
#define MAGICKEY 0x14235296 /* A magic value for underrun key */
|
|
|
|
/*
|
|
Warning: do not change the MAGICEND? values to something with the
|
|
high bit set. Various C compilers (like the 4.2bsd one) do not do
|
|
the sign extension right later on in this code and you will get
|
|
erroneous errors.
|
|
*/
|
|
|
|
#define MAGICEND0 0x68 /* Magic values for overrun keys */
|
|
#define MAGICEND1 0x34 /* " */
|
|
#define MAGICEND2 0x7A /* " */
|
|
#define MAGICEND3 0x15 /* " */
|
|
|
|
|
|
/* Allocate some memory. */
|
|
|
|
void *_mymalloc(size_t size, const char *filename, uint lineno, myf MyFlags)
|
|
{
|
|
struct st_irem *irem;
|
|
uchar *data;
|
|
DBUG_ENTER("_mymalloc");
|
|
DBUG_PRINT("enter",("Size: %lu", (ulong) size));
|
|
|
|
if (!sf_malloc_quick)
|
|
(void) _sanity (filename, lineno);
|
|
|
|
if (size + sf_malloc_cur_memory > sf_malloc_mem_limit)
|
|
irem= 0;
|
|
else
|
|
{
|
|
/* Allocate the physical memory */
|
|
irem= (struct st_irem *) malloc (ALIGN_SIZE(sizeof(struct st_irem)) +
|
|
sf_malloc_prehunc +
|
|
size + /* size requested */
|
|
4 + /* overrun mark */
|
|
sf_malloc_endhunc);
|
|
}
|
|
/* Check if there isn't anymore memory avaiable */
|
|
if (!irem)
|
|
{
|
|
if (MyFlags & MY_FAE)
|
|
error_handler_hook=fatal_error_handler_hook;
|
|
if (MyFlags & (MY_FAE+MY_WME))
|
|
{
|
|
char buff[SC_MAXWIDTH];
|
|
my_errno=errno;
|
|
sprintf(buff,"Out of memory at line %d, '%s'", lineno, filename);
|
|
my_message(EE_OUTOFMEMORY, buff, MYF(ME_BELL+ME_WAITTANG+ME_NOREFRESH));
|
|
sprintf(buff,"needed %u byte (%ldk), memory in use: %ld bytes (%ldk)",
|
|
(uint) size, (uint) (size + 1023L) / 1024L,
|
|
sf_malloc_max_memory, (sf_malloc_max_memory + 1023L) / 1024L);
|
|
my_message(EE_OUTOFMEMORY, buff, MYF(ME_BELL+ME_WAITTANG+ME_NOREFRESH));
|
|
}
|
|
DBUG_PRINT("error",("Out of memory, in use: %ld at line %d, '%s'",
|
|
sf_malloc_max_memory,lineno, filename));
|
|
if (MyFlags & MY_FAE)
|
|
exit(1);
|
|
DBUG_RETURN ((void*) 0);
|
|
}
|
|
|
|
/* Fill up the structure */
|
|
data= (((uchar*) irem) + ALIGN_SIZE(sizeof(struct st_irem)) +
|
|
sf_malloc_prehunc);
|
|
*((uint32*) (data-sizeof(uint32)))= MAGICKEY;
|
|
data[size + 0]= MAGICEND0;
|
|
data[size + 1]= MAGICEND1;
|
|
data[size + 2]= MAGICEND2;
|
|
data[size + 3]= MAGICEND3;
|
|
irem->filename= (char *) filename;
|
|
irem->linenum= lineno;
|
|
irem->datasize= size;
|
|
irem->prev= NULL;
|
|
|
|
/* Add this remember structure to the linked list */
|
|
pthread_mutex_lock(&THR_LOCK_malloc);
|
|
if ((irem->next= sf_malloc_root))
|
|
sf_malloc_root->prev= irem;
|
|
sf_malloc_root= irem;
|
|
|
|
/* Keep the statistics */
|
|
sf_malloc_cur_memory+= size;
|
|
if (sf_malloc_cur_memory > sf_malloc_max_memory)
|
|
sf_malloc_max_memory= sf_malloc_cur_memory;
|
|
sf_malloc_count++;
|
|
pthread_mutex_unlock(&THR_LOCK_malloc);
|
|
|
|
/* Set the memory to the aribtrary wierd value */
|
|
if ((MyFlags & MY_ZEROFILL) || !sf_malloc_quick)
|
|
bfill(data, size, (char) (MyFlags & MY_ZEROFILL ? 0 : ALLOC_VAL));
|
|
/* Return a pointer to the real data */
|
|
DBUG_PRINT("exit",("ptr: 0x%lx", (long) data));
|
|
if (sf_min_adress > data)
|
|
sf_min_adress= data;
|
|
if (sf_max_adress < data)
|
|
sf_max_adress= data;
|
|
DBUG_RETURN((void*) data);
|
|
}
|
|
|
|
|
|
/*
|
|
Allocate some new memory and move old memoryblock there.
|
|
Free then old memoryblock
|
|
*/
|
|
|
|
void *_myrealloc(register void *ptr, register size_t size,
|
|
const char *filename, uint lineno, myf MyFlags)
|
|
{
|
|
struct st_irem *irem;
|
|
char *data;
|
|
DBUG_ENTER("_myrealloc");
|
|
|
|
if (!ptr && (MyFlags & MY_ALLOW_ZERO_PTR))
|
|
DBUG_RETURN(_mymalloc(size, filename, lineno, MyFlags));
|
|
|
|
if (!sf_malloc_quick)
|
|
(void) _sanity (filename, lineno);
|
|
|
|
if (check_ptr("Reallocating", (uchar*) ptr, filename, lineno))
|
|
DBUG_RETURN((uchar*) NULL);
|
|
|
|
irem= (struct st_irem *) (((char*) ptr) - ALIGN_SIZE(sizeof(struct st_irem))-
|
|
sf_malloc_prehunc);
|
|
if (*((uint32*) (((char*) ptr)- sizeof(uint32))) != MAGICKEY)
|
|
{
|
|
fprintf(stderr, "Error: Reallocating unallocated data at line %d, '%s'\n",
|
|
lineno, filename);
|
|
DBUG_PRINT("safe",("Reallocating unallocated data at line %d, '%s'",
|
|
lineno, filename));
|
|
(void) fflush(stderr);
|
|
DBUG_RETURN((uchar*) NULL);
|
|
}
|
|
|
|
if ((data= _mymalloc(size,filename,lineno,MyFlags))) /* Allocate new area */
|
|
{
|
|
size=min(size, irem->datasize); /* Move as much as possibly */
|
|
memcpy((uchar*) data, ptr, (size_t) size); /* Copy old data */
|
|
_myfree(ptr, filename, lineno, 0); /* Free not needed area */
|
|
}
|
|
else
|
|
{
|
|
if (MyFlags & MY_HOLD_ON_ERROR)
|
|
DBUG_RETURN(ptr);
|
|
if (MyFlags & MY_FREE_ON_ERROR)
|
|
_myfree(ptr, filename, lineno, 0);
|
|
}
|
|
DBUG_RETURN(data);
|
|
} /* _myrealloc */
|
|
|
|
|
|
/* Deallocate some memory. */
|
|
|
|
void _myfree(void *ptr, const char *filename, uint lineno, myf myflags)
|
|
{
|
|
struct st_irem *irem;
|
|
DBUG_ENTER("_myfree");
|
|
DBUG_PRINT("enter",("ptr: 0x%lx", (long) ptr));
|
|
|
|
if (!sf_malloc_quick)
|
|
(void) _sanity (filename, lineno);
|
|
|
|
if ((!ptr && (myflags & MY_ALLOW_ZERO_PTR)) ||
|
|
check_ptr("Freeing",(uchar*) ptr,filename,lineno))
|
|
DBUG_VOID_RETURN;
|
|
|
|
/* Calculate the address of the remember structure */
|
|
irem= (struct st_irem *) ((char*) ptr- ALIGN_SIZE(sizeof(struct st_irem))-
|
|
sf_malloc_prehunc);
|
|
|
|
/*
|
|
Check to make sure that we have a real remember structure.
|
|
Note: this test could fail for four reasons:
|
|
(1) The memory was already free'ed
|
|
(2) The memory was never new'ed
|
|
(3) There was an underrun
|
|
(4) A stray pointer hit this location
|
|
*/
|
|
|
|
if (*((uint32*) ((char*) ptr- sizeof(uint32))) != MAGICKEY)
|
|
{
|
|
fprintf(stderr, "Error: Freeing unallocated data at line %d, '%s'\n",
|
|
lineno, filename);
|
|
DBUG_PRINT("safe",("Unallocated data at line %d, '%s'",lineno,filename));
|
|
(void) fflush(stderr);
|
|
DBUG_VOID_RETURN;
|
|
}
|
|
|
|
/* Remove this structure from the linked list */
|
|
pthread_mutex_lock(&THR_LOCK_malloc);
|
|
if (irem->prev)
|
|
irem->prev->next= irem->next;
|
|
else
|
|
sf_malloc_root= irem->next;
|
|
|
|
if (irem->next)
|
|
irem->next->prev= irem->prev;
|
|
/* Handle the statistics */
|
|
sf_malloc_cur_memory-= irem->datasize;
|
|
sf_malloc_count--;
|
|
pthread_mutex_unlock(&THR_LOCK_malloc);
|
|
|
|
#ifndef HAVE_purify
|
|
/* Mark this data as free'ed */
|
|
if (!sf_malloc_quick)
|
|
bfill(ptr, irem->datasize, (pchar) FREE_VAL);
|
|
#endif
|
|
*((uint32*) ((char*) ptr- sizeof(uint32)))= ~MAGICKEY;
|
|
/* Actually free the memory */
|
|
free((char*) irem);
|
|
DBUG_VOID_RETURN;
|
|
}
|
|
|
|
/* Check if we have a wrong pointer */
|
|
|
|
static int check_ptr(const char *where, uchar *ptr, const char *filename,
|
|
uint lineno)
|
|
{
|
|
if (!ptr)
|
|
{
|
|
fprintf(stderr, "Error: %s NULL pointer at line %d, '%s'\n",
|
|
where,lineno, filename);
|
|
DBUG_PRINT("safe",("Null pointer at line %d '%s'", lineno, filename));
|
|
(void) fflush(stderr);
|
|
return 1;
|
|
}
|
|
#ifndef _MSC_VER
|
|
if ((long) ptr & (ALIGN_SIZE(1)-1))
|
|
{
|
|
fprintf(stderr, "Error: %s wrong aligned pointer at line %d, '%s'\n",
|
|
where,lineno, filename);
|
|
DBUG_PRINT("safe",("Wrong aligned pointer at line %d, '%s'",
|
|
lineno,filename));
|
|
(void) fflush(stderr);
|
|
return 1;
|
|
}
|
|
#endif
|
|
if (ptr < sf_min_adress || ptr > sf_max_adress)
|
|
{
|
|
fprintf(stderr, "Error: %s pointer out of range at line %d, '%s'\n",
|
|
where,lineno, filename);
|
|
DBUG_PRINT("safe",("Pointer out of range at line %d '%s'",
|
|
lineno,filename));
|
|
(void) fflush(stderr);
|
|
return 1;
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
|
|
/*
|
|
Report on all the memory pieces that have not been free'ed
|
|
|
|
SYNOPSIS
|
|
TERMINATE()
|
|
file Write output to this file
|
|
flag If <> 0, also write statistics
|
|
*/
|
|
|
|
void TERMINATE(FILE *file, uint flag)
|
|
{
|
|
struct st_irem *irem;
|
|
DBUG_ENTER("TERMINATE");
|
|
pthread_mutex_lock(&THR_LOCK_malloc);
|
|
|
|
/*
|
|
Report the difference between number of calls to
|
|
NEW and the number of calls to FREE. >0 means more
|
|
NEWs than FREEs. <0, etc.
|
|
*/
|
|
|
|
if (sf_malloc_count)
|
|
{
|
|
if (file)
|
|
{
|
|
fprintf(file, "Warning: Not freed memory segments: %u\n", sf_malloc_count);
|
|
(void) fflush(file);
|
|
}
|
|
DBUG_PRINT("safe",("sf_malloc_count: %u", sf_malloc_count));
|
|
}
|
|
|
|
/*
|
|
Report on all the memory that was allocated with NEW
|
|
but not free'ed with FREE.
|
|
*/
|
|
|
|
if ((irem= sf_malloc_root))
|
|
{
|
|
if (file)
|
|
{
|
|
fprintf(file, "Warning: Memory that was not free'ed (%ld bytes):\n",
|
|
sf_malloc_cur_memory);
|
|
(void) fflush(file);
|
|
}
|
|
DBUG_PRINT("safe",("Memory that was not free'ed (%ld bytes):",
|
|
sf_malloc_cur_memory));
|
|
while (irem)
|
|
{
|
|
char *data= (((char*) irem) + ALIGN_SIZE(sizeof(struct st_irem)) +
|
|
sf_malloc_prehunc);
|
|
if (file)
|
|
{
|
|
fprintf(file,
|
|
"\t%6u bytes at 0x%09lx, allocated at line %4u in '%s'",
|
|
irem->datasize, (long) data, irem->linenum, irem->filename);
|
|
fprintf(file, "\n");
|
|
(void) fflush(file);
|
|
}
|
|
DBUG_PRINT("safe",
|
|
("%6u bytes at 0x%09lx, allocated at line %4d in '%s'",
|
|
irem->datasize, (long) data, irem->linenum, irem->filename));
|
|
irem= irem->next;
|
|
}
|
|
}
|
|
/* Report the memory usage statistics */
|
|
if (file && flag)
|
|
{
|
|
fprintf(file, "Maximum memory usage: %ld bytes (%ldk)\n",
|
|
sf_malloc_max_memory, (sf_malloc_max_memory + 1023L) / 1024L);
|
|
(void) fflush(file);
|
|
}
|
|
DBUG_PRINT("safe",("Maximum memory usage: %ld bytes (%ldk)",
|
|
sf_malloc_max_memory, (sf_malloc_max_memory + 1023L) /
|
|
1024L));
|
|
pthread_mutex_unlock(&THR_LOCK_malloc);
|
|
DBUG_VOID_RETURN;
|
|
}
|
|
|
|
|
|
/*
|
|
Report where a piece of memory was allocated
|
|
|
|
This is usefull to call from withing a debugger
|
|
*/
|
|
|
|
|
|
void sf_malloc_report_allocated(void *memory)
|
|
{
|
|
struct st_irem *irem;
|
|
for (irem= sf_malloc_root ; irem ; irem=irem->next)
|
|
{
|
|
char *data= (((char*) irem) + ALIGN_SIZE(sizeof(struct st_irem)) +
|
|
sf_malloc_prehunc);
|
|
if (data <= (char*) memory && (char*) memory <= data + irem->datasize)
|
|
{
|
|
printf("%u bytes at 0x%lx, allocated at line %u in '%s'\n",
|
|
irem->datasize, (long) data, irem->linenum, irem->filename);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
/* Returns 0 if chunk is ok */
|
|
|
|
static int _checkchunk(register struct st_irem *irem, const char *filename,
|
|
uint lineno)
|
|
{
|
|
int flag=0;
|
|
char *magicp, *data;
|
|
|
|
data= (((char*) irem) + ALIGN_SIZE(sizeof(struct st_irem)) +
|
|
sf_malloc_prehunc);
|
|
/* Check for a possible underrun */
|
|
if (*((uint32*) (data- sizeof(uint32))) != MAGICKEY)
|
|
{
|
|
fprintf(stderr, "Error: Memory allocated at %s:%d was underrun,",
|
|
irem->filename, irem->linenum);
|
|
fprintf(stderr, " discovered at %s:%d\n", filename, lineno);
|
|
(void) fflush(stderr);
|
|
DBUG_PRINT("safe",("Underrun at 0x%lx, allocated at %s:%d",
|
|
(long) data, irem->filename, irem->linenum));
|
|
flag=1;
|
|
}
|
|
|
|
/* Check for a possible overrun */
|
|
magicp= data + irem->datasize;
|
|
if (*magicp++ != MAGICEND0 ||
|
|
*magicp++ != MAGICEND1 ||
|
|
*magicp++ != MAGICEND2 ||
|
|
*magicp++ != MAGICEND3)
|
|
{
|
|
fprintf(stderr, "Error: Memory allocated at %s:%d was overrun,",
|
|
irem->filename, irem->linenum);
|
|
fprintf(stderr, " discovered at '%s:%d'\n", filename, lineno);
|
|
(void) fflush(stderr);
|
|
DBUG_PRINT("safe",("Overrun at 0x%lx, allocated at %s:%d",
|
|
(long) data,
|
|
irem->filename,
|
|
irem->linenum));
|
|
flag=1;
|
|
}
|
|
return(flag);
|
|
}
|
|
|
|
|
|
/* Returns how many wrong chunks */
|
|
|
|
int _sanity(const char *filename, uint lineno)
|
|
{
|
|
reg1 struct st_irem *irem;
|
|
reg2 int flag=0;
|
|
uint count=0;
|
|
|
|
pthread_mutex_lock(&THR_LOCK_malloc);
|
|
#ifndef PEDANTIC_SAFEMALLOC
|
|
if (sf_malloc_tampered && (int) sf_malloc_count < 0)
|
|
sf_malloc_count=0;
|
|
#endif
|
|
count=sf_malloc_count;
|
|
for (irem= sf_malloc_root; irem != NULL && count-- ; irem= irem->next)
|
|
flag+= _checkchunk (irem, filename, lineno);
|
|
pthread_mutex_unlock(&THR_LOCK_malloc);
|
|
if (count || irem)
|
|
{
|
|
const char *format="Error: Safemalloc link list destroyed, discovered at '%s:%d'";
|
|
fprintf(stderr, format, filename, lineno); fputc('\n',stderr);
|
|
fprintf(stderr, "root=%p,count=%d,irem=%p\n", sf_malloc_root,count,irem);
|
|
(void) fflush(stderr);
|
|
DBUG_PRINT("safe",(format, filename, lineno));
|
|
flag=1;
|
|
}
|
|
return flag;
|
|
} /* _sanity */
|
|
|
|
|
|
/* malloc and copy */
|
|
|
|
void *_my_memdup(const void *from, size_t length, const char *filename,
|
|
uint lineno, myf MyFlags)
|
|
{
|
|
void *ptr;
|
|
if ((ptr= _mymalloc(length,filename,lineno,MyFlags)) != 0)
|
|
memcpy(ptr, from, length);
|
|
return(ptr);
|
|
} /*_my_memdup */
|
|
|
|
|
|
char *_my_strdup(const char *from, const char *filename, uint lineno,
|
|
myf MyFlags)
|
|
{
|
|
char *ptr;
|
|
size_t length= strlen(from)+1;
|
|
if ((ptr= (char*) _mymalloc(length,filename,lineno,MyFlags)) != 0)
|
|
memcpy((uchar*) ptr, (uchar*) from, (size_t) length);
|
|
return(ptr);
|
|
} /* _my_strdup */
|
|
|
|
|
|
char *_my_strndup(const char *from, size_t length,
|
|
const char *filename, uint lineno,
|
|
myf MyFlags)
|
|
{
|
|
char *ptr;
|
|
if ((ptr= (char*) _mymalloc(length+1,filename,lineno,MyFlags)) != 0)
|
|
{
|
|
memcpy((uchar*) ptr, (uchar*) from, (size_t) length);
|
|
ptr[length]=0;
|
|
}
|
|
return(ptr);
|
|
}
|