// -*- C++ -*-
#define N 10
#define M 5

generic main()
{
  stream long A1;
  stream long B1;

  genera(output_stream A1);  
  p_array(input_stream A1 output_stream B1);
  fine1(input_stream B1);
}


genera(output_stream long A1) {
  fgen(output_stream A1);
}


proc fgen(output_stream long A1)
inc<"iostream">
$c++{
  long a;
  
  // start regression test
  std::cerr << "STARTING gen" << std::endl;

  for (int i=0;i<N;i++) {
    a = i;
    assist_out(A1, a);
  };
}c++$


parmod p_array (input_stream long A1 output_stream long B1) {
  topology array[i:M] Pv;
  attribute long z;

  do input_section {
    guard1: on , , A1 {
      distribution A1 broadcast to Pv;
      operation {
	z = z + 1;
      }<use {z}>
    }
  } while (true)
  
  virtual_processors {
    elab1 (in guard1 out B1) {
      VP i {
	f_p1 (in A1 output_stream B1);
      }
    }
  }
   
  output_section {
    collects B1 from ANY Pv;
  } 
}


fine1(input_stream long B1)
 
inc<"iostream">
$c++{
  static int count = 0;
  static int ok = 0;

  //std::cerr << "Fine -> ricevuto B1 = " << B1 <<std::endl;
  
  // verify result
  long b;

  if (B1 != ((int)(count/M))) ok = -1;
  count++;

  // end of regression test
  if (count >= N*M) {  
    if (ok==0) 
      std::cerr << "ENDING with SUCCESS fine parmod.ast" << std::endl;
    else std::cerr << "ENDING with FAILURE fine parmod.ast" << std::endl;
  }
}c++$


proc f_p1(in long A1 output_stream long B1)
 
inc<"iostream">
$c++{
  long b = A1;
  assist_out(B1,b);
}c++$