Commit 44dc2fbf authored by Rich Prohaska's avatar Rich Prohaska Committed by Yoni Fogel

#4488 disable toku memory stats refs[t:4488]

git-svn-id: file:///svn/toku/tokudb@39661 c7de825b-a66e-492c-adef-691d508d4ae1
parent 60973da5
...@@ -17,6 +17,7 @@ static realloc_fun_t t_realloc = 0; ...@@ -17,6 +17,7 @@ static realloc_fun_t t_realloc = 0;
static realloc_fun_t t_xrealloc = 0; static realloc_fun_t t_xrealloc = 0;
static LOCAL_MEMORY_STATUS_S status; static LOCAL_MEMORY_STATUS_S status;
int toku_memory_do_stats = 0;
int int
toku_memory_startup(void) { toku_memory_startup(void) {
...@@ -107,11 +108,13 @@ void * ...@@ -107,11 +108,13 @@ void *
toku_malloc(size_t size) { toku_malloc(size_t size) {
void *p = t_malloc ? t_malloc(size) : os_malloc(size); void *p = t_malloc ? t_malloc(size) : os_malloc(size);
if (p) { if (p) {
size_t used = my_malloc_usable_size(p); if (toku_memory_do_stats) {
__sync_add_and_fetch(&status.malloc_count, 1); size_t used = my_malloc_usable_size(p);
__sync_add_and_fetch(&status.requested,size); __sync_add_and_fetch(&status.malloc_count, 1);
__sync_add_and_fetch(&status.used, used); __sync_add_and_fetch(&status.requested,size);
set_max(status.used, status.freed); __sync_add_and_fetch(&status.used, used);
set_max(status.used, status.freed);
}
} else { } else {
__sync_add_and_fetch(&status.malloc_fail, 1); __sync_add_and_fetch(&status.malloc_fail, 1);
} }
...@@ -131,12 +134,14 @@ toku_realloc(void *p, size_t size) { ...@@ -131,12 +134,14 @@ toku_realloc(void *p, size_t size) {
size_t used_orig = p ? my_malloc_usable_size(p) : 0; size_t used_orig = p ? my_malloc_usable_size(p) : 0;
void *q = t_realloc ? t_realloc(p, size) : os_realloc(p, size); void *q = t_realloc ? t_realloc(p, size) : os_realloc(p, size);
if (q) { if (q) {
size_t used = my_malloc_usable_size(q); if (toku_memory_do_stats) {
__sync_add_and_fetch(&status.realloc_count, 1); size_t used = my_malloc_usable_size(q);
__sync_add_and_fetch(&status.requested, size); __sync_add_and_fetch(&status.realloc_count, 1);
__sync_add_and_fetch(&status.used, used); __sync_add_and_fetch(&status.requested, size);
__sync_add_and_fetch(&status.freed, used_orig); __sync_add_and_fetch(&status.used, used);
set_max(status.used, status.freed); __sync_add_and_fetch(&status.freed, used_orig);
set_max(status.used, status.freed);
}
} else { } else {
__sync_add_and_fetch(&status.realloc_fail, 1); __sync_add_and_fetch(&status.realloc_fail, 1);
} }
...@@ -158,9 +163,11 @@ toku_strdup(const char *s) { ...@@ -158,9 +163,11 @@ toku_strdup(const char *s) {
void void
toku_free(void *p) { toku_free(void *p) {
if (p) { if (p) {
size_t used = my_malloc_usable_size(p); if (toku_memory_do_stats) {
__sync_add_and_fetch(&status.free_count, 1); size_t used = my_malloc_usable_size(p);
__sync_add_and_fetch(&status.freed, used); __sync_add_and_fetch(&status.free_count, 1);
__sync_add_and_fetch(&status.freed, used);
}
if (t_free) if (t_free)
t_free(p); t_free(p);
else else
...@@ -178,11 +185,13 @@ toku_xmalloc(size_t size) { ...@@ -178,11 +185,13 @@ toku_xmalloc(size_t size) {
void *p = t_xmalloc ? t_xmalloc(size) : os_malloc(size); void *p = t_xmalloc ? t_xmalloc(size) : os_malloc(size);
if (p == NULL) // avoid function call in common case if (p == NULL) // avoid function call in common case
resource_assert(p); resource_assert(p);
size_t used = my_malloc_usable_size(p); if (toku_memory_do_stats) {
__sync_add_and_fetch(&status.malloc_count, 1); size_t used = my_malloc_usable_size(p);
__sync_add_and_fetch(&status.requested, size); __sync_add_and_fetch(&status.malloc_count, 1);
__sync_add_and_fetch(&status.used, used); __sync_add_and_fetch(&status.requested, size);
set_max(status.used, status.freed); __sync_add_and_fetch(&status.used, used);
set_max(status.used, status.freed);
}
return p; return p;
} }
...@@ -200,12 +209,14 @@ toku_xrealloc(void *v, size_t size) { ...@@ -200,12 +209,14 @@ toku_xrealloc(void *v, size_t size) {
void *p = t_xrealloc ? t_xrealloc(v, size) : os_realloc(v, size); void *p = t_xrealloc ? t_xrealloc(v, size) : os_realloc(v, size);
if (p == 0) // avoid function call in common case if (p == 0) // avoid function call in common case
resource_assert(p); resource_assert(p);
size_t used = my_malloc_usable_size(p); if (toku_memory_do_stats) {
__sync_add_and_fetch(&status.realloc_count, 1); size_t used = my_malloc_usable_size(p);
__sync_add_and_fetch(&status.requested, size); __sync_add_and_fetch(&status.realloc_count, 1);
__sync_add_and_fetch(&status.used, used); __sync_add_and_fetch(&status.requested, size);
__sync_add_and_fetch(&status.freed, used_orig); __sync_add_and_fetch(&status.used, used);
set_max(status.used, status.freed); __sync_add_and_fetch(&status.freed, used_orig);
set_max(status.used, status.freed);
}
return p; return p;
} }
......
...@@ -693,7 +693,6 @@ test_update_stress.tdbrun: VGRIND= ...@@ -693,7 +693,6 @@ test_update_stress.tdbrun: VGRIND=
stress-test.tdbrun: VGRIND= stress-test.tdbrun: VGRIND=
stress-test.bdbrun: VGRIND= stress-test.bdbrun: VGRIND=
hot-optimize-table-tests.tdbrun: VGRIND= hot-optimize-table-tests.tdbrun: VGRIND=
perf_checkpoint_var.tdbrun: VGRIND=
libs: libs:
...@@ -1052,7 +1051,11 @@ maxsize-for-loader-A.tdbrun: maxsize-for-loader.tdb ...@@ -1052,7 +1051,11 @@ maxsize-for-loader-A.tdbrun: maxsize-for-loader.tdb
maxsize-for-loader-B.tdbrun: maxsize-for-loader.tdb maxsize-for-loader-B.tdbrun: maxsize-for-loader.tdb
./$< -e $@ 2> /dev/null $(SUMMARIZE_CMD) ./$< -e $@ 2> /dev/null $(SUMMARIZE_CMD)
perf%.tdb: CPPFLAGS+=-DDONT_DEPRECATE_MALLOC # dont run perf tests with valgrind
perf_%.tdbrun: VGRIND=
# build some perf test with malloc
perf_%.tdb: CPPFLAGS+=-DDONT_DEPRECATE_MALLOC
clean: clean:
rm -f $(ALL_BINS) rm -f $(ALL_BINS)
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment