---

CAVERNdb_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 _CAVERNDB_C
#define _CAVERNDB_C

#include "CAVERN.hxx"
#include "keytool.hxx"

// Default server database directory name.
#define CAVERNDB_SERVER_DEFAULT_DB_NAME "CAVERNdbserver"
// Default client database directory name.
#define CAVERNDB_CLIENT_DEFAULT_DB_NAME "CAVERNdbclient"

class CAVERNdb_server_c
{
public:
        static const char PUT_MESG/* = 'p'*/;
        static const char FETCH_MESG/* = 'f'*/;
        static const char COMMIT_MESG/* = 'c'*/;


        static const int DEFAULT_TCP_REFLECTOR_PORT/* = 9500*/;

    static const int DEFAULT_UDP_REFLECTOR_PORT /* = 9550*/;
    
        static const int DEFAULT_MAX_CLIENTS/* = 64*/;

        static const int OK/* = 1*/;

        static const int FAILED/* = 0*/;

        static const int MEM_ALLOC_ERR/* = 3*/;

        static const int TOO_MANY_CLIENTS/* = 4*/;
    

        ~CAVERNdb_server_c();

        int init(char *defaultDBName = CAVERNDB_SERVER_DEFAULT_DB_NAME, int incomingPort = CAVERNdb_server_c::DEFAULT_TCP_REFLECTOR_PORT, int maxClients = CAVERNdb_server_c::DEFAULT_MAX_CLIENTS, int udpReflectorPort = CAVERNdb_server_c::DEFAULT_UDP_REFLECTOR_PORT);

        int process();

        // Handle any new connections. This does nothing.
        static  void newConnectionHandler(CAVERNnet_tcpReflectorClient_c *newClient, void* userData);

        // Handle incoming commands.
        static int newDataHandler(CAVERNnet_tcpReflectorClient_c * client, char** buffer, int *bufferSize, void *userData);

    // Handler for incoming commands received by the udp reflector
    static int udpDataHandler(CAVERNnet_udp_c* udpClient, char** buffer, int* bufferSize,void* userData);
    
    //Functions 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:
        CAVERNnet_tcpReflector_c * server;
    CAVERNnet_udpReflector_c*  udpreflector;
    keyToolManager_c *keyToolManager;
    
    //TCP Reflector listening port
        int incomingPort;

        // Handle PUT commands.
        void handlePut(char *buf, int size);

        // Handle FETCH commands.
        void handleFetch(CAVERNnet_tcpReflectorClient_c *client, char *buf, int size);

        // Handle COMMIT command.
        void handleCommit(CAVERNnet_tcpReflectorClient_c *client, char *buf, int size);

        // Send a put message
        void sendPutMessage(CAVERNnet_tcpReflectorClient_c *client, char* pathname, int pathsize, char* keyname, int keysize);


};

class CAVERNdb_client_c  : public CAVERNmisc_subject_c
{
public:


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

        static const int MEM_ALLOC_ERR/* = 2*/;

        static const int CONNECTION_TERMINATED/* = 3*/;

        static const int IGNORED/* = 4*/;

    static  const int UNRELIABLE_CONNECTION /* = 5*/;
    
    static  const int RELIABLE_CONNECTION /* = 6*/;
    
    static const int MAX_UDP_PACKET_SIZE /* = 1K*/;


        CAVERNdb_client_c();
        ~CAVERNdb_client_c();

        int init(char *serverIP, int serverPort= CAVERNdb_server_c::DEFAULT_TCP_REFLECTOR_PORT,  char* defaultDBName = CAVERNDB_CLIENT_DEFAULT_DB_NAME, int udp_reflector_port = CAVERNdb_server_c::DEFAULT_UDP_REFLECTOR_PORT);

        int fetch(char *pathname, char *keyname);
        void trigger(void (*callback) (char* pathname, char* keyname, void *userData), void* userData);

        int put(char* pathname, char* keyname, char* data, int datasize, int typeOfConnection = CAVERNdb_client_c::RELIABLE_CONNECTION);

        char* get(char* pathname, char* keyname, int* datasize);

        int process();

        int reconnect(char* servername = NULL, int port = 0);

        int commit(char* pathname, char* keyname);

        int remoteCommit(char* pathname, char* keyname);

        char* getNotifyPathname() {return notifyPathname;}

        char* getNotifyKeyname() {return notifyKeyname;}


    //Functions 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 *notifyPathname;
        char *notifyKeyname;

        keyToolManager_c *keyToolManager;
        CAVERNnet_tcpReflectorClient_c *client;
    CAVERNnet_udp_c* udpClient;
        void *callbackUserData;
        void (*triggerCallback) (char* pathname, char* keyname, void* userData);
        char itsServerName[256];
        int itsServerPort;
    int udpReflectorPort;
    
        CAVERNts_mutex_c *clientmutex, *callbackmutex;

        // Handle incoming messages
        void handleMessage(char* data, int dataSize);

        // Handle incoming PUT messags
        void handleIncomingPut(char* data, int datasize);
};


#endif

---