shithub: bench9

Download patch

ref: 03bf5f5359c5a4919b97bc5f7843341f4a43f42d
parent: a7f13757d67c3169a938c95d2db667d1bd4ee407
author: Sigrid Solveig Haflínudóttir <[email protected]>
date: Sun Nov 1 10:54:33 EST 2020

change benchmarks, grouping

--- a/b.c
+++ b/b.c
@@ -54,7 +54,7 @@
 	return fmtprint(f,	"%zd", c.ns);
 }
 
-void
+B *
 benchinit(B *b, char *name)
 {
 	Res r;
@@ -84,8 +84,57 @@
 		}
 		adj = v / i;
 	}
+
+	return b;
 }
 
+B *
+benchadd(Bgr *gr, char *name)
+{
+	B **gb, *b;
+
+	if((gb = realloc(gr->b, (gr->nb+1)*sizeof(b))) == nil)
+		return nil;
+	gr->b = gb;
+	if((b = malloc(sizeof(*b)+strlen(name)+1)) == nil)
+		return nil;
+	gr->b[gr->nb++] = b;
+
+	return benchinit(b, strcpy((char*)(b+1), name));
+}
+
+Bgr *
+benchinitgr(Bgr *gr, char *name)
+{
+	gr->name = name;
+	gr->b = nil;
+	gr->nb = 0;
+
+	return gr;
+}
+
+void
+benchprintgr(Bgr *gr, int fd)
+{
+	fprint(fd, "%s\n", gr->name);
+	benchprint(gr->b, gr->nb, fd);
+}
+
+void
+benchfreegr(Bgr *gr)
+{
+	int i;
+
+	for(i = 0; i < gr->nb; i++)
+		free(gr->b[i]);
+}
+
+void
+bseparator(int fd)
+{
+	fprint(fd, "\n");
+}
+
 static int
 ccmp(void *a, void *b)
 {
@@ -124,6 +173,9 @@
 {
 	uvlong c;
 
+	if(b->n < 1)
+		return;
+
 	if(b->step == 0)
 		b->t0 = b->tin;
 	b->step++;
@@ -156,7 +208,7 @@
 }
 
 void
-benchprint(B *b, int nb, int fd)
+benchprint(B **b, int nb, int fd)
 {
 	static char *header[] = {"   ", "op/s", "98%", "96%", "75%", "med", "avg", "min", "max"};
 	static int w[] = {16, 8, 8, 8, 8, 8, 8, 8, 8};
@@ -175,10 +227,10 @@
 	int i, j, n, x;
 
 	for(i = 0; i < nb; i++){
-		w[0] = MAX(w[0], snprint(t, sizeof(t), "%s  ", b[i].name ? b[i].name : ""));
-		w[1] = MAX(w[1], snprint(t, sizeof(t), "%σ  ", &b[i]));
+		w[0] = MAX(w[0], snprint(t, sizeof(t), "%s  ", b[i]->name ? b[i]->name : ""));
+		w[1] = MAX(w[1], snprint(t, sizeof(t), "%σ  ", b[i]));
 		for(j = 2; j < nelem(header); j++)
-			w[j] = MAX(w[j], snprint(t, sizeof(t), "%τ  ", *(Cns*)((char*)(b+i) + off[j])));
+			w[j] = MAX(w[j], snprint(t, sizeof(t), "%τ  ", *(Cns*)((char*)b[i] + off[j])));
 	}
 
 	for(j = n = 0; j < nelem(header); j++)
@@ -195,16 +247,33 @@
 	for(i = 0; i < nb; i++){
 		memset(s, ' ', n);
 		p = s;
-		p[sprint(p, "%s  ", b[i].name)] = ' ';
+		p[sprint(p, "%s  ", b[i]->name)] = ' ';
 		p += w[0];
-		x = snprint(t, sizeof(t), "%σ  ", b+i);
+		x = snprint(t, sizeof(t), "%σ  ", b[i]);
 		memmove(p+w[1]-x, t, x);
 		p += w[1];
 		for(j = 2; j < nelem(header); p += w[j], j++){
-			x = snprint(t, sizeof(t), "%τ  ", *(Cns*)((char*)(b+i) + off[j]));
+			x = snprint(t, sizeof(t), "%τ  ", *(Cns*)((char*)b[i] + off[j]));
 			memmove(p+w[j]-x, t, x);
 		}
 		*p = 0;
 		fprint(fd, "%s\n", s);
 	}
+}
+
+int
+benchwire(int cpu)
+{
+	char t[64];
+	int r, f;
+
+	r = -1;
+	snprint(t, sizeof(t), "/proc/%d/ctl", getpid());
+	if((f = open(t, OWRITE)) >= 0){
+		if(fprint(f, "wired %d\n", cpu) >= 8)
+			r = 0;
+		close(f);
+	}
+
+	return r;
 }
--- a/b.h
+++ b/b.h
@@ -1,6 +1,13 @@
 typedef struct B B;
+typedef struct Bgr Bgr;
 typedef struct Cns Cns;
 
+enum {
+	Kb = 1024ULL,
+	Mb = 1024ULL*1024ULL,
+	Gb = 1024ULL*1024ULL*1024ULL,
+};
+
 struct Cns {
 	uvlong c;
 	uvlong ns;
@@ -22,6 +29,12 @@
 	char *name;
 };
 
+struct Bgr {
+	char *name;
+	B **b;
+	int nb;
+};
+
 /* private */
 void benchstep(B *b);
 void tstart(uvlong *c);
@@ -28,7 +41,15 @@
 extern void (*tend)(uvlong *c);
 
 /* public */
-void benchinit(B *b, char *name);
-void benchprint(B *b, int nb, int fd);
+int benchwire(int cpu);
+
+Bgr *benchinitgr(Bgr *gr, char *name);
+B *benchadd(Bgr *gr, char *name);
 #define benchin(b) do{ tstart(&(b)->tin); }while(0)
 #define benchout(b) do{ tend(&(b)->tout); benchstep(b); }while(0)
+void benchprintgr(Bgr *gr, int fd);
+void benchfreegr(Bgr *gr);
+void bseparator(int fd);
+
+B *benchinit(B *b, char *name);
+void benchprint(B **b, int nb, int fd);
--- a/main.c
+++ b/main.c
@@ -4,109 +4,113 @@
 #include "b.h"
 
 static void
-proc(void *)
+bmallocfree(int out)
 {
-	threadexits(nil);
-}
+	Bgr g;
+	B *bm, *bf;
+	int sz[] = {
+		{0},
+		{1},
+		{16},
+		{64},
+		{256},
+		{1*Kb},
+		{4*Kb},
+		{64*Kb},
+		{1*Mb},
+		{2*Mb},
+		{4*Mb},
+	};
+	int i;
+	void *ptr;
+	char t[32];
 
-void
-threadmain(int argc, char **argv)
-{
-	B *group, *b;
-	uchar d[1];
-	char t[64];
-	int f;
+	benchinitgr(&g, "malloc & free");
+	for(i = 0; i < nelem(sz); i++){
+		snprint(t, sizeof(t), "malloc/%d", sz[i]);
+		bm = benchadd(&g, t);
+		snprint(t, sizeof(t), "free/%d", sz[i]);
+		bf = benchadd(&g, t);
 
-	ARGBEGIN{
-	}ARGEND
+		for(; bm->n > 0 || bf->n > 0;){
+			benchin(bm);
+			ptr = malloc(sz[i]);
+			benchout(bm);
 
-	snprint(t, sizeof(t), "/proc/%d/ctl", getpid());
-	if((f = open(t, OWRITE)) < 0)
-		fprint(2, "%r\n");
-	else{
-		if(write(f, "wired 0\n", 8) != 8)
-			fprint(2, "failed to wire\n");
-		close(f);
+			benchin(bf);
+			free(ptr);
+			benchout(bf);
+		}
 	}
 
-	b = group = malloc(32 * sizeof(*b));
+	benchprintgr(&g, out);
+	benchfreegr(&g);
+}
 
-	f = open("/dev/null", OREAD);
-	benchinit(b, "read/1");
-	while(b->n > 0){
-		benchin(b);
-		read(f, d, 1);
-		benchout(b);
-	}
+static void
+bzeronull(int out)
+{
+	Bgr g;
+	B *br, *bw;
+	int sz[] = {
+		{0},
+		{1},
+		{64*Kb},
+		{1*Mb},
+		{2*Mb},
+		{4*Mb},
+		{16*Mb},
+		{64*Mb},
+	};
+	int i, zero, null;
+	void *ptr;
+	char t[32];
 
-	b++;
-	benchinit(b, "read/0");
-	while(b->n > 0){
-		benchin(b);
-		read(f, d, 0);
-		benchout(b);
-	}
-	close(f);
+	ptr = malloc(sz[nelem(sz)-1]);
+	if((zero = open("/dev/zero", OREAD)) < 0)
+		sysfatal("%r");
+	if((null = open("/dev/null", OWRITE)) < 0)
+		sysfatal("%r");
+	benchinitgr(&g, "/dev/zero → /dev/null");
+	for(i = 0; i < nelem(sz); i++){
+		snprint(t, sizeof(t), "read/%d", sz[i]);
+		br = benchadd(&g, t);
+		snprint(t, sizeof(t), "write/%d", sz[i]);
+		bw = benchadd(&g, t);
 
-	b++;
-	benchinit(b, "sin(n)");
-	while(b->n > 0){
-		benchin(b);
-		sin(b->n);
-		benchout(b);
-	}
+		for(; br->n > 0 || bw->n > 0;){
+			benchin(br);
+			if(readn(zero, ptr, sz[i]) != sz[i])
+				sysfatal("/dev/zero: readn");
+			benchout(br);
 
-	b++;
-	benchinit(b, "cos(n)");
-	while(b->n > 0){
-		benchin(b);
-		cos(b->n);
-		benchout(b);
+			benchin(bw);
+			if(write(null, ptr, sz[i]) != sz[i])
+				sysfatal("/dev/null: write");
+			benchout(bw);
+		}
 	}
 
-	b++;
-	benchinit(b, "tan(n)");
-	while(b->n > 0){
-		benchin(b);
-		tan(b->n);
-		benchout(b);
-	}
+	benchprintgr(&g, out);
+	benchfreegr(&g);
 
-	b++;
-	benchinit(b, "sleep(0)");
-	while(b->n > 0){
-		benchin(b);
-		sleep(0);
-		benchout(b);
-	}
+	close(zero);
+	close(null);
+	free(ptr);
+}
 
-	b++;
-	benchinit(b, "sleep(5)");
-	while(b->n > 0){
-		benchin(b);
-		sleep(5);
-		benchout(b);
-	}
+void
+threadmain(int argc, char **argv)
+{
+	ARGBEGIN{
+	}ARGEND
 
-	b++;
-	benchinit(b, "sleep(10)");
-	while(b->n > 0){
-		benchin(b);
-		sleep(10);
-		benchout(b);
-	}
+	if(benchwire(0) != 0)
+		fprint(2, "failed to wire: %r\n");
 
-	b++;
-	benchinit(b, "proccreate");
-	while(b->n > 0){
-		benchin(b);
-		proccreate(proc, (void*)b->n, 1024);
-		benchout(b);
-	}
-
-	b++;
-
-	benchprint(group, b-group, 1);
+	bmallocfree(1);
+	bseparator(1);
+	bzeronull(1);
 
 	threadexitsall(nil);
 }