#include <CAVERNnet_tcpReflector_c.hxx>
Public Methods | |
CAVERNnet_tcpReflectorClient_c () | |
CAVERNnet_tcpReflectorClient_c (CAVERNnet_tcpClient_c *) | |
Use this constructor if you have a pre-opened socket. | |
~CAVERNnet_tcpReflectorClient_c () | |
int | read (char **ret, int *nbytes, int blockingType) |
int | write (char *outgoingData, int *nbytes) |
int | isReadyToRead () |
int | isReadyToWrite () |
int | isReady () |
void | showStatus (int status, int nbytes) |
Show status of connection in English. | |
void | close () |
Close the current client connection. | |
int | connectToServer (char *ip, int port=CAVERNnet_tcpReflector_c::DEFAULT_PORT) |
void | setTimeOut (int timeout=CAVERNnet_tcpReflectorClient_c::NO_TIME_OUT) |
void | showStats (char *streamInfo, char *comment) |
int | logStats (char *streamInfo, char *comment, FILE *filePtr) |
int | sendStats (char *streamInfo, char *comment) |
int | initSendStats (char *monitorClientIP, int port=PERF_DAEMON_DEFAULT_PORT) |
void | exitSendStats () |
unsigned int | getRemoteIP () |
void | getRemoteIP (char *name) |
unsigned int | getSelfIP () |
Get IP address of self. | |
void | getSelfIP (char *name) |
Get IP address of self. | |
int | getSelfPort () |
Get port of self. | |
int | getRemotePort () |
Get port of client. | |
Static Public Attributes | |
const int | OK |
Status ok. | |
const int | FAILED |
Status failed. | |
const int | MEM_ALLOC_ERR |
Memory allocation error. | |
const int | NON_BLOCKING_HAS_NO_DATA |
A non-blocking read had no data available to read. | |
const int | CONNECTION_TERMINATED |
Connection terminated. | |
const int | NOT_READY |
Connection not ready for use. | |
const int | READY_TO_READ |
Connection has data available to read. | |
const int | READY_TO_WRITE |
Connection is ready to write. | |
const int | READY_TO_READ_AND_WRITE |
Connection has data available to read and is ready to write. | |
const int | BLOCKING |
const int | NON_BLOCKING |
const int | NO_TIME_OUT |
Private Attributes | |
CAVERNnet_tcpClient_c* | client |
int | timeOut |
int | connectionAlive |
|
Connect to a server.
|
|
Properly delete the perfDaemonClient after sendStats is done |
|
Get the IP address of remote connection. If you are a client this returns the ip of the destination server. If you are a server this returns the ip of the destination client. |
|
Get the IP address of remote connection. If you are a client this returns the ip of the destination server. If you are a server this returns the ip of the destination client. |
|
Initialize sendStats - provide the IP of the perfDaemon and an optional port number to connect to. This should be done initially before using the sendStats API.
|
|
Determines if a socket is ready to write or read or both. |
|
Determines if a socket has data available to read. |
|
Determines if a socket is ready to write. |
|
This logs performance statistics in a file. The user opens a file and passes the file pointer with this function and results of monitoring are written into the logfile.
|
|
Read data from a reflector (if available).
|
|
Sends the performance statistics to a remote perfdaemon -for further analysis of the monitored data - the initSendStats API should be called first, before calling a sendStats (In order to connect to the perfdaemon initially) (Note: A typical example of sendStats is given in the (CAVERN_DISTRIB_DIR/demos/tcpreflector/ directory)
|
|
Set timeout for read and writes. By default no time out is set. Setting time out means that if the read or write is unsuccessful after a certain amount of time the connection will be terminated. This is to prevent you from doing subsequent writes or reads from the stream and getting incorrect data. In order to re-establish the connection you need to instantiate another object of this type. |
|
Displays the resultant statistics instantaneously in the netlogger format - this should be typically done after a read/write is done a network. Also, it should be noted that a showStats call should be made at the end of atleast one send and receive for two-way information (the same applies for logStats and sendStats)
|
|
Write data to the reflector.
|