---

CAVERNnet_remoteParallelFileIO32_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_remoteParallelFileIO32_c
#define _CAVERNnet_remoteParallelFileIO32_c

#include "CAVERN.hxx"
#include "CAVERNnet_extendedParallelTcp_c.hxx"
#include "CAVERNnet_datapack_c.hxx"
#include "CAVERNmisc_fileList_c.hxx"

#ifdef WIN32
#include <stdlib.h>
#define MAXPATHLEN      MAX_PATH
#else
#include <sys/param.h>
#endif

class CAVERNnet_remoteParallelFileIOServer32_c {
public:
        static const int DEFAULT_PORT/* = 7673*/;

        static const int THREADED/* = 1*/;

        static const int NON_THREADED/* = 0*/;

        int init(int incomingPort=CAVERNnet_remoteParallelFileIOServer32_c::DEFAULT_PORT,
                        char* neighborServer = NULL, 
                        int neighborPort = CAVERNnet_remoteParallelFileIOServer32_c::DEFAULT_PORT, 
                        int storeLocally = 1, int numOfSockets = 5);

        void process(int threaded = CAVERNnet_remoteParallelFileIOServer32_c::NON_THREADED);

        void setRemotePort(int port = CAVERNnet_remoteParallelFileIOServer32_c::DEFAULT_PORT) { 
                neighborPortNumber = port;
        }
        void setNeighborServer(char* ServerName) { 
                if (ServerName) strcpy(neighborServerName, ServerName);
                else neighborServerName[0] = '\0';
        }
        void setStore(int StoreLocally) { store = StoreLocally; }

        long getFileSize(FILE* readFile);

        static const int TRANSFERSIZE/* = 30000*/;

private:
        CAVERNnet_extendedParallelTcpServer_c server;
        char neighborServerName[MAXPATHLEN];
        int neighborPortNumber;
        int store;
        int numberOfSockets;

        static int getHostIPNumber(char* hostNameOrIP);
        static void* threadHandler(void*);
};

class CAVERNnet_remoteParallelFileIOClient32_c {
        public:


        static const int OK/* = 1*/;

        static const int FAILED/* = 0*/;

        static const int CANNOT_CONNECT/* = 2*/;

        static const int CANNOT_READ_LOCAL_FILE/* = 3*/;

        static const int CANNOT_WRITE_LOCAL_FILE/* = 3*/;

        static const int INVALID_COMMAND/* = 4*/;

        static const int MEM_ALLOC_ERR/* = 5*/;

        static const int FILE_ERROR/* = 6*/;

        static const int EARLIER/* = 7*/;

        static const int LATER/* = 8*/;

        static const int SAME/* = 9*/;


        CAVERNnet_remoteParallelFileIOClient32_c();

        void setRemotePort(int port = CAVERNnet_remoteParallelFileIOServer32_c::DEFAULT_PORT);

        int upload(char* ipAddress,char* localFileName, char* remoteFileName, int numberOfSockets = 5);

        int download(char* ipAddress, char* localFilename, char* remoteFileName, int numberOfSockets = 5);

        int getRemoteDateTime(char* ipAddress, char* remoteFileName,
                              int *remDay, int *remMon, int *remYear,
                              int* remHour, int* remMin, int* remSec,
                              int numberOfSockets = 1);
#if (defined(__sgi) || defined(linux) || defined(sun))

    int getRemoteFileList(char* ipAddress, char* remotePath, CAVERNmisc_fileInfo_c*& fileList, int* noObjects, int doRecursion = CAVERNmisc_fileList_c::SKIP_RECURSION, int linkTraversal = CAVERNmisc_fileList_c::DO_NOT_TRAVERSE_LINKS, int numberOfSockets = 1);
#endif 

        static int getLocalDateTime(char* filename,
                 int *day,
                 int *month,
                 int *year,
                 int *hour,
                 int *minute,
                 int *second);

        int compareDateTime(int day1, int month1, int year1,
                int hour1, int minute1, int second1,
                int day2, int month2, int year2,
                int hour2, int minute2, int second2);

    //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();


private:
        int remotePort;
        CAVERNnet_extendedParallelTcpClient_c client;
    CAVERNnet_perfMonitor_c pmonitor;   //for performance monitoring
};

/*
FORMAT:There are no spaces between fields
CLIENT -> SERVER
u fileNameLen fileName dataSize data
d fileNameLen fileName

SERVER->CLIENT
d dataSize data


What if download file not found?
need to delete thread somehow
*/
#endif

---