// -*- C++ -*-
 
#define   CIPATH "/usr/include"

#define    N 10
#define    M 5
#define NUM1 0
#define NUM2 1

generic main()
{
  stream long    A;
  stream long[2] B;

  genera   (                 output_stream A);  
  p_array  (input_stream A   output_stream B);
  fine1    (input_stream B);
}


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


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

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


parmod p_array (input_stream long A output_stream long B[2]) {
  
  topology array[i:M] Pv;
  attribute long b[2] replicated;

  do input_section {
    guard1: on , , A {
      distribution A broadcast to Pv;
    }
  } while (true)
  
  virtual_processors {
    elab1 (in guard1) {
      VP i {
	f_p1 (in A, i  out b);
        f_p2 (in b  out b);
	assist_out (B, b);
      }
    }
  }
   
  output_section {
    collects B from ANY Pv;
  } 
}


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

  long b;
  
  if (B[1] != NUM2) ok = -1;
  count++;
  
  // end of regression test
  if (count >= N*M) {  
    if (ok==0) 
      std::cerr << "ENDING with SUCCESS fine parmod_due_proc.ast" << std::endl;
    else std::cerr << "ENDING with FAILURE fine parmod_due_proc.ast" << std::endl;
  }
}c++$


proc f_p1(in long A, long i  out long B[2])
 
inc<"iostream">
$c++{
  B[0] = i;
  B[1] = NUM1;
}c++$


proc f_p2(in long B1[2]  out long B2[2])
 
inc<"iostream">
$c++{
  B2[0] = B1[0];
  B2[1] = NUM2;
}c++$