// -*- C++ -*-
#define N 10
#define MAX_ITER 10

/* ------------------------------------------------------------ */
/* Test di pipeline semplice con un parmod none centrale        */
/* in cui le proc sono scritte in linguaggio C                  */ 
/* ------------------------------------------------------------ */

typedef struct
{
  long x;
  long y;
} T_cart;
 

generic main()
{
  stream T_cart[N] A;
  stream T_cart[N] B;

  genera    (output_stream A);
  elabora   (input_stream A output_stream B);
  stampa    (input_stream B);
} 


genera (output_stream T_cart A[N]) {
  Fgenera (output_stream A);
}


proc Fgenera (output_stream T_cart A[N])
inc<"stdio.h">
$c{
  int i, k;
  T_cart tmp_A[N];

  // messaggio di partenza x il regression test
  printf ("STARTING gen\n");
  
  for (k=0; k<MAX_ITER; k++) {
    for (i=0; i<N; i++) {
      tmp_A[i].x = i+(k/MAX_ITER);
      tmp_A[i].y = (i+(k/MAX_ITER)) * (i+(k/MAX_ITER));
    }
    assist_out (A, tmp_A);
  }
}c$ 



parmod elabora (input_stream T_cart A[N] output_stream T_cart B[N]) 
{
  topology none Pv;
  
  do input_section {
    guard1: on , , A {
      distribution A on_demand to Pv;
    }
  } while (true)
  
  virtual_processors {
    elab (in guard1 out B) {
      VP {
	Felab (in A output_stream B);
      }
    }
  }
 
  output_section {
    collects B from ANY Pv;
  } 
}


stampa (input_stream T_cart B[N])
inc<"stdio.h">
$c{
  int i;
  static int count = 0;
  static int ok = 0;

  /*
    for (i=0; i<N; i++) {
    printf("%d,%d - ",(*B)[i].x,(*B)[i].y);
    }
    printf("\n");
  */
  
  // verifica del risultato
  for (i=0; i<N; i++) {
    if ((*B)[i].y != -((int)(i+(count/MAX_ITER)))) {
      ok = -1;
      printf("B[%d].y = %d e il mio conto = %d\n", i, (*B)[i].y, 
	     ((int)(i+(count/MAX_ITER))));
    }
    if ((*B)[i].x != ((int)((i+(count/MAX_ITER)) * (i+(count/MAX_ITER))))) {
      ok = -1;
      printf("B[%d].x = %d e il mio conto = %d\n", i, (*B)[i].x, 
	     -((int)((i+(count/MAX_ITER)) * (i+(count/MAX_ITER)))));
    }
  }
    
  count++;
  
  if (count >= MAX_ITER) {
    // messaggio di terminazione x il regression test
    if (ok==0) 
      printf("ENDING with SUCCESS pipeline_C.ast\n");
    else 
      printf("ENDING with FAILURE pipeline_C.ast\n");
  }
}c$

proc Felab (in T_cart A[N] output_stream T_cart S[N])
inc<"stdio.h">
$c{
  int i;
  T_cart B[N];

  for (i=0; i<N; i++) {
    B[i].x = (*A)[i].y;
    B[i].y = -((*A)[i].x);
  }
  assist_out(S,B);
}c$