---

CAVERNnet_udp_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_UDP
#define _CAVERNNET_UDP

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

#ifdef WIN32
#include <winsock.h>
#elif defined(__sgi)
extern int h_errno;
#endif

//class CAVERNnet_perfMonitor_c;
//class CAVERNnet_perfDaemon_c;

class CAVERNnet_udp_c : public CAVERNnet_socketbase_c {

private:
        // Instrumentation flag.
        int enableInstr;

    // Socket file descriptor.
        int sockfd;

    // Timing flags for blocking mode.
        int timeOutStatus;
        int timeOutPeriod;              

    // Socket structures.
        struct sockaddr_in selfAddress, sendAddress, receiveAddress;

   //For performance monitoring
    CAVERNnet_perfMonitor_c pmonitor;

   // Socket blocking type.
        int typeOfBlocking;     

public:



        static const int OK/* = 1*/;

        static const int FAILED/* = 0*/;




        static const int BLOCKING/* = 1*/;

        static const int NON_BLOCKING/* = 2*/;

        static const int NULL_VALUE/* =3*/;




        static const int NO_TIME_OUT/* = -1*/;

        static const int DEFAULT_TIME_OUT/* = NO_TIME_OUT*/; 




        static const int SOCKET_NOT_OPEN/* = -1*/;

        static const int TIMED_OUT/* = -4*/;

        static const int NON_BLOCKING_NOT_READY_TO_WRITE /* =-5*/;

        static const int NON_BLOCKING_HAS_NO_DATA /* =-6*/;



        CAVERNnet_udp_c();

        void enableInstrumentation();

        void disableInstrumentation();

        void setTimeOut(int t) {timeOutPeriod = t;}

        int getTimeOut() {return timeOutPeriod;}

        int init(unsigned short port = 0);

        int setSendAddress(char *host, unsigned short port);

        void copyReceiveAddressToSendAddress();

        CAVERNnet_udp_c * clone();

        int send(char *message, int length, int blockingType = CAVERNnet_udp_c::NULL_VALUE);

        int receive(char *message, int length,  int blockingType = CAVERNnet_udp_c::NULL_VALUE);


        int peek(char *message, int length);

        void makeNonBlocking();



        unsigned long getReceiveIP();
        void getReceiveIP(char *ip);
        unsigned short getReceivePort();

        unsigned long getSendIP();
        void getSendIP(char *ip);
        unsigned short getSendPort();

        unsigned long getSelfIP();
        void getSelfIP(char *ip);
        unsigned short  getSelfPort();


        void printInfo();

#ifdef WIN32
        void close() {::closesocket(sockfd);}
#else
        void close() {::close(sockfd);}
#endif

    //Functions added for performance monitoring interface
    
    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();


};


#endif

---