---

CAVERNnet_perfDaemon_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_PERF_DAEMON_C
#define _CAVERNPLUS_PERF_DAEMON_C

#include <stdio.h>

#include "CAVERNnet_perfClient_c.hxx"

class CAVERNnet_tcpServer_c;

struct PerfDaemonClient
{
    CAVERNnet_perfDaemonClient_c *Client;
    int IsPerfClient;
    int Started;
};

class CAVERNnet_perfDaemon_c
{
public:
        CAVERNnet_perfDaemon_c(FILE* File = NULL);
        ~CAVERNnet_perfDaemon_c();


        static const int OK/* = 0*/;

        static const int FAILED/* = 1*/;

        static const int MEM_ALLOC_ERR/* = 2*/;

        static const int NEW_CONNECTION_ESTABLISHED/* = 4*/;

        static const int TOO_MANY_CLIENTS/* = 5*/;

        static const int NO_NEW_CONNECTION/* = 6*/;

        static const int NON_BLOCKING_HAS_NO_DATA/* = 7*/;

        static const int SKIP_DISTRIBUTION/* = 8*/;

        static const int DEFAULT_PORT/* = 9500*/;

        int init(int incomingPort=PERF_DAEMON_DEFAULT_PORT, int maxClients = 64);

        int process();

        int checkForNewClients();

        void intercept(int (*callback) (CAVERNnet_perfDaemonClient_c *client, char** buffer, 
                                            int *bufferSize,  void *userData), void* userData);

        void interceptNewConnection(void (*callback) (CAVERNnet_perfDaemonClient_c *newClient, void* userData), void *userData);

        int sendToAll(char* buf, int incomingSize);

private:
        PerfDaemonClient **clients;
        CAVERNnet_tcpServer_c *server;
        unsigned short incomingPort;
        FILE* LogFile;

        int (*interceptCallback) (CAVERNnet_perfDaemonClient_c *newClient, char** buffer, 
                                      int* bufsize, void *userData);
        void *interceptUserData;

        void (*interceptNewConnectionCallback) (CAVERNnet_perfDaemonClient_c *newClient, void *userData);
        void *interceptNewConnectionUserData;

        // Distribute the data to all connected performance monitoring clients.
        // Specify -1 if want to send to all.
        int distributeDataToPerfClients(char* buf, int incomingSize);

        // Remove a client from the client array.
        void removeClient(int clientNum);

        // Close all client sockets and remove them. Used by destructor.
        // Also closes down and deallocates the server.
        void closeDownSockets();
        int maxNumClients;
};

#endif

---