2 files changed, 41 insertions, 1 deletions

diff --git a/SConstruct b/SConstruct
index 7d0525d..85deeec 100644
--- a/SConstruct
+++ b/SConstruct
@@ -191,7 +191,7 @@ pmpy.Replace(LINKFLAGS = '')
 # Preemption and migration overhead analysis
 
 pmrt.Program('pm_task', ['bin/pm_task.c', 'bin/pm_common.c'])
-
+pmrt.Program('pm_polluter', ['bin/pm_polluter.c', 'bin/pm_common.c'])
 # #####################################################################
 # Additional Help
 
diff --git a/bin/pm_polluter.c b/bin/pm_polluter.c
new file mode 100644
index 0000000..db63b48
--- /dev/null
+++ b/bin/pm_polluter.c
@@ -0,0 +1,40 @@
+/*
+ * pm_be_polluter.c
+ *
+ * Best Effort Cache Polluter Task
+ */
+#include "pm_common.h"
+#include "pm_arch.h"
+#include "asm.h"
+
+int mem_block[NUMWS][INTS_PER_WSS] __attribute__ ((aligned(CACHEALIGNMENT)));
+
+int main(int argc, char **argv)
+{
+        int read, *loc_ptr;
+
+        memset(&mem_block, 0, sizeof(int) * NUMWS * INTS_PER_WSS);
+
+        /* Initialize random library for read/write ratio enforcement. */
+        srandom(SEEDVAL);
+
+        while(1) {
+                read = (random() % 100) < READRATIO;
+                loc_ptr = &mem_block[random() % NUMWS][0];
+                loc_ptr += (random() % INTS_PER_WSS);
+
+                barrier();
+
+                if (read)
+                        read_mem(loc_ptr);
+                else
+                        write_mem(loc_ptr);
+
+                /* FIXME is really needed? */
+                usleep(40);
+        }
+
+        /* never reached */
+        return 0;
+}
+