Main Page   Class Hierarchy   Compound List   File List   Compound Members  

SmartSockets::TipcConn Class Reference

#include <tconn.h>

Inheritance diagram for SmartSockets::TipcConn::

SmartSockets::TipcConnClient SmartSockets::TipcConnServer SmartSockets::TipcSrv List of all members.

Public Methods

virtual ~TipcConn () throw ()
 Destructor.

 operator T_IPC_CONN () const throw ()
 operator.

virtual bool check (T_IO_CHECK_MODE check_mode, real8 timeout) throw (TipcException)
virtual void flush () throw (TipcException)
virtual sock getSocket () const throw (TipcException)
virtual int4 getNumQueued () const throw (TipcException)
virtual sock getXtSource () const throw (TipcException)
virtual void keepAlive () throw (TipcException)
virtual bool mainLoop (real8 timeout=T_TIMEOUT_FOREVER) throw (TipcException)
virtual void insert (TipcMsg &msg, int4 pos) throw (TipcException)
virtual void process (TipcMsg &msg) throw (TipcException)
void read (real8 timeout) throw (TipcException)
virtual void next (TipcMsg &msg, real8 timeout) throw (TipcException)
virtual bool nextEx (TipcMsg &msg, real8 timeout) throw (TipcException)
virtual void search (TipcMsg &msg, TipcConnSearchSelector *selObj, real8 timeout) throw (TipcException)
virtual void searchType (TipcMsg &msg, TipcMt &mt, real8 timeout) throw (TipcException)
virtual void send (const TipcMsg &msg, bool rtserver_check=FALSE) throw (TipcException)
virtual void sendRpc (TipcMsg &reply_msg, const TipcMsg &call_msg, real8 timeout) throw (TipcException)
void write (TipcMt &mt,...) throw (TipcException)
void writeVa (TipcMt &mt, va_list var_arg_list) throw (TipcException)
virtual void print (T_OUT_FUNC func=(T_OUT_FUNC) TutOut) const throw (TipcException)
virtual CallBack< MessageQueueCallBack > * queueCbCreate (const TipcMt &mt, MessageQueueCallBack *, void *arg=NULL) throw (TipcException)
virtual CallBack< ErrorCallBack > * errorCbCreate (ErrorCallBack *implementor, void *arg=NULL) throw (TipcException)
virtual CallBack< MessageCallBack > * encryptCbCreate (const TipcMt &mt, MessageCallBack *implementor, void *arg=NULL) throw (TipcException)
virtual CallBack< MessageCallBack > * decryptCbCreate (const TipcMt &mt, MessageCallBack *implementor, void *arg=NULL) throw (TipcException)
virtual CallBack< MessageCallBack > * defaultCbCreate (MessageCallBack *implementor, void *arg=NULL) throw (TipcException)
virtual CallBack< MessageCallBack > * processCbCreate (const TipcMt &mt, MessageCallBack *implementor, void *arg=NULL) throw (TipcException)
virtual CallBack< MessageCallBack > * readCbCreate (const TipcMt &mt, MessageCallBack *implementor, void *arg=NULL) throw (TipcException)
virtual CallBack< MessageCallBack > * writeCbCreate (const TipcMt &mt, MessageCallBack *implementor, void *arg=NULL) throw (TipcException)
virtual CallBack< EncodeCallBack > * encodeCbCreate (EncodeCallBack *implementor, void *arg=NULL) throw (TipcException)
virtual CallBack< DecodeCallBack > * decodeCbCreate (DecodeCallBack *impleemntor, void *arg=NULL) throw (TipcException)
virtual const char * getPeerUniqueSubject () const throw (TipcException)
virtual const char * getNode () const throw (TipcException)
virtual const char * getUser () const throw (TipcException)
virtual int4 getPid () const throw (TipcException)
virtual const char * getArch () const throw (TipcException)
virtual void gmdFileCreate () throw (TipcException)
virtual void gmdFileDelete () throw (TipcException)
virtual void gmdResend () throw (TipcException)
virtual void gmdMsgDelete (TipcMsg &msg) throw (TipcException)
virtual void gmdMsgResend (TipcMsg &msg) throw (TipcException)
const char * getGmdDir () const throw (TipcException)
virtual int4 getGmdNumPending () const throw (TipcException)
virtual int4 trafficGetBytesRecv () const throw (TipcException)
virtual int8 trafficGetBytesRecv8 () const throw (TipcException)
virtual int4 trafficGetBytesSent () const throw (TipcException)
virtual int8 trafficGetBytesSent8 () const throw (TipcException)
virtual int4 trafficGetMsgsRecv () const throw (TipcException)
virtual int8 trafficGetMsgsRecv8 () const throw (TipcException)
virtual int4 trafficGetMsgsSent () const throw (TipcException)
virtual int8 trafficGetMsgsSent8 () const throw (TipcException)
virtual int4 bufferGetReadSize () const throw (TipcException)
virtual int4 bufferGetWriteSize () const throw (TipcException)
 TipcConn () throw (TipcException)
 TipcConn (T_IPC_CONN connection, bool destroy_flag=true) throw (TipcException)
