|| || || || || || || ||

---

PxSystem.h

Go to the documentation of this file.

/*
 *  Copyright (c) 2003-2004, University of Amsterdam, The Netherlands.
 *  All rights reserved.
 *
 *  Author(s):
 *  Frank Seinstra <fjseins@wins.uva.nl>
 */

#ifndef __PxSystem_h_
#define __PxSystem_h_


#include "mpi.h"
#include <stdlib.h>

namespace Impala
{
namespace Core
{
namespace Array
{
namespace Pattern
{


/*** Global variables ***/

int     sys_myCPU   = 0;
char    sys_myCPUname[MPI_MAX_PROCESSOR_NAME] = "unknown";
int     sys_nrCPUs  = 1;

int     sys_xCPUs   = 1;
int     sys_yCPUs   = 1;
int     sys_zCPUs   = 1;
int     sys_rootCPU = 0;

int     run_parallel     = 1;
int     run_lazyParallel = 1;

int     in_dataCPU  = 0;
int     out_dataCPU = 0;


/**********************************************************************
 *** General Parallel System Functions                              ***
 **********************************************************************/

inline void
PxInitSystem(int *argc, char ***argv)
{
    int reslen;

    MPI_Init(argc, argv);
    MPI_Comm_rank(MPI_COMM_WORLD, &sys_myCPU);
    MPI_Comm_size(MPI_COMM_WORLD, &sys_nrCPUs);
    MPI_Get_processor_name(sys_myCPUname, &reslen);
}


inline int
PxExitSystem()
{
    MPI_Barrier(MPI_COMM_WORLD);
    return MPI_Finalize();
}


inline void
PxAbortSystem()
{
    MPI_Barrier(MPI_COMM_WORLD);
    MPI_Abort(MPI_COMM_WORLD, 1);
    MPI_Finalize();
    exit(1);
}


inline int
PxMyCPU()
{
    return sys_myCPU;
}


inline char*
PxMyCPUname()
{
    return sys_myCPUname;
}


inline int
PxNrCPUs()
{
    return sys_nrCPUs;
}


inline void
PxInitSystemGrid(int xcpus, int ycpus, int zcpus)
{
    sys_xCPUs = xcpus;
    sys_yCPUs = ycpus;
    sys_zCPUs = zcpus;
}


inline int
PxXCPUs()
{
    return sys_xCPUs;
}


inline int
PxYCPUs()
{
    return sys_yCPUs;
}


inline int
PxZCPUs()
{
    return sys_zCPUs;
}


inline void
PxInitRoot(int cpu)
{
    sys_rootCPU = (cpu < 0 || cpu >= sys_nrCPUs) ? 0 : cpu;
}


inline int
PxRootCPU()
{
    return sys_rootCPU;
}


/**********************************************************************/


inline void
PxInitRunParallel(int runpar)
{
    run_parallel = (runpar < 0 || runpar > 1) ? 0 : runpar;
    if (!run_parallel) {
        run_lazyParallel = 0;
    }
}


inline int
PxRunParallel()
{
    return run_parallel;
}


inline void
PxInitLazyParallel(int lazypar)
{
    run_lazyParallel = (lazypar < 0 || lazypar > 1) ? 0 : lazypar;
    if (run_lazyParallel) {
        run_parallel = 1;
    }
}


inline int
PxRunLazyParallel()
{
    return run_lazyParallel;
}


/**********************************************************************/


inline void
PxInitDataInOut(int cpu)
{
    in_dataCPU  = (cpu < 0 || cpu >= sys_nrCPUs) ? sys_rootCPU : cpu;
    out_dataCPU = in_dataCPU;
}


inline int
PxInCPU()
{
    return in_dataCPU;
}


inline int
PxOutCPU()
{
    return out_dataCPU;
}


} // namespace Pattern
} // namespace Array
} // namespace Core
} // namespace Impala

#endif /* __PxSystem_h_ */

---