// -*- C++ -*-
 
 

#define N 10
#define MAX_ITER 10  
#define FILE_OUT "/tmp/risultato.txt"


/* ------------------------------------------------------------ */
/* 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<"iostream">
$c++{
  T_cart tmp_A[N];

  // messaggio di partenza x il regression test
  std::cerr << "STARTING gen" << std::endl;
  
  for (int k=0; k<MAX_ITER; k++) {
    for (int 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 out B);
      }
    }
  }
 
  output_section {
    collects B from ANY Pv;
  } 
}


stampa (input_stream T_cart B[N])
 
inc<"iostream","fstream">
$c++{
  std::ofstream f;
  static int file_aperto = -1;
  static int count = 0;
  static int ok = 0;

  if (file_aperto == -1) {
    f.open (FILE_OUT);
    file_aperto = 0;
  }
  
  for(int i=0; i<N; i++)
    f << B[i].x << " " << B[i].y << std::endl;
  f << std::endl << std::endl;

  // verifica del risultato
  for (int i=0; i<N; i++) {
    if (B[i].y != -((int)(i+(count/MAX_ITER)))) ok = -1;
    if (B[i].x != ((int)((i+(count/MAX_ITER)) * (i+(count/MAX_ITER))))) ok = -1;
  }
    
  count++;
  
  if (count >= MAX_ITER) {
    f.close();
    
    // messaggio di terminazione x il regression test
    if (ok==0) 
      std::cerr << "ENDING with SUCCESS pipeline.ast --> stampa su file " << FILE_OUT << std::endl;
    else 
      std::cerr << "ENDING with FAILURE pipeline.ast --> stampa su file " << FILE_OUT << std::endl;
  }
}c++$


proc Felab (in T_cart A[N] out T_cart B[N])
 
inc<"iostream">
$c++{
  static int count= 0;
  //std::cerr << " Felab " << count++ << std::endl;
  
  for (int i=0; i<N; i++) {
    B[i].x = A[i].y;
    B[i].y = -A[i].x;
  }
}c++$