---

CAVERNnet_parallelTcp_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_PARALLEL_TCP_C
#define _CAVERNPLUS_PARALLEL_TCP_C

#include "CAVERNnet_socketbase_c.hxx"
#include "CAVERNnet_datapack_c.hxx"

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

class CAVERNnet_parallelTcpClient_c : public CAVERNnet_socketbase_c
{ 
public:
        CAVERNnet_parallelTcpClient_c();
    ~CAVERNnet_parallelTcpClient_c();



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

    int write( char* buffer, int* length );

    int read( char* buffer, int* length );


    void close();

        int connectToServer(char *RemoteName, int RemotePort, int Size);



        unsigned int getRemoteIP();

        void getRemoteIP(char* name);

        unsigned int getSelfIP();

        void getSelfIP(char *name);

        int  getSelfPort();

        int  getRemotePort();

public:
        /* These functions are provided to be used in CAVERNnet_parallelTcpServer_c only. */
        void setSockets(int* Sockets, int NumSockets);/* { 
        sockets = Sockets;
        numSockets = NumSockets; 
        for (int i = 0; i < NumSockets; i++) {
            if (sockets[i] > maxSockDesc) maxSockDesc = sockets[i];
        }
        pcReadPtr = new char *[NumSockets];
        pcWritePtr = new char *[NumSockets];
        piBytesLeft = new int[NumSockets];
    }*/

protected:
        /* Not to be called by user */
        void makeNonBlocking(int Sockfd);
        int connectToClient(char* RemoteName, unsigned short RemotePort, 
                                                int& SocketInfo);

        char** pcReadPtr;
        char** pcWritePtr;
        int* piBytesLeft;
        int* sockets;    
        fd_set fdSet;
    int maxSockDesc;
    int numSockets;
    struct sockaddr_in remoteAddr;
    struct sockaddr_in localAddr;   
};

class CAVERNnet_parallelTcpServer_c : public CAVERNnet_socketbase_c
{
public:

        static const int OK/* = 1*/;

        static const int FAILED/* = 0*/;


        CAVERNnet_parallelTcpServer_c() {};
        ~CAVERNnet_parallelTcpServer_c() 
        { 
#ifdef WIN32
                if (sockfd > 0) closesocket(sockfd); 
#else
                if (sockfd > 0) ::close(sockfd);
#endif
        }

        int init(int port);

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

        CAVERNnet_parallelTcpClient_c *checkForNewConnections();

        unsigned int getSelfIP();

        int getSelfPort() { return ntohs(serverInfo.sin_port); };

protected:
        void makeNonBlocking(int Sockfd);
        int connectToClient(unsigned long RemoteAddr, unsigned short RemotePort, 
                                                int& SocketInfo);

        struct sockaddr_in  serverInfo;
        int sockfd;
};

#endif

---