Changeset 582 for trunk/user

Timestamp:

Oct 11, 2018, 5:04:28 PM (6 years ago)

Author:

alain

Message:

New DQDT implementation supporting missing clusters
thanks to the cluster_info[x][y] array.

File:

• trunk/user/fft/fft.c (modified) (8 diffs)

trunk/user/fft/fft.c

@@ -89 +89 @@
 #define MODE                    COSIN
 #define CHECK                   0
-#define DEBUG_MAIN              0               // trace main() function (detailed if odd)
-#define DEBUG_FFT1D             0               // trace FFT1D() function (detailed if odd)
+#define DEBUG_MAIN              1               // trace main() function (detailed if odd)
+#define DEBUG_FFT1D             1               // trace FFT1D() function (detailed if odd)
 #define DEBUG_ROW               0               // trace FFTRow() function (detailed if odd)
 #define PRINT_ARRAY             0
@@ -300 +300 @@
     }
 
-    printf("\n[FFT] main complete remote_malloc\n");
+    printf("\n[FFT] main completes remote_malloc\n");
 
     // arrays initialisation
@@ -307 +307 @@
     InitT( twid );
 
-    printf("\n[FFT] main complete init arrays\n");
+    printf("\n[FFT] main complete arrays init\n");
 
 #if CHECK 
@@ -326 +326 @@
 #endif
 
-    // initialise distributed barrier
+    // initialise barrier
     barrierattr.x_size   = x_size;
     barrierattr.y_size   = y_size;
@@ -346 +346 @@
             for ( lid = 0 ; lid < ncores ; lid++ )
             {
-                // compute thread continuous index
+                // compute thread user index (continuous index)
                 tid = (((x * y_size) + y) * ncores) + lid;
 
@@ -365 +365 @@
                                          &args[tid]) ) // pointer on function arguments 
                     {
-                        printf("\n[FFT ERROR] creating thread %x\n", trdid[tid] );
+                        printf("\n[FFT ERROR] creating thread %x\n", tid );
                         exit( 0 );
                     }
 #if DEBUG_MAIN 
-printf("\n[FFT] main created thread %x\n", trdid[tid] );
+printf("\n[FFT] main created thread %x on core %d in cluster(%d,%d) \n", tid, lid, x, y );
 #endif
                 }
@@ -497 +497 @@
     MyNum = *tid;
 
-    // get 
+    // BARRIER before parallel exec
+    pthread_barrier_wait( &barrier );
+
     // initialise instrumentation
     get_cycle( &parallel_start );
@@ -607 +609 @@
 }  // end SimpleDft()
 
-/////////////////
+///////////////////////
 double CheckSum( void )
 {