BIE Overview Quick Start Theoretical overview Available methods Parallel chains Computation engine Command Line Interface Graphical User Interface Assigning Output Visualization tool Data handling Software technology Parallel debugging Results to date Recent developments Links User guide Future features Project goals Project Team Copyright and license

/home/weinberg/src/BIE/include/TileRequestHandlerThread.h #ifndef TileRequestHandlerThread_h #define TileRequestHandlerThread_h #include "EvaluationRequest.h" #include <BIEmpi.h> #include <vector> #include <list> #include <cc++/thread.h> #include "ElapsedTime.h" using namespace ost; namespace BIE { class TileMasterWorkerThread; // forward declaration class TileRequestHandlerThread : public Thread { public: TileRequestHandlerThread(int numWorkersInTileGroup, vector<int> *p_GroupIdToSystemId, vector<int> *p_SystemIdToGroupId, vector<MPI_Comm> *p_comms, Semaphore *numberSlavesReady); void reInitialize(int tileGroupSize, vector<int> *groupIdToSystemId, vector<int> *systemIdToGroupId, vector<MPI_Comm> *comms, Semaphore *numberSlavesReady); void setTileMasterWorkerThread(TileMasterWorkerThread* tileMasterWorkerThread); void masterWorkerRegister(); void masterWorkerAvailable(); void resetPause(); void unPause(); void stopPausedThread(); virtual ~TileRequestHandlerThread(){}; virtual void run (); virtual void enqueueRequest(EvaluationRequest *request); virtual void readAndProcessMessage(MPI_Status *status); bool allWorking(); bool noneWorking(); bool noMPISlaves(); bool workAvailable(); virtual void final(); // Event that signifies some work just went out. Event MPIThreadLoopEvent; //aah todo Why doesn't volatile work here? /*volatile*/ vector<double> startTime; /*volatile*/ vector<double> endTime; vector< vector<int> > histo; ElapsedTime workerWaitTime; ElapsedTime workWaitTime; ElapsedTime mutexWaitTime; ElapsedTime probeTime; ElapsedTime IprobeTime; ElapsedTime loopEventWaitTime; ElapsedTime thrqMutexHoldTime; ElapsedTime recvTime; private: // helper function for constructors and reInitialize methods. void commonInitialize(int tileGroupSize, vector<int> *groupIdToSystemId, vector<int> *systemIdToGroupId, vector<MPI_Comm> *p_comms, Semaphore *numberSlavesReady); volatile bool stopRequested; volatile bool resetRequested; Semaphore workerAvailableSemaphore; // initializes to zero Semaphore requestAvailableSemaphore; // initializes to zero int workerAvailableSemaphoreCount; int requestAvailableSemaphoreCount; // Semaphores to control resetting and stopping Semaphore exitedMainLoop; Semaphore resumeMainLoop; // this object also owns the request queue. list<EvaluationRequest*> requestQueue; Mutex requestQueueMutex; /*volatile*/ vector<EvaluationRequest*> pendingRequest; vector<int> *groupIdToSystemId; vector<int> *systemIdToGroupId; vector<MPI_Comm> *comms; int numWorkersInTileGroup; TileMasterWorkerThread *tileMasterWorkerThread; }; } #endif // TileRequestHandlerThread_h