---

CAVERNnet_perfMonitor_c.hxx

/******************************************************************
 * CAVERNsoft
 * Copyright (C) 1994-2000 Electronic Visualization Laboratory,
 * all rights reserved
 * By Jason Leigh, Yong-joo Cho, Naveen Krishnaprasad, Chris Scharver,
 * Stuart Bailey, Atul Nayak, Shalini Venkataraman
 * University of Illinois at Chicago
 * 
 * This publication and its text and code may not be copied for commercial 
 * use without the express written permission of the University of Illinois
 * at Chicago.
 * The contributors disclaim any representation of warranty: use this
 * code at your own risk.
 * Direct questions, comments etc to cavern@evl.uic.edu
 ******************************************************************/

#ifndef _CAVERNNET_PERFMONITOR_C
#define _CAVERNNET_PERFMONITOR_C

#ifdef CAVERN_USE_GLOBUS_THREADS
#include "globus_common.h"
#endif

#ifdef CAVERN_USE_PTHREADS
#include <pthread.h>
#endif

#include <errno.h>

#include "CAVERNnet_socketbase_c.hxx"
#include "CAVERNnet_perfDaemon_c.hxx"

#define DEFAULT_BUFFER_SIZE 1024
#define _STREAM_INFO_SIZE 256

class CAVERNnet_perfDaemonClient_c;


class CAVERNnet_perfMonitor_c: public CAVERNnet_socketbase_c
{
public:
    


    static const int OK; //=0
    
    static const int FAILED;  //=1
    CAVERNnet_perfMonitor_c();

    ~CAVERNnet_perfMonitor_c();

    //set the source and destination IPs of the machines communicating over the network - not to be used by the user
    void setIPs(char* selfIp, char* remoteIp);
   
    //set the source and destination ports of the machines communicating over the network - not to be used by the user

    void setPorts(int selfPort, int remotePort);
    
    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 = CAVERNnet_perfDaemon_c::DEFAULT_PORT);
    
    void exitSendStats();
    
private:

    //source and destination IP's of the machines communicating over the network
    char *selfIp, *remoteIp;
    
   //source and destination ports of the machines communicating over the network    

    int selfPort, remotePort;
    
    //The buffer in which the resultant stats is stored in netlogger format

    char* resultantStats;
    
    //A perfDaemonClient used to connect to a perfDaemon to send the resultant statistics

    CAVERNnet_perfDaemonClient_c* aClient;
    
    //Upate the performance statistics
    void updateStats(char* streamInfo, char* comment);
    
    
};




#endif

---