# HG changeset patch
# User Merten Sach <msach@mailbox.tu-berlin.de>
# Date 1317199454 -7200
# Node ID 53dd2334f1367b53b8ee6db433e1316cfd6b4fce
# Parent  0ce47c784647203de67e8e8ad5f1e438f004f47a
Working SSR version

diff -r 0ce47c784647 -r 53dd2334f136 kmeans
Binary file kmeans has changed
diff -r 0ce47c784647 -r 53dd2334f136 kmeans.c
--- a/kmeans.c	Tue Sep 27 15:08:02 2011 +0200
+++ b/kmeans.c	Wed Sep 28 10:44:14 2011 +0200
@@ -134,7 +134,7 @@
             break;
         else
             work(x, VProc);
-    }
+    }        
     
     SSR__dissipate_procr(VProc);
 }
@@ -261,8 +261,7 @@
         ip[i].numClusters=numClusters;
         ip[i].numCoords=numCoords;
 
-        if(i!=0)
-            tasks[i] = SSR__create_procr_with(tfwork, (void*)&ip[i], VProc);
+        tasks[i] = SSR__create_procr_with(tfwork, (void*)&ip[i], VProc);
     }
     
 	/* === COMPUTATIONAL PHASE === */
@@ -270,18 +269,13 @@
     do {
         delta = 0.0;
         
-        printf("start children 1\n");
         for(i=0; i<nthreads; i++)
             SSR__send_from_to((void*)&syncMsg, VProc, tasks[i]);
         
         //let the children do the work
         
-        printf("receive results\n");
         for(i=0; i<nthreads; i++)
             delta += *(double*)SSR__receive_from_to(tasks[i],VProc);
-        printf("start children 2\n");
-        for(i=1; i<nthreads; i++)
-            SSR__send_from_to((void*)&syncMsg, VProc, tasks[i]);
         
 		/* Let the main thread perform the array reduction */
 		for (i = 0; i < numClusters; i++) {