#include "header.h"
#include <sys/time.h>
#include <math.h>
#include <queue>
#include <unistd.h>
#include "../scheduling/Clock.h"
#include "DiagonalMsg.h"
#include "SparseMatrix.h"
#include "SparseMsg.h"
#include "../mpi/PostMaster.h"
#include "../shell/Shell.h"

Include dependency graph for pymooseinit.cpp:

Functions
void	checkChildren (Id parent, const string &info)

unsigned int	getNumCores ()

Id	init (int argc, char **argv, bool &doUnitTests, bool &doRegressionTests, unsigned int &benchmark)

void	mooseBenchmarks (unsigned int option)

void	mpiTests ()

void	nonMpiTests (Shell *s)

void	processTests (Shell *s)

void	speedTestMultiNodeIntFireNetwork (unsigned int size, unsigned int runsteps)

Variables
bool	quitFlag = 0

Function Documentation

void checkChildren	(	Id	parent,
		const string &	info
	)

Definition at line 128 of file pymooseinit.cpp.

References Neutral::children(), Id::element(), Id::eref(), and Element::getName().

 {
     vector< Id > ret;
     Neutral::children( parent.eref(), ret );
     cout << info << " checkChildren of " <<
             parent.element()->getName() << ": " <<
         ret.size() << " children\n";
     for ( vector< Id >::iterator i = ret.begin(); i != ret.end(); ++i )
     {
         cout << i->element()->getName() << endl;
     }
 }

Here is the call graph for this function:

unsigned int getNumCores ( )

Definition at line 82 of file pymooseinit.cpp.

Referenced by moose::getArgMap(), and init().

 {
     unsigned int numCPU = 0;
 #ifdef WIN_32
     SYSTEM_INFO sysinfo;
     GetSystemInfo( &sysinfo );
 
     numCPU = sysinfo.dwNumberOfProcessors;
 #endif
 
 #ifdef LINUX
     numCPU = sysconf( _SC_NPROCESSORS_ONLN );
 #endif
 
 #ifdef MACOSX
     int mib[4];
     size_t len = sizeof(numCPU);
 
     /* set the mib for hw.ncpu */
     mib[0] = CTL_HW;
     mib[1] = HW_AVAILCPU;  // alternatively, try HW_NCPU;
 
     /* get the number of CPUs from the system */
     sysctl(mib, 2, &numCPU, &len, NULL, 0);
 
     if( numCPU < 1 )
     {
         mib[1] = HW_NCPU;
         sysctl( mib, 2, &numCPU, &len, NULL, 0 );
     }
 #endif
     if ( numCPU < 1 )
     {
 #ifndef QUIET_MODE
         cout << "No CPU information available. Assuming single core." << endl;
 #else
 #endif
         numCPU = 1;
     }
     return numCPU;
 }

Here is the caller graph for this function:

Id init	(	int	argc,
		char **	argv,
		bool &	doUnitTests,
		bool &	doRegressionTests,
		unsigned int &	benchmark
	)

Here we allow the user to override the automatic identification of processor configuration

Sets up the Elements that represent each class of Msg.

Definition at line 141 of file pymooseinit.cpp.

References Shell::adopt(), Eref::data(), Id::eref(), getNumCores(), Clock::initCinfo(), PostMaster::initCinfo(), Neutral::initCinfo(), Shell::initCinfo(), Msg::initMsgManagers(), isInfinite, Shell::loadBalance(), Cinfo::makeCinfoElements(), myNode, Id::nextId(), numCores, numNodes, quitFlag, Cinfo::rebuildOpIndex(), Shell::setHardware(), Shell::setShellElement(), and Id::value().

