---

CAVERNnet_rpc_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_RPC_C
#define _CAVERNPLUS_RPC_C

#include "CAVERN.hxx"
class CAVERNnet_rpcHandle_c
{
public:
        char *rpcName;
        int (*callback) (char* indata, int inlen, char** outdata, int *outlen);
        CAVERNnet_rpcHandle_c();
};


class CAVERNnet_rpcManager_c
{
public:

        static const int DEFAULT_RPCS/* = 64*/;

        static const int DEFAULT_PORT/* = 9000*/;

        static const int OK/* = 1*/;

        static const int CANNOT_MANAGE_ANY_MORE/* = 4*/;

        static const int RPC_NOT_FOUND/* = 3*/;

        static const int MEM_ALLOC_ERR/* = 2*/;

        static const int FAILED/* = 0*/;

        CAVERNnet_rpcManager_c();

        int init(int maxRPCs = CAVERNnet_rpcManager_c :: DEFAULT_RPCS,
                 int inPort = CAVERNnet_rpcManager_c :: DEFAULT_PORT);

        int manage(char* procedureName, int (*callback) (char *indata, int inlen,
                                                         char **outdata, int *outlen));

        int unmanage(char* procedureName);

        void process();


    //for performance monitoring

    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 maxNumRPCs;
        CAVERNnet_rpcHandle_c *handleList;
        CAVERNnet_tcpServer_c server;

        // Reply to an RPC. Returns OK or FAILED
        int replyRPC(CAVERNnet_tcpClient_c *client, char* returnValue, int returnSize);

        // Find an RPC in the manager list
        CAVERNnet_rpcHandle_c *findRPC(char*);

        // Handle incoming RPC request. Returns OK or FAILED
        int handleRPC(CAVERNnet_tcpClient_c *client);

    //For performance monitoring
    CAVERNnet_perfMonitor_c pmonitor;
};

class CAVERNnet_rpcCaller_c
{
public:

        static const int NEVER_TIME_OUT/* = CAVERNnet_tcpClient_c::NO_TIME_OUT*/;
        static const int FAILED/* = 0*/;

        static const int OK/* = 1*/;

        static const int MEM_ALLOC_ERR/* = 2*/;

        int init(char *remoteProcedureName, char* ipAddress, int destPort=CAVERNnet_rpcManager_c::DEFAULT_PORT);

        int call(char *outdata, int outlen, char** retdata, int *retlen);

        int call1way(char *outdata, int outlen);

        void setTimeOut(int timeout = CAVERNnet_rpcCaller_c::NEVER_TIME_OUT) {itsTimeOut = timeout;}

        CAVERNnet_rpcCaller_c();

    //for performance monitoring

    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:
        char *rpcName;
        char ipAddress[256];
        int destinationPort;
        int itsTimeOut;
    //For performance monitoring
    CAVERNnet_perfMonitor_c pmonitor;
};


#endif

---