openMP.h

Go to the documentation of this file.

#ifndef openMP_H
#define openMP_H

//argmin reduction

#include "OMP_ArrayElement.h"

#ifdef _OPENMP


//openMP code
#include "omp.h"



#define OMP_IS_ENABLED() true
#define STR(a) #a
#define STRINGIFY(a) STR(a)
#define CMD_PRIVATE(C,P) C P  default(none)
#define CMD_SHARED(C,S) C S  default(none)
#define CMD_PRIVATE_SHARED(C,P,S) C P  S  default(none)
#define CMD_PRIVATE_SHARED_REDUCTION(C,P,S,R) C P  S  default(none) R
#define CMD_PRIVATE_SHARED_DEFAULT(C,P,S,D) C P  S  D
#define CMD_PRIVATE_SHARED_DEFAULT_REDUCTION(C,P,S,D,R) C P  S  D  R 


//OMP Functions
#define OMP_DISABLE_DYNAMIC_THREADS_NUMBER() omp_set_dynamic(0)
#define OMP_GET_THREADS_NUMBER() omp_get_num_threads()
#define OMP_GET_MAX_THREADS_NUMBER() omp_get_max_threads()
#define OMP_GET_THREAD_ID()  omp_get_thread_num()
#define OMP_SET_THREADS_NUMBER(A) omp_set_num_threads(A)
#define OMP_SET_MAX_THREADS_NUMBER(A) omp_set_max_threads(A)
#define OMP_GET_TIME() omp_get_wtime()
#define OMP_GET_DURATION(S) (1000*(omp_get_wtime()-S))

// PARALLEL
#define OMP_PARALLEL() _Pragma( STRINGIFY (omp parallel ) )
#define OMP_PARALLEL_PRIVATE(P) _Pragma( STRINGIFY( CMD_PRIVATE(omp parallel,P) ))
#define OMP_PARALLEL_SHARED(S) _Pragma( STRINGIFY( CMD_SHARED(omp parallel,S) ))
#define OMP_PARALLEL_PRIVATE_SHARED(P,S) _Pragma( STRINGIFY( CMD_PRIVATE_SHARED(omp parallel,P,S) ))
#define OMP_PARALLEL_PRIVATE_SHARED_REDUCTION(P,S,R) _Pragma( STRINGIFY( CMD_PRIVATE_SHARED_REDUCTION(omp parallel,P,S,R) ))
#define OMP_PARALLEL_PRIVATE_SHARED_DEFAULT(P,S,D) _Pragma( STRINGIFY( CMD_PRIVATE_SHARED_DEFAULT(omp parallel,P,S,D) ))
#define OMP_PARALLEL_PRIVATE_SHARED_DEFAULT_REDUCTION(P,S,D,R) _Pragma( STRINGIFY( CMD_PRIVATE_SHARED_DEFAULT_REDUCTION(omp parallel,P,S,D,R) ))
#define OMP_SECTION() _Pragma( STRINGIFY (omp section ) )
#define OMP_SECTIONS() _Pragma( STRINGIFY (omp sections ) )

// BARRIER
#define OMP_BARRIER() _Pragma(STRINGIFY(omp barrier))

// FOR LOOP
#define OMP_FOR(S,E,I) _Pragma(STRINGIFY(omp for ))      \
    for (S;E;I)
#define OMP_PARALLEL_FOR(S,E,I) _Pragma(STRINGIFY(omp parallel for))     \
    for (S;E;I) 
#define OMP_FOR_COLLAPSE(C,S,E,I) _Pragma(STRINGIFY(omp for collapse(C))) \
    for (S;E;I)

//CRITICAL
#define OMP_CRITICAL(A) _Pragma(STRINGIFY(omp critical (A) )) 

#pragma omp declare reduction(argrmin: std::pair<tReal,tUIndex> : omp_out=OMP_ArrayElement<tReal>::pmin(omp_out,omp_in)) 
#pragma omp declare reduction(argrmax: std::pair<tReal,tUIndex> : omp_out=OMP_ArrayElement<tReal>::pmax(omp_out,omp_in))

#else  /* ifndef _OPENMP */

//no open MP  code
#include "CORE_Time.h"
#include <ctime>

//OMP Functions
#define OMP_IS_ENABLED() false
#define OMP_DISABLE_DYNAMIC_THREADS_NUMBER() 
#define OMP_GET_THREADS_NUMBER() 1
#define OMP_GET_MAX_THREADS_NUMBER() 1
#define OMP_GET_THREAD_ID() 0
#define OMP_SET_THREADS_NUMBER(A)
#define OMP_SET_MAX_THREADS_NUMBER(A)
#define OMP_GET_TIME() CORE_Time::getClockTime()
#define OMP_GET_DURATION(S) CORE_Time::getClockDuration(S)

// PARALLEL
#define OMP_PARALLEL()
#define OMP_PARALLEL_PRIVATE(P)
#define OMP_PARALLEL_SHARED(S)
#define OMP_PARALLEL_PRIVATE_SHARED(P,S)
#define OMP_PARALLEL_PRIVATE_SHARED_REDUCTION(P,S,R)
#define OMP_PARALLEL_PRIVATE_SHARED_DEFAULT(P,S,D)
#define OMP_PARALLEL_PRIVATE_SHARED_DEFAULT_REDUCTION(P,S,D,R)
#define OMP_SECTIONS()
#define OMP_SECTION()

//BARRIER
#define OMP_BARRIER()

//FOR
#define OMP_PARALLEL_FOR(S,E,I)                  \
    for (S;E;I) 
#define OMP_FOR(S,E,I)                           \
    for (S;E;I) 
#define OMP_FOR_COLLAPSE(C,S,E,I) \
    for (S;E;I)

// CRITICAL
#define OMP_CRITICAL(A) 


    
#endif /*ifdef _OPENMP */

#endif /* openMP_H */