Main Page | Class Hierarchy | Alphabetical List | Class List | File List | Class Members | File Members | Related Pages

dox/Parallel/vtkMPIController.h

Go to the documentation of this file.
00001 /*========================================================================= 00002 00003 Program: Visualization Toolkit 00004 Module: $RCSfile: vtkMPIController.h,v $ 00005 00006 Copyright (c) Ken Martin, Will Schroeder, Bill Lorensen 00007 All rights reserved. 00008 See Copyright.txt or http://www.kitware.com/Copyright.htm for details. 00009 00010 This software is distributed WITHOUT ANY WARRANTY; without even 00011 the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR 00012 PURPOSE. See the above copyright notice for more information. 00013 00014 =========================================================================*/ 00048 #ifndef __vtkMPIController_h 00049 #define __vtkMPIController_h 00050 00051 #include "vtkMultiProcessController.h" 00052 // Do not remove this header file. This class contains methods 00053 // which take arguments defined in vtkMPICommunicator.h by 00054 // reference. 00055 #include "vtkMPICommunicator.h" // Needed for direct access to communicator 00056 00057 class VTK_PARALLEL_EXPORT vtkMPIController : public vtkMultiProcessController 00058 { 00059 00060 public: 00061 00062 static vtkMPIController *New(); 00063 vtkTypeRevisionMacro(vtkMPIController,vtkMultiProcessController); 00064 void PrintSelf(ostream& os, vtkIndent indent); 00065 00067 00075 virtual void Initialize(int* argc, char*** argv) 00076 { this->Initialize(argc, argv, 0); } 00078 00079 virtual void Initialize(int* vtkNotUsed(argc), char*** vtkNotUsed(argv), 00080 int initializedExternally); 00081 00084 virtual void Finalize() { this->Finalize(0); } 00085 00086 virtual void Finalize(int finalizedExternally); 00087 00090 virtual void SingleMethodExecute(); 00091 00095 virtual void MultipleMethodExecute(); 00096 00099 void Barrier(); 00100 00103 virtual void CreateOutputWindow(); 00104 00107 static char* ErrorString(int err); 00108 00109 00115 void SetCommunicator(vtkMPICommunicator* comm); 00116 00117 //BTX 00118 00120 00125 int NoBlockSend(int* data, int length, int remoteProcessId, int tag, 00126 vtkMPICommunicator::Request& req) 00127 { return ((vtkMPICommunicator*)this->Communicator)->NoBlockSend 00128 (data ,length, remoteProcessId, tag, req); } 00129 int NoBlockSend(unsigned long* data, int length, int remoteProcessId, 00130 int tag, vtkMPICommunicator::Request& req) 00131 { return ((vtkMPICommunicator*)this->Communicator)->NoBlockSend 00132 (data, length, remoteProcessId, tag, req); } 00133 int NoBlockSend(char* data, int length, int remoteProcessId, 00134 int tag, vtkMPICommunicator::Request& req) 00135 { return ((vtkMPICommunicator*)this->Communicator)->NoBlockSend 00136 (data, length, remoteProcessId, tag, req); } 00137 int NoBlockSend(float* data, int length, int remoteProcessId, 00138 int tag, vtkMPICommunicator::Request& req) 00139 { return ((vtkMPICommunicator*)this->Communicator)->NoBlockSend 00140 (data, length, remoteProcessId, tag, req); } 00142 00144 00148 int NoBlockReceive(int* data, int length, int remoteProcessId, 00149 int tag, vtkMPICommunicator::Request& req) 00150 { return ((vtkMPICommunicator*)this->Communicator)->NoBlockReceive 00151 (data, length, remoteProcessId, tag, req); } 00152 int NoBlockReceive(unsigned long* data, int length, 00153 int remoteProcessId, int tag, 00154 vtkMPICommunicator::Request& req) 00155 { return ((vtkMPICommunicator*)this->Communicator)->NoBlockReceive 00156 (data, length, remoteProcessId, tag, req); } 00157 int NoBlockReceive(char* data, int length, int remoteProcessId, 00158 int tag, vtkMPICommunicator::Request& req) 00159 { return ((vtkMPICommunicator*)this->Communicator)->NoBlockReceive 00160 (data, length, remoteProcessId, tag, req); } 00161 int NoBlockReceive(float* data, int length, int remoteProcessId, 00162 int tag, vtkMPICommunicator::Request& req) 00163 { return ((vtkMPICommunicator*)this->Communicator)->NoBlockReceive 00164 (data, length, remoteProcessId, tag, req); } 00166 00167 //ETX 00168 00169 static const char* GetProcessorName(); 00170 00171 protected: 00172 vtkMPIController(); 00173 ~vtkMPIController(); 00174 00175 // Given a communicator, obtain size and rank 00176 // setting NumberOfProcesses and LocalProcessId 00177 // Should not be called if the current communicator 00178 // does not include this process 00179 int InitializeNumberOfProcesses(); 00180 00181 // Set the communicator to comm and call InitializeNumberOfProcesses() 00182 void InitializeCommunicator(vtkMPICommunicator* comm); 00183 00184 // Duplicate the current communicator, creating RMICommunicator 00185 void InitializeRMICommunicator(); 00186 00187 // MPI communicator created when Initialize() called. 00188 // This is a copy of MPI_COMM_WORLD but uses a new 00189 // context, i.e. even if the tags are the same, the 00190 // RMI messages will not interfere with user level 00191 // messages. 00192 static vtkMPICommunicator* WorldRMICommunicator; 00193 00194 // Initialize only once. 00195 static int Initialized; 00196 00197 static char ProcessorName[]; 00198 00199 private: 00200 vtkMPIController(const vtkMPIController&); // Not implemented. 00201 void operator=(const vtkMPIController&); // Not implemented. 00202 }; 00203 00204 00205 #endif 00206 00207