---

CAVERNnet_socketbase_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 _CAVERNPLUS_SOCKETBASE_C
#define _CAVERNPLUS_SOCKETBASE_C

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

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

#include <stdio.h>
#include <fcntl.h>
#include <time.h>
#include <string.h>
#include <stdio.h>
#include <math.h>
//#include <fstream.h>

#ifdef WIN32
#include <windows.h>
#include <winsock.h>
#include <sys\timeb.h>
#else
#include <unistd.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <sys/uio.h>
#include <arpa/inet.h>
#include <sys/errno.h>
#include <signal.h>
#include <netdb.h>
#include <unistd.h>
#include <sys/param.h>
#include <sys/time.h>
#endif

//These are the number of packets for which all calculations are done -this is to be changed as desired

#define LATENCY_BUF_SIZE 100
#define BANDWIDTH_BUF_SIZE 100

extern int errno;

class CAVERNnet_socketbase_c {
public:



        static const int OK/* = 1*/;
        static const int FAILED/* = 0*/;

        CAVERNnet_socketbase_c();

        static int hostnameToIP(char *hostname, char* hostIP);

        static void ipNumToString(unsigned int ip, char *ipstring);

        static double getTimeInSecs();

        static void getHostName(char *name, int len);

        static void expandHostName(char *src, char *newname, int len);

        unsigned int getTotalDataSent();

        unsigned int getTotalDataRead();

        double getInstantReceiveBandwidth();

        double getInstantSendBandwidth();

        double getAverageReceiveBandwidth();

        double getAverageSendBandwidth();

        void setInstantLatency(double lat);

        double getInstantLatency();

        double getAverageLatency();

        double getMaxLatency();

        double getMinLatency();

        void incrementDataSent(unsigned long size);

        void incrementDataRead(unsigned long size);

        double getInstantInterMesgDelay();

        double getMaxInterMesgDelay();

        double getMinInterMesgDelay();

        double getAverageInterMesgDelay();

    double getSTABandwidth();

    double getSTALatency();

    double getBurstiness();   

    double getJitter();

    unsigned long getPacketsRead();

    unsigned long getPacketsSent();

protected:
        double instLat, latTotal, minLat, maxLat, avgLat;
        unsigned long latCount,sentCount, readCount;
        double instDelay, totalDelay, minDelay, maxDelay, avgDelay, prevLocalTime;
        double currentTime, previousSentTime, previousReadTime,initialSentTime, initialReadTime;
        unsigned long prevTotalDataRead, prevTotalDataSent, totalDataRead, totalDataSent;
        double instReadBandwidth, instSendBandwidth, avgReadBandwidth, avgSendBandwidth;

        //STA - Short Term Average -calculated for  a specified number of packets (calcualted over a number of packets defined by LATENCY_BUF_SIZE)

    //Jitter is the average of the deviations of the instantaneous latencies from the STALatency

    //Burstiness(for bandwidths) is calculated the same way as Jitter is calculated for latencies

    double STALatency, STABandwidth, jitter, burstiness;

    //The latencies and bandwidth are stored in a buffer of defined size and the short term sums -(STlatencySum and STBandwidthSum) are calculated
    double latencyBuffer[LATENCY_BUF_SIZE];
    double bandwidthBuffer[BANDWIDTH_BUF_SIZE];  
    double STlatencySum, STbandwidthSum;

    //to simplify Short Term Average calculations
    int tempLatCounter, tempBWCounter;

        void computeInstantSendBandwidth();

    void computeInstantReceiveBandwidth();

        void computeAverageReceiveBandwidth();

    void computeAverageSendBandwidth();

    void calculateJitter(double lat);
    
    void calculateBurstiness(double bw);


};


#endif

---