Subversion Repositories openrisc

/* { dg-do run } */

#include <omp.h>

#include <stdio.h>

extern void abort (void);

#define NUMBER_OF_THREADS 4

int synch[NUMBER_OF_THREADS];

int work[NUMBER_OF_THREADS];

int result[NUMBER_OF_THREADS];

int

fn1 (int i)

{

  return i * 2;

}

int

fn2 (int a, int b)

{

  return a + b;

}

int

main ()

{

  int i, iam, neighbor;

  omp_set_num_threads (NUMBER_OF_THREADS);

#pragma omp parallel private(iam,neighbor) shared(work,synch)

  {

    iam = omp_get_thread_num ();

    synch[iam] = 0;

#pragma omp barrier

    /*Do computation into my portion of work array */

    work[iam] = fn1 (iam);

    /* Announce that I am done with my work. The first flush

     * ensures that my work is made visible before synch.

     * The second flush ensures that synch is made visible.

     */

#pragma omp flush(work,synch)

    synch[iam] = 1;

#pragma omp flush(synch)

    /* Wait for neighbor. The first flush ensures that synch is read

     * from memory, rather than from the temporary view of memory.

     * The second flush ensures that work is read from memory, and

     * is done so after the while loop exits.

     */

    neighbor = (iam > 0 ? iam : omp_get_num_threads ()) - 1;

    while (synch[neighbor] == 0)

      {

#pragma omp flush(synch)

      }

#pragma omp flush(work,synch)

    /* Read neighbor's values of work array */

    result[iam] = fn2 (work[neighbor], work[iam]);

  }

  /* output result here */

  for (i = 0; i < NUMBER_OF_THREADS; i++)

    {

      neighbor = (i > 0 ? i : NUMBER_OF_THREADS) - 1;

      if (result[i] != i * 2 + neighbor * 2)

        abort ();

    }

  return 0;

}