Changeset 712 for soft/giet_vm/applications/gameoflife/gameoflife.c

Timestamp:

Oct 7, 2015, 11:56:33 AM (9 years ago)

Author:

alain

Message:

Introduce the giet_fbf_size() and giet_fbf_alloc() system calls.

File:

• soft/giet_vm/applications/gameoflife/gameoflife.c (modified) (13 diffs)

soft/giet_vm/applications/gameoflife/gameoflife.c

@@ -6 +6 @@
 //////////////////////////////////////////////////////////////////////////////////
 // This multi-threaded application is an emulation of the Game of Life automaton.
-// The world size is defined by the HEIGHT and WIDTH parameters.
+// The world size is defined by the Frame Buffer width and height.
 //
 // There is at most one thread per processor in the platform.
@@ -14 +14 @@
 // - if the number of processors is not larger than the number of lines,
 //   the number of threads is equal to the number of processors, and
-//   each thread process HEIGHT/nthreads (or HEIGHT/nthreads + 1) lines.
+//   each thread process height/nthreads (or height/nthreads + 1) lines.
 // 
 // Thread running on processor P(0,0,0) execute the main() function,
@@ -31 +31 @@
 #include "malloc.h"
 
-#define WIDTH           FBUF_X_SIZE
-#define HEIGHT          FBUF_Y_SIZE
-
 #define VERBOSE         1
 
@@ -46 +43 @@
 arguments_t   args[1024];     // at most 1024 threads 
 
-uint8_t world[2][HEIGHT][WIDTH] __attribute__((aligned(64)));
-
-uint8_t display[2][HEIGHT][WIDTH] __attribute__((aligned(64)));
-
-unsigned int status0[16];
-unsigned int status1[16];
+uint8_t world[2][256][256] __attribute__((aligned(64)));
+
+uint8_t display[2][256][256] __attribute__((aligned(64)));
+
+unsigned int status0[16] __attribute__((aligned(64)));
+unsigned int status1[16] __attribute__((aligned(64)));
 
 giet_sqt_barrier_t barrier;
+
+unsigned int width;
+unsigned int height;
 
 ////////////////////////////////////
@@ -63 +63 @@
    for (y = base_line ; y < base_line + nb_line ; y++)
    {
-      for(x = 0 ; x < WIDTH ; x++) 
+      for(x = 0 ; x < width ; x++) 
       {
          world[phase][y][x] = (giet_rand() >> (x % 8)) & 0x1;
@@ -77 +77 @@
    uint8_t nb = 0;
 
-   nb += world[phase][(y - 1) % HEIGHT][(x - 1) % WIDTH];
-   nb += world[phase][ y              ][(x - 1) % WIDTH];
-   nb += world[phase][(y + 1) % HEIGHT][(x - 1) % WIDTH];
-   nb += world[phase][(y - 1) % HEIGHT][ x             ];
-   nb += world[phase][(y + 1) % HEIGHT][ x             ];
-   nb += world[phase][(y - 1) % HEIGHT][(x + 1) % WIDTH];
-   nb += world[phase][ y              ][(x + 1) % WIDTH];
-   nb += world[phase][(y + 1) % HEIGHT][(x + 1) % WIDTH];
+   nb += world[phase][(y - 1) % height][(x - 1) % width];
+   nb += world[phase][ y              ][(x - 1) % width];
+   nb += world[phase][(y + 1) % height][(x - 1) % width];
+   nb += world[phase][(y - 1) % height][ x             ];
+   nb += world[phase][(y + 1) % height][ x             ];
+   nb += world[phase][(y - 1) % height][(x + 1) % width];
+   nb += world[phase][ y              ][(x + 1) % width];
+   nb += world[phase][(y + 1) % height][(x + 1) % width];
 
    return nb;
@@ -116 +116 @@
    for (y = base_line; y < base_line + nb_line; y++)
    {
-      for(x = 0; x < WIDTH ; x++) 
+      for(x = 0; x < width ; x++) 
       {
          world[phase][y][x] = compute_cell( 1 - phase , x , y );  
@@ -131 +131 @@
    for (y = base_line; y < base_line + nb_line; y++)
    {
-      for(x = 0; x < WIDTH ; x++) 
+      for(x = 0; x < width ; x++) 
       {
          display[phase][y][x] = world[phase][y][x]*255;  
@@ -224 +224 @@
    giet_procs_number( &x_size, &y_size, &nprocs );
 
+   // get a shared TTY 
+   giet_tty_alloc( 1 );
+
    giet_pthread_assert( (x_size <= 16) , "x_size no larger than 16" );
    giet_pthread_assert( (y_size <= 16) , "y_size no larger than 16" );
-   giet_pthread_assert( (nprocs <=  4) , "nprocs no larger than 16" );
+   giet_pthread_assert( (nprocs <=  4) , "nprocs no larger than 4" );
+
+   // get FBF width and height
+   giet_fbf_size( &width , &height );
+
+   giet_pthread_assert( (width  <= 256)   , "FBF width larger than 256" );
+   giet_pthread_assert( (height <= 256)   , "FBF height larger than 256" );
+   giet_pthread_assert( (width  && height) , "FBF not available" );
 
    // compute number of threads and min number of lines per thread
@@ -234 +244 @@
    unsigned int nlines;
    unsigned int extra;
-   if ( total_procs > HEIGHT )
-   {
-      nthreads = HEIGHT;
+   if ( total_procs > height )
+   {
+      nthreads = height;
       nlines   = 1;
       extra    = 0;
@@ -243 +253 @@
    {
       nthreads = total_procs;
-      nlines   = HEIGHT / total_procs;
-      extra    = HEIGHT % total_procs;  
-   }
-
-   // get a shared TTY 
-   giet_tty_alloc( 1 );
+      nlines   = height / total_procs;
+      extra    = height % total_procs;  
+   }
+
+   // get FBF ownership
+   giet_fbf_alloc();
 
    // get a Chained Buffer DMA channel
@@ -260 +270 @@
 
    // activates CMA channel
-   giet_fbf_cma_start( HEIGHT * WIDTH );
+   giet_fbf_cma_start( height * width );
 
    // initializes distributed heap
@@ -278 +288 @@
    giet_tty_printf("\n[GAMEOFLIFE] P[%d,%d,%d] completes initialisation at cycle %d\n"
                    " nprocs = %d / nlines = %d / nthreads = %d\n", 
-                   x, y, p, giet_proctime() , total_procs , HEIGHT , nthreads );
+                   x, y, p, giet_proctime() , total_procs , height , nthreads );
 
    // compute arguments (index, nlines) for all threads