vtkPVSessionServer.h

Go to the documentation of this file.

// SPDX-FileCopyrightText: Copyright (c) Kitware Inc.
// SPDX-License-Identifier: BSD-3-Clause
#ifndef vtkPVSessionServer_h
#define vtkPVSessionServer_h
 
#include "vtkPVSessionBase.h"
#include "vtkRemotingServerManagerModule.h" //needed for exports
 
class vtkMultiProcessController;
class vtkMultiProcessStream;
 
class VTKREMOTINGSERVERMANAGER_EXPORT vtkPVSessionServer : public vtkPVSessionBase
{
public:
  static vtkPVSessionServer* New();
  vtkTypeMacro(vtkPVSessionServer, vtkPVSessionBase);
  void PrintSelf(ostream& os, vtkIndent indent) override;
 
  vtkMultiProcessController* GetController(ServerFlags processType) override;
 
  virtual bool Connect(const char* url);
 
  bool Connect();
 
  bool GetIsAlive() override;
 
  enum
  {
    PUSH = 12,
    PULL = 13,
    EXECUTE_STREAM = 14,
    GATHER_INFORMATION = 15,
    REGISTER_SI = 16,
    UNREGISTER_SI = 17,
    LAST_RESULT = 18,
    SERVER_NOTIFICATION_MESSAGE_RMI = 55624,
    CLIENT_SERVER_MESSAGE_RMI = 55625,
    CLOSE_SESSION = 55626,
    REPLY_GATHER_INFORMATION_TAG = 55627,
    REPLY_PULL = 55628,
    REPLY_LAST_RESULT = 55629,
    EXECUTE_STREAM_TAG = 55630
  };
 
 
  vtkBooleanMacro(MultipleConnection, bool);
  vtkSetMacro(MultipleConnection, bool);
  vtkGetMacro(MultipleConnection, bool);
 
 
  vtkBooleanMacro(DisableFurtherConnections, bool);
  vtkGetMacro(DisableFurtherConnections, bool);
  void SetDisableFurtherConnections(bool disable);
 
 
  void SetConnectID(int newConnectID);
  int GetConnectID();
 
  void OnClientServerMessageRMI(void* message, int message_length);
  void OnCloseSessionRMI();
 
  void NotifyAllClients(const vtkSMMessage*) override;
 
  void NotifyOtherClients(const vtkSMMessage*) override;
 
protected:
  vtkPVSessionServer();
  ~vtkPVSessionServer() override;
 
  void GatherInformationInternal(
    vtkTypeUInt32 location, const char* classname, vtkTypeUInt32 globalid, vtkMultiProcessStream&);
 
  void SendLastResultToClient();
 
  vtkMPIMToNSocketConnection* MPIMToNSocketConnection;
 
  bool MultipleConnection;
  bool DisableFurtherConnections;
 
  class vtkInternals;
  vtkInternals* Internal;
  friend class vtkInternals;
 
private:
  vtkPVSessionServer(const vtkPVSessionServer&) = delete;
  void operator=(const vtkPVSessionServer&) = delete;
};
 
#endif