00001 /*========================================================================= 00002 00003 Program: Visualization Toolkit 00004 Module: $RCSfile: vtkSocketController.h,v $ 00005 Language: C++ 00006 00007 Copyright (c) 1993-2001 Ken Martin, Will Schroeder, Bill Lorensen 00008 All rights reserved. 00009 00010 Redistribution and use in source and binary forms, with or without 00011 modification, are permitted provided that the following conditions are met: 00012 00013 * Redistributions of source code must retain the above copyright notice, 00014 this list of conditions and the following disclaimer. 00015 00016 * Redistributions in binary form must reproduce the above copyright notice, 00017 this list of conditions and the following disclaimer in the documentation 00018 and/or other materials provided with the distribution. 00019 00020 * Neither name of Ken Martin, Will Schroeder, or Bill Lorensen nor the names 00021 of any contributors may be used to endorse or promote products derived 00022 from this software without specific prior written permission. 00023 00024 * Modified source versions must be plainly marked as such, and must not be 00025 misrepresented as being the original software. 00026 00027 THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS ``AS IS'' 00028 AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 00029 IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE 00030 ARE DISCLAIMED. IN NO EVENT SHALL THE AUTHORS OR CONTRIBUTORS BE LIABLE FOR 00031 ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL 00032 DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR 00033 SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER 00034 CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, 00035 OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 00036 OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 00037 00038 =========================================================================*/ 00057 #ifndef __vtkSocketController_h 00058 #define __vtkSocketController_h 00059 00060 #if defined(_WIN32) && !defined(__CYGWIN__) 00061 #include <winsock2.h> 00062 #else 00063 #include <sys/types.h> 00064 #include <sys/socket.h> 00065 #include <netinet/in.h> 00066 #include <arpa/inet.h> 00067 #include <netdb.h> 00068 #include <unistd.h> 00069 #endif 00070 00071 #include "vtkObject.h" 00072 #include "vtkMultiProcessController.h" 00073 #include "vtkSocketCommunicator.h" 00074 00075 class VTK_PARALLEL_EXPORT vtkSocketController : public vtkMultiProcessController 00076 { 00077 public: 00078 static vtkSocketController *New(); 00079 vtkTypeMacro(vtkSocketController,vtkMultiProcessController); 00080 void PrintSelf(ostream& os, vtkIndent indent); 00081 00083 00085 virtual void Initialize(int* , char***); 00086 virtual void Initialize() 00087 { this->Initialize(0,0); } 00089 00091 void Finalize() {}; 00092 00094 void SingleMethodExecute() {}; 00095 00097 void MultipleMethodExecute() {}; 00098 00100 void CreateOutputWindow() {}; 00101 00103 void Barrier() {}; 00104 00106 virtual void SetNumberOfProcesses(int num); 00107 00109 00110 virtual int WaitForConnection(int port) 00111 { 00112 return vtkSocketCommunicator::SafeDownCast(this->Communicator)-> 00113 WaitForConnection(port); 00114 } 00116 00118 00119 virtual void CloseConnection() 00120 { 00121 vtkSocketCommunicator::SafeDownCast(this->Communicator)-> 00122 CloseConnection(); 00123 } 00125 00127 00128 virtual int ConnectTo( char* hostName, int port ) 00129 { 00130 return vtkSocketCommunicator::SafeDownCast(this->Communicator)-> 00131 ConnectTo(hostName, port); 00132 } 00134 00135 int GetSwapBytesInReceivedData() 00136 { 00137 return vtkSocketCommunicator::SafeDownCast(this->Communicator)-> 00138 GetSwapBytesInReceivedData(); 00139 } 00140 00142 void SetCommunicator(vtkSocketCommunicator* comm); 00143 00144 //BTX 00145 00146 enum Consts { 00147 ENDIAN_TAG=1010580540 // 0x3c3c3c3c 00148 }; 00149 00150 //ETX 00151 00152 protected: 00153 00154 vtkSocketController(); 00155 ~vtkSocketController(); 00156 00157 // Initialize only once, finialize on destruction. 00158 static int Initialized; 00159 private: 00160 vtkSocketController(const vtkSocketController&); // Not implemented. 00161 void operator=(const vtkSocketController&); // Not implemented. 00162 }; 00163 00164 00165 #endif // __vtkSocketController_h