Referenced by getShell().

 {
     unsigned int numCores = getNumCores();
     int numNodes = 1;
     int myNode = 0;
     bool isInfinite = 0;
     int opt;
     benchmark = 0; // Default, means don't do any benchmarks.
     Cinfo::rebuildOpIndex();
 #ifdef USE_MPI
     /*
     // OpenMPI does not use argc or argv.
     // unsigned int temp_argc = 1;
     int provided;
     MPI_Init_thread( &argc, &argv, MPI_THREAD_SERIALIZED, &provided );
     */
     MPI_Init( &argc, &argv );
 
     MPI_Comm_size( MPI_COMM_WORLD, &numNodes );
     MPI_Comm_rank( MPI_COMM_WORLD, &myNode );
     /*
     if ( provided < MPI_THREAD_SERIALIZED && myNode == 0 ) {
         cout << "Warning: This MPI implementation does not like multithreading: " << provided << "\n";
     }
     */
     // myNode = MPI::COMM_WORLD.Get_rank();
 #endif
 
     while ( ( opt = getopt( argc, argv, "hiqurn:b:B:" ) ) != -1 ) {
         switch ( opt ) {
             case 'i' : // infinite loop, used for multinode debugging, to give gdb something to attach to.
                 isInfinite = 1;
                 break;
             case 'n': // Multiple nodes
               numNodes = (unsigned int)atoi( optarg );
                 break;
             case 'b': // Benchmark:
                 benchmark = atoi( optarg );
                 break;
             case 'B': // Benchmark plus dump data: handle later.
                 break;
             case 'u': // Do unit tests, pass back.
                 doUnitTests = 1;
                 break;
             case 'r': // Do regression tests: pass back
                 doRegressionTests = 1;
                 break;
             case 'q': // quit immediately after completion.
                 quitFlag = 1;
                 break;
             case 'h': // help
             default:
                 cout << "Usage: moose -help -infiniteLoop -unit_tests -regression_tests -quit -n numNodes -benchmark [ksolve intFire hhNet msg_<msgType>_<size>]\n";
 
                 exit( 1 );
         }
     }
     if ( myNode == 0 )
         {
 #ifndef QUIET_MODE
         cout << "on node " << myNode << ", numNodes = "
                     << numNodes << ", numCores = " << numCores << endl;
 #endif
         }
 
     Id shellId;
     Element* shelle =
         new GlobalDataElement( shellId, Shell::initCinfo(), "root", 1 );
 
     Id clockId = Id::nextId();
     assert( clockId.value() == 1 );
     Id classMasterId = Id::nextId();
     Id postMasterId = Id::nextId();
 
     Shell* s = reinterpret_cast< Shell* >( shellId.eref().data() );
     s->setShellElement( shelle );
     s->setHardware( numCores, numNodes, myNode );
     s->loadBalance();
 
     unsigned int numMsg = Msg::initMsgManagers();
 
     new GlobalDataElement( clockId, Clock::initCinfo(), "clock", 1 );
     new GlobalDataElement( classMasterId, Neutral::initCinfo(), "classes", 1);
     new GlobalDataElement( postMasterId, PostMaster::initCinfo(), "postmaster", 1 );
 
     assert ( shellId == Id() );
     assert( clockId == Id( 1 ) );
     assert( classMasterId == Id( 2 ) );
     assert( postMasterId == Id( 3 ) );
 
 
 
     // s->connectMasterMsg();
 
     Shell::adopt( shellId, clockId, numMsg++ );
     Shell::adopt( shellId, classMasterId, numMsg++ );
     Shell::adopt( shellId, postMasterId, numMsg++ );
 
     assert( numMsg == 10 ); // Must be the same on all nodes.
 
     Cinfo::makeCinfoElements( classMasterId );
 
 
     // This will be initialized within the Process loop, and better there
     // as it flags attempts to call the Reduce operations before ProcessLoop
     // Qinfo::clearReduceQ( numCores ); // Initialize the ReduceQ entry.
 
 
     // SetGet::setShell();
     // Msg* m = new OneToOneMsg( shelle, shelle );
     // assert ( m != 0 );
 
     while ( isInfinite ) // busy loop for debugging under gdb and MPI.
         ;
 
     return shellId;
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void mooseBenchmarks ( unsigned int option )

void mpiTests ( )

These are tests that are MPI safe. They should also run properly on single nodes.

Definition at line 319 of file pymooseinit.cpp.

References testMpiBuiltins(), testMpiMsg(), testMpiScheduling(), and testMpiShell().

Referenced by getShell().

 {
 #ifdef DO_UNIT_TESTS
         testMpiMsg();
         cout << "." << flush;
         testMpiShell();
         cout << "." << flush;
         testMpiBuiltins();
         cout << "." << flush;
         testMpiScheduling();
         cout << "." << flush;
 #endif
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void nonMpiTests ( Shell * s )

These tests are meant to run on individual nodes, and should not invoke MPI calls. They should not be run when MPI is running. These tests do not use the threaded/MPI event loop and are the most basic of the set.

Definition at line 270 of file pymooseinit.cpp.

References Shell::myNode(), numCores, Shell::numCores(), numNodes, Shell::numNodes(), Shell::setHardware(), testAsync(), testBiophysics(), testBuiltins(), testDiffusion(), testHSolve(), testKsolve(), testMesh(), testMsg(), testScheduling(), testShell(), testSigNeur(), and testSynapse().

Referenced by getShell().

 {
 #ifdef DO_UNIT_TESTS
     if ( Shell::myNode() == 0 ) {
         unsigned int numNodes = s->numNodes();
         unsigned int numCores = s->numCores();
         if ( numCores > 0 )
         s->setHardware( 1, 1, 0 );
         testAsync();
         testMsg();
         testShell();
         testScheduling();
         testBuiltins();
         // testKinetics();
         // testKineticSolvers();
         testBiophysics();
         // testHSolve();
         // testGeom();
         // testMesh();
         // testSigNeur();
 #ifdef USE_SMOLDYN
         // testSmoldyn();
 #endif
         s->setHardware( numCores, numNodes, 0 );
     }
 #endif
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void processTests ( Shell * s )

These tests involve the threaded/MPI process loop and are the next level of tests.

Definition at line 302 of file pymooseinit.cpp.

References testBiophysicsProcess(), testBuiltinsProcess(), testSchedulingProcess(), and testSigNeurProcess().

Referenced by getShell().

 {
 #ifdef DO_UNIT_TESTS
     testSchedulingProcess();
     testBuiltinsProcess();
     // testKineticsProcess();
     testBiophysicsProcess();
     // testKineticSolversProcess();
     // testSimManager();
     // testSigNeurProcess();
 #endif
 }

Here is the call graph for this function:

Here is the caller graph for this function:

void speedTestMultiNodeIntFireNetwork	(	unsigned int	size,
		unsigned int	runsteps
	)

Variable Documentation

bool quitFlag = 0

Definition at line 124 of file pymooseinit.cpp.

Referenced by init().

Functions

Variables

Function Documentation

Variable Documentation