/

2008-05-30  Neal H. Walfield  <neal@gnu.org>

	* benchmarks: New directory.
	* configure.ac: Generate benchmarks/Makefile and
	benchmarks/boehm-gc/Makefile.
	* Makefile.am (SUBDIRS): Add benchmarks.

benchmarks/

2008-05-30  Neal H. Walfield  <neal@gnu.org>

	* Makefile.am: New file.
	* activity-distribution.c: Likewise.
	* shared-memory-distribution.c: Likewise.
	* boehm-gc: New directory.

benchmarks/boehm-gc/

2008-05-30  Neal H. Walfield  <neal@gnu.org>

	* Makefile.am: New file.
	* pathches: New directory.
	* patches/01-gc-include-private-gcconfig-h.patch: New file.
	* patches/02-gc-mach_dep-c.patch: New file.

1 files changed, 148 insertions, 0 deletions

diff --git a/benchmarks/shared-memory-distribution.c b/benchmarks/shared-memory-distribution.c
new file mode 100644
index 0000000..22a046a
--- /dev/null
+++ b/benchmarks/shared-memory-distribution.c
@@ -0,0 +1,148 @@
+#include <stdbool.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <sys/mman.h>
+#include <errno.h>
+#include <string.h>
+#include <pthread.h>
+
+#include <hurd/activity.h>
+#include <hurd/storage.h>
+#include <hurd/startup.h>
+
+static addr_t activity;
+
+/* Initialized by the machine-specific startup-code.  */
+extern struct hurd_startup_data *__hurd_startup_data;
+
+int
+main (int argc, char *argv[])
+{
+  extern int output_debug;
+  output_debug = 1;
+
+  activity = __hurd_startup_data->activity;
+
+#define PAGES 1000
+
+  /* Allocate the buffer.  */
+  void *buffer = mmap (0, PAGESIZE * PAGES, PROT_READ | PROT_WRITE,
+		       MAP_PRIVATE | MAP_ANONYMOUS, -1, 0);
+  if (buffer == MAP_FAILED)
+    {
+      printf ("Failed to allocate memory: %s\n", strerror (errno));
+      return 1;
+    }
+
+#define THREADS 3
+  /* And the activities.  */
+  addr_t activities[THREADS];
+
+  int i;
+  for (i = 0; i < THREADS; i ++)
+    activities[i] = storage_alloc (activity, cap_activity,
+				   STORAGE_LONG_LIVED,
+				   OBJECT_POLICY_DEFAULT,
+				   ADDR_VOID).addr;
+
+  bool terminate = false;
+  l4_thread_id_t tids[THREADS];
+  for (i = 0; i < THREADS; i ++)
+    tids[i] = l4_nilthread;
+
+  void *worker (void *arg)
+  {
+    int w = (intptr_t) arg;
+
+    tids[w] = l4_myself ();
+
+    pthread_setactivity_np (activities[w]);
+
+    uintptr_t t = 0;
+    int count = 0;
+    while (! terminate)
+      {
+	uintptr_t *p = buffer + (rand () % PAGES) * PAGESIZE;
+	t = *p;
+
+	count ++;
+	if (count % 100000 == 0)
+	  debug (0, DEBUG_BOLD ("Read %d pages so far"), count);
+
+	l4_thread_switch (tids[rand () % THREADS]);
+      }
+
+    printf ("Thread %d: %d operations\n", w, count);
+
+    /* We need to return t, otherwise, the above loop will be
+       optimized away.  */
+    return (void *) t;
+  }
+
+  /* Start the threads.  */
+  pthread_t threads[THREADS];
+
+  error_t err;
+  for (i = 0; i < THREADS; i ++)
+    {
+      err = pthread_create (&threads[i], NULL, worker, (intptr_t) i);
+      if (err)
+	printf ("Failed to create thread: %s\n", strerror (errno));
+    }
+
+#define ITERATIONS 100
+  struct activity_stats stats[ITERATIONS][1 + THREADS];
+
+  uintptr_t next_period = 0;
+  for (i = 0; i < ITERATIONS; i ++)
+    {
+      debug (0, DEBUG_BOLD ("starting iteration %d (%x)"), i, l4_myself ());
+
+      int count;
+      struct activity_stats_buffer buffer;
+
+      rm_activity_stats (activity, next_period, &buffer, &count);
+      assert (count > 0);
+      if (i != 0)
+	assert (buffer.stats[0].period != stats[i - 1][0].period);
+
+      stats[i][0] = buffer.stats[0];
+
+      int j;
+      for (j = 0; j < THREADS; j ++)
+	{
+	  rm_activity_stats (activities[j], next_period, &buffer, &count);
+	  assert (count > 0);
+	  stats[i][1 + j] = buffer.stats[0];
+	}
+
+      next_period = buffer.stats[0].period + 1;
+    }
+
+  terminate = true;
+  for (i = 0; i < THREADS; i ++)
+    {
+      void *status;
+      pthread_join (threads[i], &status);
+    }
+
+  printf ("parent ");
+  for (i = 0; i < THREADS; i ++)
+    printf (ADDR_FMT " ", ADDR_PRINTF (activities[i]));
+  printf ("\n");
+
+  for (i = 0; i < ITERATIONS; i ++)
+    {
+      int j;
+
+      printf ("%d ", (int) stats[i][0].period);
+
+      for (j = 0; j < 1 + THREADS; j ++)
+	printf ("%d ", (int) stats[i][j].clean + (int) stats[i][j].dirty);
+      printf ("\n");
+    }
+
+  printf ("Done!\n");
+
+  return 0;
+}