23 #ifndef vtkSMSessionClient_h 24 #define vtkSMSessionClient_h 26 #include "vtkPVServerManagerCoreModule.h" 29 class vtkMultiProcessController;
40 void PrintSelf(ostream& os, vtkIndent indent);
45 virtual const char*
GetURI() {
return this->URI; };
60 virtual bool Connect(
const char* url);
116 vtkSetMacro(AbortConnect,
bool);
131 vtkTypeUInt32 location,
vtkPVInformation* information, vtkTypeUInt32 globalid);
159 virtual bool IsNotBusy();
165 virtual void StartBusyWork();
171 virtual void EndBusyWork();
199 void OnServerNotificationMessageRMI(
void* message,
int message_length);
205 void SetRenderServerController(vtkMultiProcessController*);
206 void SetDataServerController(vtkMultiProcessController*);
208 void SetupDataServerRenderServerConnection();
224 vtkTypeUInt32 GetRealLocation(vtkTypeUInt32);
235 vtkSetStringMacro(URI);
253 virtual bool OnWrongTagEvent(vtkObject* caller,
unsigned long eventid,
void* calldata);
258 virtual void OnConnectionLost(vtkObject* caller,
unsigned long eventid,
void* calldata);
265 vtkTypeUInt32 LastGlobalID;
266 vtkTypeUInt32 LastGlobalIDAvailable;
vtkPVServerInformation * RenderServerInformation
vtkPVServerInformation * ServerInformation
vtkPVServerInformation * DataServerInformation
virtual bool GetIsAlive()
Builtin session is always alive.
virtual vtkSMCollaborationManager * GetCollaborationManager()
Return the instance of vtkSMCollaborationManager that will be lazy created at the first call...
virtual const vtkClientServerStream & GetLastResult(vtkTypeUInt32 location)
Returns the response of the ExecuteStream() call from the location.
vtkSMSession is the default ParaView session.
vtkMultiProcessController * RenderServerController
virtual const char * GetURI()
Return the url used to connect the current session to a server.
virtual bool GatherInformation(vtkTypeUInt32 location, vtkPVInformation *information, vtkTypeUInt32 globalid)
Gather information about an object referred by the globalid.
Class used to broadcast message from one client to the others.
Store messages for the interpreter.
singleton/facade to vtkSMSessionProxyManager
virtual void PreDisconnection()
virtual bool IsMPIInitialized(vtkTypeUInt32 servers)
Returns whether or not MPI is initialized on the specified server/s.
vtkSMSessionClient is a remote-session that connects to a remote server.
vtkMultiProcessController * DataServerController
Header class that setup every thing in order to use Protobuf messages in a transparent manner...
virtual vtkTypeUInt32 GetNextGlobalUniqueIdentifier()
Provides the next available identifier.
virtual void Initialize()
Initialize various internal classes after the session has been setup correctly.
static vtkSMSession * New()
virtual void PushState(vtkSMMessage *msg)
Push the state message.
virtual vtkPVServerInformation * GetServerInformation()
vtkPVServerInformation is an information-object that provides information about the server processes...
virtual void UnRegisterSIObject(vtkSMMessage *msg)
Unregister server side object.
virtual void RegisterSIObject(vtkSMMessage *msg)
Register server side object.
is used to locate proxies referred to in state xmls while loading state files.
virtual int GetNumberOfProcesses(vtkTypeUInt32 servers)
Returns the number of processes on the given server/s.
virtual vtkTypeUInt32 GetNextChunkGlobalUniqueIdentifier(vtkTypeUInt32 chunkSize)
Return the first Id of the requested chunk.
vtkClientServerStream * ServerLastInvokeResult
virtual void PullState(vtkSMMessage *msg)
Pull the state message.
void PrintSelf(ostream &os, vtkIndent indent)
vtkSMCollaborationManager * CollaborationCommunicator
virtual ServerFlags GetProcessRoles()
Returns a ServerFlags indicate the nature of the current processes.
virtual bool OnWrongTagEvent(vtkObject *caller, unsigned long eventid, void *calldata)
Callback when any vtkMultiProcessController subclass fires a WrongTagEvent.
virtual vtkMultiProcessController * GetController(ServerFlags processType)
Returns the controller used to communicate with the process.
virtual void ExecuteStream(vtkTypeUInt32 location, const vtkClientServerStream &stream, bool ignore_errors=false)
Execute a command on the given processes.