virtual int4 getAutoFlushSize () const throw (TipcException)
virtual void setAutoFlushSize (int4 auto_flush_size) throw (TipcException)
virtual long getBlockMode () const throw (TipcException)
virtual void setBlockMode (bool block_mode) throw (TipcException)
virtual real8 getTimeout (T_IPC_TIMEOUT timeout) const throw (TipcException)
virtual void setTimeout (T_IPC_TIMEOUT timeout, real8 value) throw (TipcException)
virtual void lock () throw (TipcException)
virtual void unlock () throw (TipcException)
virtual uint4 getGmdMaxSize () const throw (TipcException)
virtual void setGmdMaxSize (uint4 gmd_max_size) throw (TipcException)

Protected Methods

 TipcConn (bool do_nothing)

Static Protected Methods

void T_ENTRY1 errorCbDelegator (T_IPC_CONN connection, T_IPC_CONN_ERROR_CB_DATA data, T_CB_ARG arg)
void T_ENTRY1 queueCbDelegator (T_IPC_CONN connection, T_IPC_CONN_QUEUE_CB_DATA data, T_CB_ARG arg)
void T_ENTRY1 messageCbDelegator (T_IPC_CONN connection, T_IPC_CONN_MSG_CB_DATA data, T_CB_ARG arg)
void T_ENTRY1 readCbDelegator (T_IPC_CONN connection, T_IPC_CONN_READ_CB_DATA data, T_CB_ARG arg)
void T_ENTRY1 encodeCbDelegator (T_IPC_CONN connection, T_IPC_CONN_ENCODE_CB_DATA data, T_CB_ARG arg)
void T_ENTRY1 decodeCbDelegator (T_IPC_CONN connection, T_IPC_CONN_DECODE_CB_DATA data, T_CB_ARG arg)

Protected Attributes

T_IPC_CONN _connection
 C style T_IPC_CONN handle to the connection.

bool _destroy_flag

Detailed Description

TipcConn - user class for a dummy connection and base class for all other connection classes

The TipcConn class calls the C API function TipcConnCreate at construction. It manages the resulting T_IPC_CONN object internally.

Constructor & Destructor Documentation

SmartSockets::TipcConn::TipcConn (  bool    do_nothing )  [protected]
 

Constructor

Parameters:
do_nothing  - if this is FALSE, it creates a connection

SmartSockets::TipcConn::TipcConn (    )  throw (TipcException)
 

Constructors

Parameters:
connection  - the C Style T_IPC_CONN handle
destroy_flag  - flag for destroy
Exceptions:
TipcConnException 

Member Function Documentation

virtual int4 SmartSockets::TipcConn::bufferGetReadSize (    )  const throw (TipcException) [virtual]
 

Gets the total number of bytes in the connection's read buffer.

Returns:
the total bytes in the connection's read buffer.
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual int4 SmartSockets::TipcConn::bufferGetWriteSize (    )  const throw (TipcException) [virtual]
 

Gets the total number of bytes in the connection's write buffer.

Returns:
the total bytes in the connection's write buffer.
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual bool SmartSockets::TipcConn::check (  T_IO_CHECK_MODE    check_mode,
real8    timeout
)  throw (TipcException) [virtual]
 

Check if data can be read from or written to connection.

