diff options
| -rw-r--r-- | src/benchmarks/blowup.py | 62 | ||||
| -rw-r--r-- | src/benchmarks/blowup/Makefile | 25 | ||||
| -rw-r--r-- | src/benchmarks/blowup/blowup.c | 90 |
3 files changed, 177 insertions, 0 deletions
diff --git a/src/benchmarks/blowup.py b/src/benchmarks/blowup.py new file mode 100644 index 0000000..ad033b3 --- /dev/null +++ b/src/benchmarks/blowup.py @@ -0,0 +1,62 @@ +# Copyright 2018-2019 Florian Fischer <florian.fl.fischer@fau.de> +# +# This file is part of allocbench. +# +# allocbench 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 3 of the License, or +# (at your option) any later version. +# +# allocbench 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 allocbench. If not, see <http://www.gnu.org/licenses/>. + +"""Definition of the blowup micro benchmark""" + +from src.benchmark import Benchmark + + +class BenchmarkBlowup(Benchmark): + """Blowup micro benchmark + + Check if allocators reuse memory. + Thread behaviour: + 1. Do many allocations and frees (100MiB is the maximum of live allocations at all times) + 2. Start new thread + 3. Join new thread + A perfect reusing allocator would need 100MiB RSS and a non reusing allocator + would need 1GiB. + """ + def __init__(self): + name = "blowup" + + self.cmd = "blowup" + + self.requirements = ["blowup"] + super().__init__(name) + + def summary(self): + # hack ideal rss in data set + allocators = self.results["allocators"] + allocators["Ideal_RSS"] = {"color": "C" + str(len(allocators) + 1)} + self.results["stats"]["Ideal_RSS"] = {} + for perm in self.iterate_args(args=self.results["args"]): + self.results["stats"]["Ideal_RSS"][perm] = {"mean": {"VmHWM": 1024 * 100}, + "std" : {"VmHWM": 0}} + + self.barplot_single_arg("{VmHWM}", + ylabel='"VmHWM in KB"', + title='"realloc micro benchmark"', + filepostfix="vmhwm") + + del allocators["Ideal_RSS"] + del self.results["stats"]["Ideal_RSS"] + + self.export_stats_to_dataref("VmHWM") + + +blowup = BenchmarkBlowup() diff --git a/src/benchmarks/blowup/Makefile b/src/benchmarks/blowup/Makefile new file mode 100644 index 0000000..afb5f2a --- /dev/null +++ b/src/benchmarks/blowup/Makefile @@ -0,0 +1,25 @@ +OBJDIR ?= obj + +CC ?= gcc + +WARNFLAGS ?= -Wall -Wextra +COMMONFLAGS ?= -fno-builtin -fPIC -DPIC -pthread +OPTFLAGS ?= -O3 -DNDEBUG + +CFLAGS ?= $(OPTFLAGS) $(WARNFLAGS) $(COMMONFLAGS) + +LDFLAGS ?= -pthread -static-libgcc + +.PHONY = all clean + +all: $(OBJDIR)/blowup + +$(OBJDIR)/blowup: blowup.c | $(OBJDIR) + @echo compiling $@... + $(CC) $(LDFLAGS) $(CFLAGS) -o $@ $< + +$(OBJDIR): + mkdir -p $@ + +clean: + rm -rf $(OBJDIR) diff --git a/src/benchmarks/blowup/blowup.c b/src/benchmarks/blowup/blowup.c new file mode 100644 index 0000000..defb58c --- /dev/null +++ b/src/benchmarks/blowup/blowup.c @@ -0,0 +1,90 @@ +#include <pthread.h> +#include <stdio.h> +#include <stdlib.h> +#include <string.h> + +#define NUM_THREADS 10 +#define ALLOCATIONS 1024 * 100 +#define SIZE 1024 + +static void do_work() +{ + void** ptrs; + + ptrs = malloc(sizeof(void*) * ALLOCATIONS); + if (ptrs == NULL) { + perror("malloc"); + return; + } + + for(int i = 0; i < ALLOCATIONS; i++) + { + ptrs[i] = malloc(SIZE); + memset(ptrs[i], 0, SIZE); + } + + for(int i = 0; i < ALLOCATIONS; i++) + { + free(malloc(SIZE)); + } + + for(int i = 0; i < ALLOCATIONS; i++) + { + /* memset(ptrs[i], 0, SIZE); */ + free(ptrs[i]); + } + + for(int i = 0; i < ALLOCATIONS; i++) + { + free(malloc(SIZE)); + } + + return; +} + +static void* thread_func(void* arg) +{ + unsigned int* thread_id = (unsigned int*)arg; + pthread_t next_thread; + + printf("thread %d doing work\n", *thread_id); + do_work(); + + if (*thread_id == NUM_THREADS) + return NULL; + + printf("thread %d spawning new thread work\n", *thread_id); + *thread_id = (*thread_id) + 1; + if (0 != pthread_create(&next_thread, NULL, thread_func, arg)) { + perror("pthread_create"); + return NULL; + } + + printf("thread %d joining thread %d work\n", *thread_id-1, *thread_id); + if (0 != pthread_join(next_thread, NULL)) { + perror("pthread_join"); + return NULL; + } + + return NULL; +} + +int main() +{ + unsigned int thread_count = 0; + pthread_t first; + + do_work(); + + if (0 != pthread_create(&first, NULL, thread_func, &thread_count)) { + perror("pthread_create"); + return 1; + } + + if (0 != pthread_join(first, NULL)) { + perror("pthread_join"); + return 1; + } + + return 0; +} |