mirror of
https://github.com/microsoft/mimalloc.git
synced 2025-05-06 15:29:31 +03:00
move statistics api into internal.h
This commit is contained in:
parent
f735e6e6b5
commit
bb9f3e3b43
3 changed files with 62 additions and 97 deletions
|
@ -258,7 +258,7 @@ bool _mi_page_is_valid(mi_page_t* page);
|
||||||
|
|
||||||
|
|
||||||
/* -----------------------------------------------------------
|
/* -----------------------------------------------------------
|
||||||
Assertions
|
Assertions
|
||||||
----------------------------------------------------------- */
|
----------------------------------------------------------- */
|
||||||
|
|
||||||
#if (MI_DEBUG)
|
#if (MI_DEBUG)
|
||||||
|
@ -281,6 +281,46 @@ void _mi_assert_fail(const char* assertion, const char* fname, unsigned int line
|
||||||
#define mi_assert_expensive(x)
|
#define mi_assert_expensive(x)
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
/* -----------------------------------------------------------
|
||||||
|
Statistics (in `stats.c`)
|
||||||
|
----------------------------------------------------------- */
|
||||||
|
|
||||||
|
// add to stat keeping track of the peak
|
||||||
|
void __mi_stat_increase(mi_stat_count_t* stat, size_t amount);
|
||||||
|
void __mi_stat_decrease(mi_stat_count_t* stat, size_t amount);
|
||||||
|
void __mi_stat_increase_mt(mi_stat_count_t* stat, size_t amount);
|
||||||
|
void __mi_stat_decrease_mt(mi_stat_count_t* stat, size_t amount);
|
||||||
|
|
||||||
|
// adjust stat in special cases to compensate for double counting (and does not adjust peak values and can decrease the total)
|
||||||
|
void __mi_stat_adjust_increase(mi_stat_count_t* stat, size_t amount);
|
||||||
|
void __mi_stat_adjust_decrease(mi_stat_count_t* stat, size_t amount);
|
||||||
|
void __mi_stat_adjust_increase_mt(mi_stat_count_t* stat, size_t amount);
|
||||||
|
void __mi_stat_adjust_decrease_mt(mi_stat_count_t* stat, size_t amount);
|
||||||
|
|
||||||
|
// counters can just be increased
|
||||||
|
void __mi_stat_counter_increase(mi_stat_counter_t* stat, size_t amount);
|
||||||
|
void __mi_stat_counter_increase_mt(mi_stat_counter_t* stat, size_t amount);
|
||||||
|
|
||||||
|
#define mi_subproc_stat_counter_increase(subproc,stat,amount) __mi_stat_counter_increase_mt( &(subproc)->stats.stat, amount)
|
||||||
|
#define mi_subproc_stat_increase(subproc,stat,amount) __mi_stat_increase_mt( &(subproc)->stats.stat, amount)
|
||||||
|
#define mi_subproc_stat_decrease(subproc,stat,amount) __mi_stat_decrease_mt( &(subproc)->stats.stat, amount)
|
||||||
|
#define mi_subproc_stat_adjust_increase(subproc,stat,amnt) __mi_stat_adjust_increase_mt( &(subproc)->stats.stat, amnt)
|
||||||
|
#define mi_subproc_stat_adjust_decrease(subproc,stat,amnt) __mi_stat_adjust_decrease_mt( &(subproc)->stats.stat, amnt)
|
||||||
|
|
||||||
|
#define mi_tld_stat_counter_increase(tld,stat,amount) __mi_stat_counter_increase( &(tld)->stats.stat, amount)
|
||||||
|
#define mi_tld_stat_increase(tld,stat,amount) __mi_stat_increase( &(tld)->stats.stat, amount)
|
||||||
|
#define mi_tld_stat_decrease(tld,stat,amount) __mi_stat_decrease( &(tld)->stats.stat, amount)
|
||||||
|
#define mi_tld_stat_adjust_increase(tld,stat,amnt) __mi_stat_adjust_increase( &(tld)->stats.stat, amnt)
|
||||||
|
#define mi_tld_stat_adjust_decrease(tld,stat,amnt) __mi_stat_adjust_decrease( &(tld)->stats.stat, amnt)
|
||||||
|
|
||||||
|
#define mi_os_stat_counter_increase(stat,amount) mi_subproc_stat_counter_increase(_mi_subproc(),stat,amount)
|
||||||
|
#define mi_os_stat_increase(stat,amount) mi_subproc_stat_increase(_mi_subproc(),stat,amount)
|
||||||
|
#define mi_os_stat_decrease(stat,amount) mi_subproc_stat_decrease(_mi_subproc(),stat,amount)
|
||||||
|
|
||||||
|
#define mi_heap_stat_counter_increase(heap,stat,amount) mi_tld_stat_counter_increase(heap->tld, stat, amount)
|
||||||
|
#define mi_heap_stat_increase(heap,stat,amount) mi_tld_stat_increase( heap->tld, stat, amount)
|
||||||
|
#define mi_heap_stat_decrease(heap,stat,amount) mi_tld_stat_decrease( heap->tld, stat, amount)
|
||||||
|
|
||||||
|
|
||||||
/* -----------------------------------------------------------
|
/* -----------------------------------------------------------
|
||||||
Inlined definitions
|
Inlined definitions
|
||||||
|
|
|
@ -76,6 +76,15 @@ terms of the MIT license. A copy of the license can be found in the file
|
||||||
#endif
|
#endif
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
// Statistics (0=only essential, 1=normal, 2=more fine-grained (expensive) tracking)
|
||||||
|
#ifndef MI_STAT
|
||||||
|
#if (MI_DEBUG>0)
|
||||||
|
#define MI_STAT 2
|
||||||
|
#else
|
||||||
|
#define MI_STAT 0
|
||||||
|
#endif
|
||||||
|
#endif
|
||||||
|
|
||||||
// Use guard pages behind objects of a certain size (set by the MIMALLOC_DEBUG_GUARDED_MIN/MAX options)
|
// Use guard pages behind objects of a certain size (set by the MIMALLOC_DEBUG_GUARDED_MIN/MAX options)
|
||||||
// Padding should be disabled when using guard pages
|
// Padding should be disabled when using guard pages
|
||||||
// #define MI_GUARDED 1
|
// #define MI_GUARDED 1
|
||||||
|
@ -565,7 +574,6 @@ typedef struct mi_arena_s {
|
||||||
} mi_arena_t;
|
} mi_arena_t;
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
/* -----------------------------------------------------------
|
/* -----------------------------------------------------------
|
||||||
Error codes passed to `_mi_fatal_error`
|
Error codes passed to `_mi_fatal_error`
|
||||||
All are recoverable but EFAULT is a serious error and aborts by default in secure mode.
|
All are recoverable but EFAULT is a serious error and aborts by default in secure mode.
|
||||||
|
@ -589,10 +597,9 @@ typedef struct mi_arena_s {
|
||||||
#define EOVERFLOW (75)
|
#define EOVERFLOW (75)
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
|
/* -----------------------------------------------------------
|
||||||
// ------------------------------------------------------
|
Debug constants
|
||||||
// Debug
|
----------------------------------------------------------- */
|
||||||
// ------------------------------------------------------
|
|
||||||
|
|
||||||
#if !defined(MI_DEBUG_UNINIT)
|
#if !defined(MI_DEBUG_UNINIT)
|
||||||
#define MI_DEBUG_UNINIT (0xD0)
|
#define MI_DEBUG_UNINIT (0xD0)
|
||||||
|
@ -604,93 +611,5 @@ typedef struct mi_arena_s {
|
||||||
#define MI_DEBUG_PADDING (0xDE)
|
#define MI_DEBUG_PADDING (0xDE)
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
#if (MI_DEBUG)
|
|
||||||
// use our own assertion to print without memory allocation
|
|
||||||
void _mi_assert_fail(const char* assertion, const char* fname, unsigned int line, const char* func );
|
|
||||||
#define mi_assert(expr) ((expr) ? (void)0 : _mi_assert_fail(#expr,__FILE__,__LINE__,__func__))
|
|
||||||
#else
|
|
||||||
#define mi_assert(x)
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#if (MI_DEBUG>1)
|
|
||||||
#define mi_assert_internal mi_assert
|
|
||||||
#else
|
|
||||||
#define mi_assert_internal(x)
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#if (MI_DEBUG>2)
|
|
||||||
#define mi_assert_expensive mi_assert
|
|
||||||
#else
|
|
||||||
#define mi_assert_expensive(x)
|
|
||||||
#endif
|
|
||||||
|
|
||||||
|
|
||||||
// ------------------------------------------------------
|
|
||||||
// Statistics
|
|
||||||
// ------------------------------------------------------
|
|
||||||
#ifndef MI_STAT
|
|
||||||
#if (MI_DEBUG>0)
|
|
||||||
#define MI_STAT 2
|
|
||||||
#else
|
|
||||||
#define MI_STAT 0
|
|
||||||
#endif
|
|
||||||
#endif
|
|
||||||
|
|
||||||
|
|
||||||
// add to stat keeping track of the peak
|
|
||||||
void __mi_stat_increase(mi_stat_count_t* stat, size_t amount);
|
|
||||||
void __mi_stat_decrease(mi_stat_count_t* stat, size_t amount);
|
|
||||||
void __mi_stat_increase_mt(mi_stat_count_t* stat, size_t amount);
|
|
||||||
void __mi_stat_decrease_mt(mi_stat_count_t* stat, size_t amount);
|
|
||||||
|
|
||||||
// adjust stat in special cases to compensate for double counting (and does not adjust peak values and can decrease the total)
|
|
||||||
void __mi_stat_adjust_increase(mi_stat_count_t* stat, size_t amount);
|
|
||||||
void __mi_stat_adjust_decrease(mi_stat_count_t* stat, size_t amount);
|
|
||||||
void __mi_stat_adjust_increase_mt(mi_stat_count_t* stat, size_t amount);
|
|
||||||
void __mi_stat_adjust_decrease_mt(mi_stat_count_t* stat, size_t amount);
|
|
||||||
|
|
||||||
// counters can just be increased
|
|
||||||
void __mi_stat_counter_increase(mi_stat_counter_t* stat, size_t amount);
|
|
||||||
void __mi_stat_counter_increase_mt(mi_stat_counter_t* stat, size_t amount);
|
|
||||||
|
|
||||||
#if (MI_STAT)
|
|
||||||
#define mi_debug_stat_increase(stat,amount) __mi_stat_increase( &(stat), amount)
|
|
||||||
#define mi_debug_stat_decrease(stat,amount) __mi_stat_decrease( &(stat), amount)
|
|
||||||
#define mi_debug_stat_counter_increase(stat,amount) __mi_stat_counter_increase( &(stat), amount)
|
|
||||||
#define mi_debug_stat_increase_mt(stat,amount) __mi_stat_increase_mt( &(stat), amount)
|
|
||||||
#define mi_debug_stat_decrease_mt(stat,amount) __mi_stat_decrease_mt( &(stat), amount)
|
|
||||||
#define mi_debug_stat_counter_increase_mt(stat,amount) __mi_stat_counter_increase_mt( &(stat), amount)
|
|
||||||
#else
|
|
||||||
#define mi_debug_stat_increase(stat,amount) ((void)0)
|
|
||||||
#define mi_debug_stat_decrease(stat,amount) ((void)0)
|
|
||||||
#define mi_debug_stat_counter_increase(stat,amount) ((void)0)
|
|
||||||
#define mi_debug_stat_increase_mt(stat,amount) ((void)0)
|
|
||||||
#define mi_debug_stat_decrease_mt(stat,amount) ((void)0)
|
|
||||||
#define mi_debug_stat_counter_increase_mt(stat,amount) ((void)0)
|
|
||||||
#endif
|
|
||||||
|
|
||||||
#define mi_subproc_stat_counter_increase(subproc,stat,amount) __mi_stat_counter_increase_mt( &(subproc)->stats.stat, amount)
|
|
||||||
#define mi_subproc_stat_increase(subproc,stat,amount) __mi_stat_increase_mt( &(subproc)->stats.stat, amount)
|
|
||||||
#define mi_subproc_stat_decrease(subproc,stat,amount) __mi_stat_decrease_mt( &(subproc)->stats.stat, amount)
|
|
||||||
#define mi_subproc_stat_adjust_increase(subproc,stat,amnt) __mi_stat_adjust_increase_mt( &(subproc)->stats.stat, amnt)
|
|
||||||
#define mi_subproc_stat_adjust_decrease(subproc,stat,amnt) __mi_stat_adjust_decrease_mt( &(subproc)->stats.stat, amnt)
|
|
||||||
|
|
||||||
#define mi_tld_stat_counter_increase(tld,stat,amount) __mi_stat_counter_increase( &(tld)->stats.stat, amount)
|
|
||||||
#define mi_tld_stat_increase(tld,stat,amount) __mi_stat_increase( &(tld)->stats.stat, amount)
|
|
||||||
#define mi_tld_stat_decrease(tld,stat,amount) __mi_stat_decrease( &(tld)->stats.stat, amount)
|
|
||||||
#define mi_tld_stat_adjust_increase(tld,stat,amnt) __mi_stat_adjust_increase( &(tld)->stats.stat, amnt)
|
|
||||||
#define mi_tld_stat_adjust_decrease(tld,stat,amnt) __mi_stat_adjust_decrease( &(tld)->stats.stat, amnt)
|
|
||||||
|
|
||||||
#define mi_os_stat_counter_increase(stat,amount) mi_subproc_stat_counter_increase(_mi_subproc(),stat,amount)
|
|
||||||
#define mi_os_stat_increase(stat,amount) mi_subproc_stat_increase(_mi_subproc(),stat,amount)
|
|
||||||
#define mi_os_stat_decrease(stat,amount) mi_subproc_stat_decrease(_mi_subproc(),stat,amount)
|
|
||||||
|
|
||||||
#define mi_heap_stat_counter_increase(heap,stat,amount) mi_tld_stat_counter_increase(heap->tld, stat, amount)
|
|
||||||
#define mi_heap_stat_increase(heap,stat,amount) mi_tld_stat_increase( heap->tld, stat, amount)
|
|
||||||
#define mi_heap_stat_decrease(heap,stat,amount) mi_tld_stat_decrease( heap->tld, stat, amount)
|
|
||||||
|
|
||||||
#define mi_debug_heap_stat_counter_increase(heap,stat,amount) mi_debug_stat_counter_increase( (heap)->tld->stats.stat, amount)
|
|
||||||
#define mi_debug_heap_stat_increase(heap,stat,amount) mi_debug_stat_increase( (heap)->tld->stats.stat, amount)
|
|
||||||
#define mi_debug_heap_stat_decrease(heap,stat,amount) mi_debug_stat_decrease( (heap)->tld->stats.stat, amount)
|
|
||||||
|
|
||||||
#endif // MI_TYPES_H
|
#endif // MI_TYPES_H
|
||||||
|
|
12
src/page.c
12
src/page.c
|
@ -429,7 +429,9 @@ void _mi_page_retire(mi_page_t* page) mi_attr_noexcept {
|
||||||
if mi_likely( /* bsize < MI_MAX_RETIRE_SIZE && */ !mi_page_queue_is_special(pq)) { // not full or huge queue?
|
if mi_likely( /* bsize < MI_MAX_RETIRE_SIZE && */ !mi_page_queue_is_special(pq)) { // not full or huge queue?
|
||||||
if (pq->last==page && pq->first==page) { // the only page in the queue?
|
if (pq->last==page && pq->first==page) { // the only page in the queue?
|
||||||
mi_heap_t* heap = mi_page_heap(page);
|
mi_heap_t* heap = mi_page_heap(page);
|
||||||
mi_debug_heap_stat_counter_increase(heap, pages_retire, 1);
|
#if MI_STAT>0
|
||||||
|
mi_heap_stat_counter_increase(heap, pages_retire, 1);
|
||||||
|
#endif
|
||||||
page->retire_expire = (bsize <= MI_SMALL_MAX_OBJ_SIZE ? MI_RETIRE_CYCLES : MI_RETIRE_CYCLES/4);
|
page->retire_expire = (bsize <= MI_SMALL_MAX_OBJ_SIZE ? MI_RETIRE_CYCLES : MI_RETIRE_CYCLES/4);
|
||||||
mi_assert_internal(pq >= heap->pages);
|
mi_assert_internal(pq >= heap->pages);
|
||||||
const size_t index = pq - heap->pages;
|
const size_t index = pq - heap->pages;
|
||||||
|
@ -618,7 +620,9 @@ static void mi_page_extend_free(mi_heap_t* heap, mi_page_t* page) {
|
||||||
size_t page_size;
|
size_t page_size;
|
||||||
//uint8_t* page_start =
|
//uint8_t* page_start =
|
||||||
mi_page_area(page, &page_size);
|
mi_page_area(page, &page_size);
|
||||||
mi_debug_heap_stat_counter_increase(heap, pages_extended, 1);
|
#if MI_STAT>0
|
||||||
|
mi_heap_stat_counter_increase(heap, pages_extended, 1);
|
||||||
|
#endif
|
||||||
|
|
||||||
// calculate the extend count
|
// calculate the extend count
|
||||||
const size_t bsize = mi_page_block_size(page);
|
const size_t bsize = mi_page_block_size(page);
|
||||||
|
@ -658,7 +662,9 @@ static void mi_page_extend_free(mi_heap_t* heap, mi_page_t* page) {
|
||||||
}
|
}
|
||||||
// enable the new free list
|
// enable the new free list
|
||||||
page->capacity += (uint16_t)extend;
|
page->capacity += (uint16_t)extend;
|
||||||
mi_debug_heap_stat_increase(heap, page_committed, extend * bsize);
|
#if MI_STAT>0
|
||||||
|
mi_heap_stat_increase(heap, page_committed, extend * bsize);
|
||||||
|
#endif
|
||||||
mi_assert_expensive(mi_page_is_valid_init(page));
|
mi_assert_expensive(mi_page_is_valid_init(page));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Reference in a new issue