Parameters:
check_mode  - value for the check mode, enum value
timeout  - timeout
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual CallBack<DecodeCallBack>* SmartSockets::TipcConn::decodeCbCreate (  DecodeCallBack *    impleemntor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates a decode callback.

Parameters:
implementor  an encode callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

void T_ENTRY1 SmartSockets::TipcConn::decodeCbDelegator (  T_IPC_CONN    connection,
T_IPC_CONN_DECODE_CB_DATA    data,
T_CB_ARG    arg
)  [static, protected]
 

Delegator method for decode callbacks. Will be called when the callback is triggered and will in turn call the callback's handler method.

Parameters:
connection  the connection on which the callback was triggered
data  the message queue callback data (contains the old and new packet information and the original message for which the callback applies)
arg  the callback object

virtual CallBack<MessageCallBack>* SmartSockets::TipcConn::decryptCbCreate (  const TipcMt &    mt,
MessageCallBack *    implementor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates a decryption callback.

Parameters:
mt  the message type for the callback
implementor  a decryption callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

Reimplemented in SmartSockets::TipcSrv.

virtual CallBack<MessageCallBack>* SmartSockets::TipcConn::defaultCbCreate (  MessageCallBack *    implementor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates a default callback.

Parameters:
implementor  a messagen callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

Reimplemented in SmartSockets::TipcSrv.

virtual CallBack<EncodeCallBack>* SmartSockets::TipcConn::encodeCbCreate (  EncodeCallBack *    implementor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates an encode callback.

Parameters:
implementor  an encode callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

void T_ENTRY1 SmartSockets::TipcConn::encodeCbDelegator (  T_IPC_CONN    connection,
T_IPC_CONN_ENCODE_CB_DATA    data,
T_CB_ARG    arg
)  [static, protected]
 

Delegator method for encode callbacks. Will be called when the callback is triggered and will in turn call the callback's handler method.

Parameters:
connection  the connection on which the callback was triggered
data  the message queue callback data (contains the old and new packet information for which the callback applies)
arg  the callback object

virtual CallBack<MessageCallBack>* SmartSockets::TipcConn::encryptCbCreate (  const TipcMt &    mt,
MessageCallBack *    implementor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates an encryption callback.

Parameters:
mt  the message type for the callback
implementor  an encryption callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

Reimplemented in SmartSockets::TipcSrv.

virtual CallBack<ErrorCallBack>* SmartSockets::TipcConn::errorCbCreate (  ErrorCallBack *    implementor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates an error callback.

Parameters:
implementor  an error callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

Reimplemented in SmartSockets::TipcSrv.

void T_ENTRY1 SmartSockets::TipcConn::errorCbDelegator (  T_IPC_CONN    connection,
T_IPC_CONN_ERROR_CB_DATA    data,
T_CB_ARG    arg
)  [static, protected]
 

Delegator method for error callbacks. Will be called when the callback is triggered and will in turn call the callback's handler method.

Parameters:
connection  the connection on which the callback was triggered
data  the subject callback data (does not really apply for error callbacks, but all delegator methods need this same signature)
arg  the callback object

virtual void SmartSockets::TipcConn::flush (    )  throw (TipcException) [virtual]
 

Flush buffered outgoing messages on the connection.

Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual const char* SmartSockets::TipcConn::getArch (    )  const throw (TipcException) [virtual]
 

Determine the architecture name of the connected server.

Returns:
the architecture name to the connected server
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual int4 SmartSockets::TipcConn::getAutoFlushSize (    )  const throw (TipcException) [virtual]
 

Accessor methods; get and sets thhe auto_flush_size of a connection to the RTserver

Parameters:
auto_flush_size  - the value to be set
Returns:
the auto flush size that is set.
Exceptions:
TipcConnException  if the operation fails.

Reimplemented in SmartSockets::TipcSrv.

virtual long SmartSockets::TipcConn::getBlockMode (    )  const throw (TipcException) [virtual]
 

Get/Set the block mode of a connection.

Parameters:
block_mode  - flag for block mode
Returns:
the value set for the block mode
Exceptions:
TipcConnException 

const char* SmartSockets::TipcConn::getGmdDir (    )  const throw (TipcException)
 

Get name of directory where files are written for guaranteed message delivery.

Returns:
the directory name where the GMD files are written
Exceptions:
TipcConnException 

virtual uint4 SmartSockets::TipcConn::getGmdMaxSize (    )  const throw (TipcException) [virtual]
 

Get/Set the GMD area maximum size of the connection to RTserver.

Parameters:
gmd_max_size  - value to be set for the maximum GMD area
Returns:
the maximum size of the GMD area
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual int4 SmartSockets::TipcConn::getGmdNumPending (    )  const throw (TipcException) [virtual]
 

Determine the number of outgoing GMD messages still pending on the connection.

Returns:
the number of GMD messages pending
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual const char* SmartSockets::TipcConn::getNode (    )  const throw (TipcException) [virtual]
 

Determine the node name of the connected server.

Returns:
the node information
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual int4 SmartSockets::TipcConn::getNumQueued (    )  const throw (TipcException) [virtual]
 

Get number of queued messages from the connection.

Returns:
the number of queued messages
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual const char* SmartSockets::TipcConn::getPeerUniqueSubject (    )  const throw (TipcException) [virtual]
 

Determine the unique subject of the connected server.

Returns:
the unique subject
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual int4 SmartSockets::TipcConn::getPid (    )  const throw (TipcException) [virtual]
 

Determine the process ID of the connected server.

Returns:
the Pid information
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual sock SmartSockets::TipcConn::getSocket (    )  const throw (TipcException) [virtual]
 

Determine the socket of the connection.

Returns:
the socket information
Exceptions:
TipcConnException  if the socket information could not be retrieved

Reimplemented in SmartSockets::TipcSrv.

virtual real8 SmartSockets::TipcConn::getTimeout (  T_IPC_TIMEOUT    timeout )  const throw (TipcException) [virtual]
 

Accessor methods; Get/Set a timeout property from the connection.

Parameters:
auto_flush_size  - the value to be set
Returns:
the timeout which is set.
Exceptions:
TipcConnException  if the operation fails.

Reimplemented in SmartSockets::TipcSrv.

virtual const char* SmartSockets::TipcConn::getUser (    )  const throw (TipcException) [virtual]
 

Determine the user name of the connected server.

Returns:
the user information
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual sock SmartSockets::TipcConn::getXtSource (    )  const throw (TipcException) [virtual]
 

Get source for XtAppAddInput from the connection.

Returns:
source for XtAppAddInput
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::gmdFileCreate (    )  throw (TipcException) [virtual]
 

Create guaranteed message delivery area on the connection to RTserver.

Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::gmdFileDelete (    )  throw (TipcException) [virtual]
 

Delete guaranteed message delivery files for the connection to RTserver.

Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::gmdMsgDelete (  TipcMsg &    msg )  throw (TipcException) [virtual]
 

Delete a message from the GMD area after a GMD failure on the connection toRTserver.

Parameters:
msg  - message to delete
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::gmdMsgResend (  TipcMsg &    msg )  throw (TipcException) [virtual]
 

Resend a message after a GMD failure on the connection to RTserver.

Parameters:
msg  - message to resend
Exceptions:
TipcConnException 

virtual void SmartSockets::TipcConn::gmdResend (    )  throw (TipcException) [virtual]
 

Resend all guaranteed messages after a delivery failure on the connection toRTserver.

Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::insert (  TipcMsg &    msg,
int4    pos
)  throw (TipcException) [virtual]
 

Insert a message into the queue of the connection.

Parameters:
msg  - message to be inserted
pos  - position at which the message to be inserted
Exceptions:
TipcConnException  if the insertion fails

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::keepAlive (    )  throw (TipcException) [virtual]
 

Check if the server connection is still alive.

Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::lock (    )  throw (TipcException) [virtual]
 

Acquire/Release exclusive access to the connection

Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual bool SmartSockets::TipcConn::mainLoop (  real8    timeout = T_TIMEOUT_FOREVER )  throw (TipcException) [virtual]
 

Read and process messages on the connection to the RTserver.

Parameters:
timeout  - value that determines the timeout period
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

void T_ENTRY1 SmartSockets::TipcConn::messageCbDelegator (  T_IPC_CONN    connection,
T_IPC_CONN_MSG_CB_DATA    data,
T_CB_ARG    arg
)  [static, protected]
 

Delegator method for message callbacks. Will be called when the callback is triggered and will in turn call the callback's handler method.

Parameters:
connection  the connection on which the callback was triggered
data  the message queue callback data (contains the message for which the callback applies)
arg  the callback object

virtual void SmartSockets::TipcConn::next (  TipcMsg &    msg,
real8    timeout
)  throw (TipcException) [virtual]
 

Retrieve the next message from the connection.

Parameters:
-  msg place holder object for return value.
timeout  - the value that determines the timeout period
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual bool SmartSockets::TipcConn::nextEx (  TipcMsg &    msg,
real8    timeout
)  throw (TipcException) [virtual]
 

Retrieve the next message from the connection.

Parameters:
msg  - place holder object for return value.
timeout  - the value that determines the timeout period
Exceptions:
TipcConnException  if an error occurs.
Returns:
false if the timeout is expired, true otherwise.

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::print (  T_OUT_FUNC    func = (T_OUT_FUNC) TutOut )  const throw (TipcException) [virtual]
 

Print information about the connection.

Parameters:
func  - the TutOut object containing the info to print
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::process (  TipcMsg &    msg )  throw (TipcException) [virtual]
 

Process a message in the connection.

Parameters:
msg  - message to be processed
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual CallBack<MessageCallBack>* SmartSockets::TipcConn::processCbCreate (  const TipcMt &    mt,
MessageCallBack *    implementor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates a process callback.

Parameters:
mt  the message type for the callback
implementor  a messagen callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

Reimplemented in SmartSockets::TipcSrv.

virtual CallBack<MessageQueueCallBack>* SmartSockets::TipcConn::queueCbCreate (  const TipcMt &    mt,
MessageQueueCallBack *    implementor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates a message queue callback.

Parameters:
mt  the message type for the callback
implementor  a message queue callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

Reimplemented in SmartSockets::TipcSrv.

void T_ENTRY1 SmartSockets::TipcConn::queueCbDelegator (  T_IPC_CONN    connection,
T_IPC_CONN_QUEUE_CB_DATA    data,
T_CB_ARG    arg
)  [static, protected]
 

Delegator method for message queue callbacks. Will be called when the callback is triggered and will in turn call the callback's handler method.

Parameters:
connection  the connection on which the callback was triggered
data  the message queue callback data (contains the message for which the callback applies and the message's position and insertion information)
arg  the callback object

void SmartSockets::TipcConn::read (  real8    timeout )  throw (TipcException)
 

Read all available data from the connection to RTserver and queue messages in priority order.

Parameters:
timeout  - timeout value, until which the read operation can be performed.
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual CallBack<MessageCallBack>* SmartSockets::TipcConn::readCbCreate (  const TipcMt &    mt,
MessageCallBack *    implementor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates a read callback.

Parameters:
mt  the message type for the callback
implementor  a messagen callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

Reimplemented in SmartSockets::TipcSrv.

void T_ENTRY1 SmartSockets::TipcConn::readCbDelegator (  T_IPC_CONN    connection,
T_IPC_CONN_READ_CB_DATA    data,
T_CB_ARG    arg
)  [static, protected]
 

Delegator method for read callbacks. Will be called when the callback is triggered and will in turn call the callback's handler method.

Parameters:
connection  the connection on which the callback was triggered
data  the message queue callback data (contains the message for which the callback applies)
arg  the callback object

virtual void SmartSockets::TipcConn::search (  TipcMsg &    msg,
TipcConnSearchSelector *    selObj,
real8    timeout
)  throw (TipcException) [virtual]
 

Search the message queue of the connection for a specific message

Parameters:
msg  - TipcMsg object which is the result of the search
selObj  - the object to be searched for
timeout  - timeout value, until which the search can be performed
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::searchType (  TipcMsg &    msg,
TipcMt &    mt,
real8    timeout
)  throw (TipcException) [virtual]
 

Search the message queue of the connection for a message with a specific type.

Parameters:
msg  - TipcMsg object which is the result of the search
mt  - TipcMt object; message type
timeout  - the timeout value until which the search can be performed
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::send (  const TipcMsg &    msg,
bool    check_server_msg_send = FALSE
)  throw (TipcException) [virtual]
 

Send a message through the connection. For connections, the rtserver_check flag is defaulted and ignored. The TipcSrv derived class version of this virtual fn will use it.

Parameters:
msg  - message to sent it through the RTserver
rtserver_check  - flag for check server message send
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual void SmartSockets::TipcConn::sendRpc (  TipcMsg &    reply_msg,
const TipcMsg &    call_msg,
real8    timeout
)  throw (TipcException) [virtual]
 

Make a remote procedure call (RPC) with messages on the connection.

Parameters:
msg  - message to sent it through the RTserver
call_msg  - message to be sent through Rpc
timeout  - timeout value, until which the operation to be performed
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual int4 SmartSockets::TipcConn::trafficGetBytesRecv (    )  const throw (TipcException) [virtual]
 

Gets the total number of bytes received on the connection.

Returns:
the total bytes received on the connection.
Exceptions:
TipcConnException 
Note:
The result is truncated to 31 bits, and may contain an incorrect sign bit on some older clients. New clients should use trafficGetBytesRecv8.
See also:
trafficGetBytesRecv8.
Deprecated:
This method is superseded by trafficGetBytesRecv8 as of SmartSockets 6.7

Reimplemented in SmartSockets::TipcSrv.

virtual int8 SmartSockets::TipcConn::trafficGetBytesRecv8 (    )  const throw (TipcException) [virtual]
 

Gets the total number of bytes received on the connection.

Returns:
the total bytes received on the connection.
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual int4 SmartSockets::TipcConn::trafficGetBytesSent (    )  const throw (TipcException) [virtual]
 

Gets the total number of bytes written to the write buffer on a connection. This number usually is the same as the total number of bytes actually sent on the connection, but sometimes the retrieved number is larger than the number of bytes sent when the write buffer is not frequently flushed.

Returns:
the total bytes written to the write buffer on the connection.
Exceptions:
TipcConnException 
Note:
The result is truncated to 31 bits, and may contain an incorrect sign bit on some older clients. New clients should use trafficGetBytesSent8.
See also:
trafficGetBytesSent8.
Deprecated:
This method is superseded by trafficGetBytesSent8 as of SmartSockets 6.7

Reimplemented in SmartSockets::TipcSrv.

virtual int8 SmartSockets::TipcConn::trafficGetBytesSent8 (    )  const throw (TipcException) [virtual]
 

Gets the total number of bytes written to the write buffer on a connection. This number usually is the same as the total number of bytes actually sent on the connection, but sometimes the retrieved number is larger than the number of bytes sent when the write buffer is not frequently flushed.

Returns:
the total bytes written to the write buffer on the connection.
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual int4 SmartSockets::TipcConn::trafficGetMsgsRecv (    )  const throw (TipcException) [virtual]
 

Gets the total number of messages received on the connection.

Returns:
the total number of messages received on the connection.
Exceptions:
TipcConnException 
Note:
The result is truncated to 31 bits, and may contain an incorrect sign bit on some older clients. New clients should use trafficGetMsgsRecv8.
See also:
trafficGetMsgsRecv8.
Deprecated:
This method is superseded by trafficGetMsgsRecv8 as of SmartSockets 6.7

Reimplemented in SmartSockets::TipcSrv.

virtual int8 SmartSockets::TipcConn::trafficGetMsgsRecv8 (    )  const throw (TipcException) [virtual]
 

Gets the total number of messages received on the connection.

Returns:
the total number of messages received on the connection.
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual int4 SmartSockets::TipcConn::trafficGetMsgsSent (    )  const throw (TipcException) [virtual]
 

Gets the total number of messages written to the write buffer on a connection. This number usually is the same as the total number of messages actually sent on the connection, but sometimes the retrieved number is larger than the number of messages sent when the write buffer is not frequently flushed.

Returns:
the total number of messages written to the write buffer on the connection.
Exceptions:
TipcConnException 
Note:
The result is truncated to 31 bits, and may contain an incorrect sign bit on some older clients. New clients should use trafficGetMsgsSent8.
See also:
trafficGetMsgsSent8.
Deprecated:
This method is superseded by trafficGetMsgsSent8 as of SmartSockets 6.7

Reimplemented in SmartSockets::TipcSrv.

virtual int8 SmartSockets::TipcConn::trafficGetMsgsSent8 (    )  const throw (TipcException) [virtual]
 

Gets the total number of messages written to the write buffer on a connection. This number usually is the same as the total number of messages actually sent on the connection, but sometimes the retrieved number is larger than the number of messages sent when the write buffer is not frequently flushed.

Returns:
the total number of messages written to the write buffer on the connection.
Exceptions:
TipcConnException 

Reimplemented in SmartSockets::TipcSrv.

virtual CallBack<MessageCallBack>* SmartSockets::TipcConn::writeCbCreate (  const TipcMt &    mt,
MessageCallBack *    implementor,
void *    arg = NULL
)  throw (TipcException) [virtual]
 

Creates a write callback.

Parameters:
mt  the message type for the callback
implementor  a messagen callback implementation
arg  argument data for the callback
Returns:
the constructed callback object
Exceptions:
TipcConnException  if creation of the callback fails

Reimplemented in SmartSockets::TipcSrv.

The documentation for this class was generated from the following file:
Generated on Fri Jul 14 15:05:55 2006 by doxygen1.2.12 written by Dimitri van Heesch, © 1997-2001