---

CAVERNnet_remoteFileIO32_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_remoteFileIO32_c
#define _CAVERNnet_remoteFileIO32_c

#include "CAVERN.hxx"
#include "CAVERNnet_extendedTcp_c.hxx"
#include "CAVERNmisc_fileList_c.hxx"

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

class CAVERNnet_remoteFileIOServer32_c {
public:
        static const int DEFAULT_PORT/* = 8000*/;

        static const int THREADED/* = 1*/;

        static const int NON_THREADED/* = 0*/;

        int init(int inPort=CAVERNnet_remoteFileIOServer32_c::DEFAULT_PORT, 
                     char* neighborServer = NULL, 
                         int neighborPort = CAVERNnet_remoteFileIOServer32_c::DEFAULT_PORT, 
                         int storeLocally = 1);

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

        void setRemotePort(int port=CAVERNnet_remoteFileIOServer32_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_extendedTcpServer_c server;
        char neighborServerName[MAXPATHLEN];
        int neighborPortNumber;
        int store;

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

class CAVERNnet_remoteFileIOClient32_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_remoteFileIOClient32_c();

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

        int upload(char* ipAddress,char* localFileName, char* remoteFileName);

        int download(char* ipAddress, char* localFilename, char* remoteFileName);

        int getRemoteDateTime(char* ipAddress, char* remoteFileName,
                              int *remDay, int *remMon, int *remYear,
                              int* remHour, int* remMin, int* remSec);

#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);
#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_extendedTcpClient_c client;
    CAVERNnet_perfMonitor_c pmonitor;   //for performance monitoring
};

/*

FORMAT:There are no spaces between fields

UPLOAD
------
CLIENT -> SERVER
u fileNameLen fileName dataSize data

DOWNLOAD
--------
CLIENT -> SERVER
d fileNameLen  fileName
SERVER->CLIENT
d (dataSize, timeStamp) data

CHECK REMOTE TIMESTAMP ON FILE
-----------------------------
CLIENT->SERVER
c fileNameLen fileName
SERVER->CLIENT
c (time, timestamp)

GET REMOTE FILE LIST
-------------------
CLIENT->SERVER
f pathname_size pathname recursion_flag
SERVER->CLIENT
f no_objects (dataSize+timestamp) packed_file_list
(if no_objects = -1, it means a file error)

REPLY:SERVER->CLIENT (For all commands)

File Not found:  'n'
Invalid command: 't' 

*/

#endif

---