Forráskód Böngészése

Show parallelism in commute test

Samuel Thibault 10 éve
szülő
commit
788f2cb674
1 módosított fájl, 12 hozzáadás és 2 törlés
  1. 12 2
      tests/datawizard/testCommute.cpp

+ 12 - 2
tests/datawizard/testCommute.cpp

@@ -40,16 +40,26 @@
 #include <vector>
 #include <vector>
 #include <unistd.h>
 #include <unistd.h>
 
 
+static unsigned nb, nb_slow;
+
 void callback(void * /*buffers*/[], void * /*cl_arg*/)
 void callback(void * /*buffers*/[], void * /*cl_arg*/)
 {
 {
+	unsigned val;
+	val = STARPU_ATOMIC_ADD(&nb, 1);
+	FPRINTF(stdout,"callback in (%d)\n", val); fflush(stdout);
 	usleep(SLEEP_FAST);
 	usleep(SLEEP_FAST);
-	FPRINTF(stdout,"COMMUTE_LOG] callback\n"); fflush(stdout);
+	val = STARPU_ATOMIC_ADD(&nb, -1);
+	FPRINTF(stdout,"callback out (%d)\n", val); fflush(stdout);
 }
 }
 
 
 void callback_slow(void * /*buffers*/[], void * /*cl_arg*/)
 void callback_slow(void * /*buffers*/[], void * /*cl_arg*/)
 {
 {
+	unsigned val;
+	val = STARPU_ATOMIC_ADD(&nb_slow, 1);
+	FPRINTF(stdout,"callback_slow in (%d)\n", val); fflush(stdout);
 	usleep(SLEEP_SLOW);
 	usleep(SLEEP_SLOW);
-	FPRINTF(stdout,"COMMUTE_LOG] callback_slow\n"); fflush(stdout);
+	val = STARPU_ATOMIC_ADD(&nb_slow, -1);
+	FPRINTF(stdout,"callback_slow out (%d)\n", val); fflush(stdout);
 }
 }