1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
/*=========================================================================
Program: ParaView
Module: vtkMPIMToNSocketConnection.h
Copyright (c) Kitware, Inc.
All rights reserved.
See Copyright.txt or http://www.paraview.org/HTML/Copyright.html for details.
This software is distributed WITHOUT ANY WARRANTY; without even
the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
PURPOSE. See the above copyright notice for more information.
=========================================================================*/
/**
* @class vtkMPIMToNSocketConnection
* @brief class to create socket connections between two servers
*
*
* class used to create socket connections between the render and data
* servers. This used for example when data is on a super computer (SGI,
* IBM, etc) and Rendering on a Linux cluster with hardware graphics support.
* This problem is known as the "M" to "N" geometry load redistribution
* problem. It addresses the common case where there is a significante
* mismatch in the size of large parallel computing resources and the often
* smaller parallel hardward-accelerated rendering resources. The larger
* number of processors on the compute servers are called M, and the smaller
* number of rendering processors are call N. This class is used to create N
* vtkSocketCommunicator's that connect the first N of the M processes on the
* data server to the N processes on the render server.
*/
#ifndef vtkMPIMToNSocketConnection_h
#define vtkMPIMToNSocketConnection_h
#include "vtkObject.h"
#include "vtkPVClientServerCoreCoreModule.h" //needed for exports
class vtkMultiProcessController;
class vtkServerSocket;
class vtkSocketCommunicator;
class vtkMPIMToNSocketConnectionPortInformation;
class vtkMPIMToNSocketConnectionInternals;
class VTKPVCLIENTSERVERCORECORE_EXPORT vtkMPIMToNSocketConnection : public vtkObject
{
public:
static vtkMPIMToNSocketConnection* New();
vtkTypeMacro(vtkMPIMToNSocketConnection, vtkObject);
void PrintSelf(ostream& os, vtkIndent indent) VTK_OVERRIDE;
void Initialize(int waiting_process_type);
/**
* Setup the connection.
*/
void ConnectMtoN();
//@{
/**
* Set the number of connections to be made.
*/
void SetNumberOfConnections(int);
vtkGetMacro(NumberOfConnections, int);
//@}
/**
* Set up information about the remote connection.
*/
void SetPortInformation(unsigned int processNumber, int portNumber, const char* hostName);
//@{
/**
* Return the socket communicator for this process.
*/
vtkGetObjectMacro(SocketCommunicator, vtkSocketCommunicator);
//@}
/**
* Fill the port information values into the port information object.
*/
void GetPortInformation(vtkMPIMToNSocketConnectionPortInformation*);
//@{
/**
* Set port to use, if the value is 0, then the system will pick the port.
*/
vtkGetMacro(PortNumber, int);
//@}
protected:
vtkSetMacro(PortNumber, int);
/**
* Setup the wait for connection, but do not wait yet.
* This should determine the network to be used and the port to be used.
*/
void SetupWaitForConnection();
/**
* SetupStartWaitForConnection must be called first. This
* method will start waiting for a connection to be made to it.
*/
void WaitForConnection();
/**
* Connect to remote server.
*/
void Connect();
virtual void SetController(vtkMultiProcessController*);
virtual void SetSocketCommunicator(vtkSocketCommunicator*);
vtkMPIMToNSocketConnection();
~vtkMPIMToNSocketConnection();
private:
int PortNumber;
int Socket;
vtkServerSocket* ServerSocket;
int NumberOfConnections;
vtkMPIMToNSocketConnectionInternals* Internals;
vtkMultiProcessController* Controller;
vtkSocketCommunicator* SocketCommunicator;
vtkMPIMToNSocketConnection(const vtkMPIMToNSocketConnection&) VTK_DELETE_FUNCTION;
void operator=(const vtkMPIMToNSocketConnection&) VTK_DELETE_FUNCTION;
bool IsWaiting;
};
#endif
|
