vtkTCPNetworkAccessManager is a concrete implementation of vtkNetworkAccessManager that uses tcp/ip sockets for communication between processes. More...
#include <vtkTCPNetworkAccessManager.h>
Public Types | |
typedef vtkNetworkAccessManager | Superclass |
![]() | |
enum | ConnectionResult { ConnectionResult::CONNECTION_SUCCESS, ConnectionResult::CONNECTION_TIMEOUT, ConnectionResult::CONNECTION_ABORT, ConnectionResult::CONNECTION_HANDSHAKE_ERROR, ConnectionResult::CONNECTION_FAILURE } |
Possible result of connection when creating a new connection CONNECTION_SUCCESS: Connection was sucessfull CONNECTION_TIMEOUT: After spending a specified amount of time, no connection was initiated CONNECTION_ABORT: User aborted the connection before it was successful or timed out CONNECTION_HANDSHAKE_ERROR: Connection was iniated but the handshake failed CONNECTION_FAILURE: Unspecified connection error. More... | |
typedef vtkObject | Superclass |
Public Member Functions | |
virtual const char * | GetClassName () |
virtual int | IsA (const char *type) |
void | PrintSelf (ostream &os, vtkIndent indent) override |
void | AbortPendingConnection () override |
Used to abort pending connection creation, if any. More... | |
int | ProcessEvents (unsigned long timeout_msecs) override |
Process any network activity. More... | |
bool | GetNetworkEventsAvailable () override |
Peeks to check if any activity is available. More... | |
bool | GetPendingConnectionsPresent () override |
Returns true is the manager is currently waiting for any connections. More... | |
void | DisableFurtherConnections (int port, bool disable) override |
Enable/disable further connections for given port. More... | |
bool | GetWrongConnectID () override |
Returns true if the last check of connect ids was wrong. More... | |
vtkMultiProcessController * | NewConnection (const char *url, vtkNetworkAccessManager::ConnectionResult &result) override |
Creates a new connection given the url. More... | |
![]() | |
virtual vtkMultiProcessController * | NewConnection (const char *url) |
Creates a new connection given the url. More... | |
![]() | |
vtkBaseTypeMacro (vtkObject, vtkObjectBase) | |
virtual void | DebugOn () |
virtual void | DebugOff () |
bool | GetDebug () |
void | SetDebug (bool debugFlag) |
virtual void | Modified () |
virtual vtkMTimeType | GetMTime () |
void | RemoveObserver (unsigned long tag) |
void | RemoveObservers (unsigned long event) |
void | RemoveObservers (const char *event) |
void | RemoveAllObservers () |
int | HasObserver (unsigned long event) |
int | HasObserver (const char *event) |
int | InvokeEvent (unsigned long event) |
int | InvokeEvent (const char *event) |
unsigned long | AddObserver (unsigned long event, vtkCommand *, float priority=0.0f) |
unsigned long | AddObserver (const char *event, vtkCommand *, float priority=0.0f) |
vtkCommand * | GetCommand (unsigned long tag) |
void | RemoveObserver (vtkCommand *) |
void | RemoveObservers (unsigned long event, vtkCommand *) |
void | RemoveObservers (const char *event, vtkCommand *) |
int | HasObserver (unsigned long event, vtkCommand *) |
int | HasObserver (const char *event, vtkCommand *) |
unsigned long | AddObserver (unsigned long event, U observer, void(T::*callback)(), float priority=0.0f) |
unsigned long | AddObserver (unsigned long event, U observer, void(T::*callback)(vtkObject *, unsigned long, void *), float priority=0.0f) |
unsigned long | AddObserver (unsigned long event, U observer, bool(T::*callback)(vtkObject *, unsigned long, void *), float priority=0.0f) |
int | InvokeEvent (unsigned long event, void *callData) |
int | InvokeEvent (const char *event, void *callData) |
unsigned long | AddObserver (unsigned long event, vtkCommand *, float priority=0.0f) |
unsigned long | AddObserver (const char *event, vtkCommand *, float priority=0.0f) |
vtkCommand * | GetCommand (unsigned long tag) |
void | RemoveObserver (vtkCommand *) |
void | RemoveObservers (unsigned long event, vtkCommand *) |
void | RemoveObservers (const char *event, vtkCommand *) |
int | HasObserver (unsigned long event, vtkCommand *) |
int | HasObserver (const char *event, vtkCommand *) |
unsigned long | AddObserver (unsigned long event, U observer, void(T::*callback)(), float priority=0.0f) |
unsigned long | AddObserver (unsigned long event, U observer, void(T::*callback)(vtkObject *, unsigned long, void *), float priority=0.0f) |
unsigned long | AddObserver (unsigned long event, U observer, bool(T::*callback)(vtkObject *, unsigned long, void *), float priority=0.0f) |
int | InvokeEvent (unsigned long event, void *callData) |
int | InvokeEvent (const char *event, void *callData) |
![]() | |
const char * | GetClassName () const |
virtual void | Delete () |
virtual void | FastDelete () |
void | Print (ostream &os) |
virtual void | Register (vtkObjectBase *o) |
virtual void | UnRegister (vtkObjectBase *o) |
void | SetReferenceCount (int) |
virtual void | PrintHeader (ostream &os, vtkIndent indent) |
virtual void | PrintTrailer (ostream &os, vtkIndent indent) |
int | GetReferenceCount () |
void | PrintRevisions (ostream &) |
virtual void | PrintHeader (ostream &os, vtkIndent indent) |
virtual void | PrintTrailer (ostream &os, vtkIndent indent) |
int | GetReferenceCount () |
void | PrintRevisions (ostream &) |
Static Public Member Functions | |
static vtkTCPNetworkAccessManager * | New () |
static int | IsTypeOf (const char *type) |
static vtkTCPNetworkAccessManager * | SafeDownCast (vtkObject *o) |
![]() | |
static int | IsTypeOf (const char *type) |
static vtkNetworkAccessManager * | SafeDownCast (vtkObject *o) |
![]() | |
static vtkObject * | New () |
static void | BreakOnError () |
static void | SetGlobalWarningDisplay (int val) |
static void | GlobalWarningDisplayOn () |
static void | GlobalWarningDisplayOff () |
static int | GetGlobalWarningDisplay () |
static void | SetGlobalWarningDisplay (int val) |
static void | GlobalWarningDisplayOn () |
static void | GlobalWarningDisplayOff () |
static int | GetGlobalWarningDisplay () |
![]() | |
static vtkTypeBool | IsTypeOf (const char *name) |
static vtkObjectBase * | New () |
static vtkObjectBase * | New () |
Protected Member Functions | |
vtkTCPNetworkAccessManager () | |
~vtkTCPNetworkAccessManager () override | |
int | ProcessEventsInternal (unsigned long timeout_msecs, bool do_processing) |
vtkMultiProcessController * | ConnectToRemote (const char *hostname, int port, const char *handshake, int timeout_in_seconds, vtkNetworkAccessManager::ConnectionResult &result) |
Connects to remote processes. More... | |
vtkMultiProcessController * | WaitForConnection (int port, bool once, const char *handshake, bool nonblocking, vtkNetworkAccessManager::ConnectionResult &result) |
Waits for connection from remote process. More... | |
int | ParaViewHandshake (vtkMultiProcessController *controller, bool server_side, const char *handshake) |
void | PrintHandshakeError (int errorcode, bool server_side) |
int | AnalyzeHandshakeAndGetErrorCode (const char *clientHS, const char *serverHS) |
![]() | |
vtkNetworkAccessManager () | |
~vtkNetworkAccessManager () override | |
![]() | |
vtkObject () | |
virtual | ~vtkObject () |
void | RegisterInternal (vtkObjectBase *, vtkTypeBool check) VTK_OVERRIDE |
void | UnRegisterInternal (vtkObjectBase *, vtkTypeBool check) VTK_OVERRIDE |
void | InternalGrabFocus (vtkCommand *mouseEvents, vtkCommand *keypressEvents=NULL) |
void | InternalReleaseFocus () |
void | InternalGrabFocus (vtkCommand *mouseEvents, vtkCommand *keypressEvents=NULL) |
void | InternalReleaseFocus () |
![]() | |
vtkObjectBase () | |
virtual | ~vtkObjectBase () |
virtual void | CollectRevisions (ostream &) |
virtual void | ReportReferences (vtkGarbageCollector *) |
vtkObjectBase (const vtkObjectBase &) | |
void | operator= (const vtkObjectBase &) |
Protected Attributes | |
bool | AbortPendingConnectionFlag |
bool | WrongConnectID |
![]() | |
bool | Debug |
vtkTimeStamp | MTime |
vtkSubjectHelper * | SubjectHelper |
![]() | |
vtkAtomicInt32 | ReferenceCount |
vtkWeakPointerBase ** | WeakPointers |
vtkTCPNetworkAccessManager is a concrete implementation of vtkNetworkAccessManager that uses tcp/ip sockets for communication between processes.
It supports urls that use "tcp" as their protocol specifier.
Definition at line 19 of file vtkTCPNetworkAccessManager.h.
Definition at line 23 of file vtkTCPNetworkAccessManager.h.
|
protected |
Enumerator | |
---|---|
HANDSHAKE_NO_ERROR | |
HANDSHAKE_SOCKET_COMMUNICATOR_DIFFERENT | |
HANDSHAKE_DIFFERENT_PV_VERSIONS | |
HANDSHAKE_DIFFERENT_CONNECTION_IDS | |
HANDSHAKE_DIFFERENT_RENDERING_BACKENDS | |
HANDSHAKE_UNKNOWN_ERROR |
Definition at line 122 of file vtkTCPNetworkAccessManager.h.
|
protected |
|
overrideprotected |
|
static |
|
virtual |
Reimplemented from vtkNetworkAccessManager.
Reimplemented from vtkNetworkAccessManager.
|
static |
|
overridevirtual |
Reimplemented from vtkNetworkAccessManager.
|
overridevirtual |
Creates a new connection given the url.
This call may block until the connection can be established. To keep user-interfaces responsive, one can listen to the vtkCommand::ProgressEvent fired periodically by this class while waiting. The result arg provide information about the failure or sucess of the connection, see vtkNetworkAccessManager::ConnectionResult for possible values.
vtkNetworkAccessManager can be waiting for atmost one connection at a time. Calling NewConnection() while another connection is pending will raise an error.
To abort the connection and cancel the waiting, simply call AbortPendingConnection() in the vtkCommand::ProgressEvent callback.
Returns the new connection instance on success, otherwise nullptr.
URLs are of the following form: <transport>
://<address>
tcp://<hostname>
:<port>tcp://localhost
:<port>/listen – listen for connection on port.tcp://localhost
:<port>/listenmultiple – listen for multiple Examples:tcp://medea
:12345tcp://localhost
:12345/listenssh://utkarsh@medea
Implements vtkNetworkAccessManager.
|
overridevirtual |
Used to abort pending connection creation, if any.
Refer to NewConnection() for details.
Implements vtkNetworkAccessManager.
|
overridevirtual |
Process any network activity.
Implements vtkNetworkAccessManager.
|
overridevirtual |
Peeks to check if any activity is available.
When this call returns true, ProcessEvents() will always result in some activity processing if called afterword.
Implements vtkNetworkAccessManager.
|
overridevirtual |
Returns true is the manager is currently waiting for any connections.
Implements vtkNetworkAccessManager.
|
overridevirtual |
Enable/disable further connections for given port.
Implements vtkNetworkAccessManager.
|
overridevirtual |
Returns true if the last check of connect ids was wrong.
Implements vtkNetworkAccessManager.
|
protected |
|
protected |
Connects to remote processes.
|
protected |
Waits for connection from remote process.
|
protected |
|
protected |
|
protected |
|
protected |
Definition at line 137 of file vtkTCPNetworkAccessManager.h.
|
protected |
Definition at line 138 of file vtkTCPNetworkAccessManager.h.