diff options
Diffstat (limited to 'storage/heap/hp_panic.c')
-rw-r--r-- | storage/heap/hp_panic.c | 57 |
1 files changed, 57 insertions, 0 deletions
diff --git a/storage/heap/hp_panic.c b/storage/heap/hp_panic.c new file mode 100644 index 00000000000..2b659cbfbb3 --- /dev/null +++ b/storage/heap/hp_panic.c @@ -0,0 +1,57 @@ +/* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult 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; either version 2 of the License, or + (at your option) any later version. + + 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 */ + +#include "heapdef.h" + + /* if flag == HA_PANIC_CLOSE then all files are removed for more + memory */ + +int heap_panic(enum ha_panic_function flag) +{ + LIST *element,*next_open; + DBUG_ENTER("heap_panic"); + + pthread_mutex_lock(&THR_LOCK_heap); + for (element=heap_open_list ; element ; element=next_open) + { + HP_INFO *info=(HP_INFO*) element->data; + next_open=element->next; /* Save if close */ + switch (flag) { + case HA_PANIC_CLOSE: + hp_close(info); + break; + default: + break; + } + } + for (element=heap_share_list ; element ; element=next_open) + { + HP_SHARE *share=(HP_SHARE*) element->data; + next_open=element->next; /* Save if close */ + switch (flag) { + case HA_PANIC_CLOSE: + { + if (!share->open_count) + hp_free(share); + break; + } + default: + break; + } + } + pthread_mutex_unlock(&THR_LOCK_heap); + DBUG_RETURN(0); +} /* heap_panic */ |