// -*- C++ -*-
#define N 10
#define K 1

generic main()
{
  stream ref_t A_rif;
  stream long fine;

  genera_A          (output_stream A_rif);
  prova_one         (input_stream A_rif  output_stream fine);
  end               (input_stream fine);
} 


genera_A (output_stream ref_t A_rif) {
  proc_genera_A (output_stream A_rif);
}


proc proc_genera_A (output_stream ref_t A_rif)
inc<"iostream">
$c++{ 
  int displ;
  int dim = N*N*sizeof(long);  // dimensione area allocata con i reference 
  int size = N*sizeof(long);
  ref_t ref_matrice;
  long riga_A[N];
  
  // messaggio di partenza x il regression test
  std::cerr << "STARTING gen" << std::endl;

  /* allocazione dell'area in memoria condivisa */ 
  REF_New (&ref_matrice, dim, REF_Default, 0);

  for (int i=0; i<N; i++) {
    /* lettura da file della riga i-esima */
    for(int j=0; j<N; j++)  
      riga_A[j] = j*i;

    displ = i*N*sizeof(long);
    
    /* scrittura in memoria condivisa della riga i-esima */
    REF_D_Write (&ref_matrice, riga_A, displ, size); 
  }
  assist_out (A_rif, ref_matrice);
}c++$



/* parmod per la generazione dello stream di righe */
parmod prova_one (input_stream ref_t A_rif  output_stream long fine) {

  topology one Pv;

  do input_section {
    guard1: on , , A_rif {
      distribution A_rif broadcast to Pv; 
    }
  } while (true)
 
  virtual_processors {
    elab_one (in guard1 out fine) {
      VP {
	proc_elab_one (in A_rif output_stream fine);
      }
    }
  }
 
  output_section {
    collects fine from ANY Pv;
  }  
}


proc proc_elab_one (in ref_t A_rif output_stream long fine)
inc<"iostream","cassert">
$c++{
  long tmp_fine = 1;
  long riga_C[N];
  int displ;
  int size = N * sizeof(long);

  for(int i=0; i<N; i++) {
    /* lettura della riga i-esima dalla memoria condivisa */
    displ = i * N * sizeof(long);
    REF_D_Read (&(A_rif), riga_C, displ, size); 
    for(int j=0;j<N;++j)
      assert(riga_C[j]==i*j);

    /* stampa a video della riga i-esima */
    
      for(int j=0; j<N; j++)
      std::cerr << riga_C[j] << " ";
      std::cerr << std::endl;
    
  }
  assist_out (fine, tmp_fine);
}c++$


end (input_stream long fine)
inc<"iostream">
$c++{
  std::cerr << "ENDING ref_par_one.ast" << std::endl;
}c++$