source: trunk/FACT++/dim/src/examples/test_server.cxx@ 12392

//============================================================================
// Name        : emptyDimFormat.cpp
// Author      : Etienne Lyard etienne.lyard@unige.ch
// Version     : 00
// Copyright   :
// Description : Demonstrates the occurence of an empty Dim format from the client's perspective
//============================================================================
/*
#include <dic.hxx>
#include <dis.hxx>
#include <iostream>
using namespace std;

class EmptyServiceSubscriber : public DimInfo
{
    DimStampedInfo* info;
        int noLink;
public:
    EmptyServiceSubscriber()
    {
//        info = new DimStampedInfo("TIME/EMPTY", const_cast<char*>(""), this);
                noLink = -1;
        info = new DimStampedInfo("TIME/EMPTY", noLink, this);
    }
    void infoHandler()
    {
        DimInfo* I = getInfo();
                int data;
        if (I == info)
                {
                        data = I->getInt();
//              cout << "EMPTY SERVICE UPDATED. " << "Format: " << I->getFormat() << endl;
                        cout << "EMPTY SERVICE UPDATED. " << data << " Format: " << I->getFormat() << endl;
                }
    }
};

int main(int, const char**)
{
    DimServer::start("TIME");

    int emptyFormatVariable = 0;
    DimService* emptyFormatService = new DimService("TIME/EMPTY", "I:1", &emptyFormatVariable, sizeof(long));
    EmptyServiceSubscriber mySubscriber;
    //The three lines below create (most of the time) an empty format on the client side.
    //We must be able to deal with such cases in our framework because services can be stopped and re-spawned at any time
    delete emptyFormatService;
    usleep(1000000);
    emptyFormatService = new DimService("TIME/EMPTY", "I:1", &emptyFormatVariable, sizeof(long));

    while (1)
    {
        emptyFormatService->updateService();
        usleep(1000000);
    }

        return 0;
}
*/

#include <iostream>
#include <dis.hxx>
#ifndef WIN32
#include <unistd.h>
#endif
using namespace std;
#include <string>

class ErrorHandler : public DimErrorHandler
{
        void errorHandler(int severity, int code, char *msg)
        {
                int index = 0;
                char **services;
                if(code){}
                cout << severity << " " << msg << endl;
                services = DimServer::getClientServices();
                cout<< "from "<< DimServer::getClientName() << " services:" << endl;
                while(services[index])
                {
                        cout << services[index] << endl;
                        index++;
                }
        }
public:
        ErrorHandler() {DimServer::addErrorHandler(this);}
};

class ExitHandler : public DimExitHandler
{
        void exitHandler(int code)
        {
                cout << "exit code " << code << endl;
        }
public:
        ExitHandler() {DimServer::addExitHandler(this);}
};

class CmndServ : public DimCommand, public DimTimer
{
        DimService servstr;
        void commandHandler()
        {
                int index = 0;
                char **services;
                cout << "Command " << getString() << " received" << endl;
                servstr.updateService(getString()); 
                services = DimServer::getClientServices();
                cout<< "from "<< DimServer::getClientName() << " services:" << endl;
                while(services[index])
                {
                        cout << services[index] << endl;
                        index++;
                }
        }

public :
        CmndServ() : DimCommand("TEST/CMND","C"), 
                                 servstr("TEST/STRVAL","empty") {};
/*
        void handleIt()
        {
                int index = 0;
                char **services;
                dim_print_date_time();
                cout << "Command " << getString() << " received" << endl;
                cout << "time: "<<getTimestamp()<<" millies: "<<getTimestampMillisecs()<<endl;
                servstr.updateService(getString()); 
        }
*/
};

/*
class CmndServMany : public DimCommand
{
        void commandHandler()
        {
                cout << "Command " << getString() << " received" << endl;
        }
public :
        CmndServMany(char *name) : DimCommand(name,"C") {};
};
*/

void add_serv(const int & ival)
{
        DimService *abc;

        abc = new DimService("TEST/INTVAL_CONST",(int &)ival);
}

void add_serv_str(const string & s1)
{
        DimService *abc;

        abc = new DimService("TEST/STRINGVAL_CONST",(char *)s1.c_str());
}

void add_serv_bool(const bool & boolval)
{
        DimService *serv;

//      serv = new DimService("TEST/BOOLVAL_CONST",(short &)boolval);
        serv = new DimService("TEST/BOOLVAL_CONST","C:1", (void *)&boolval, 1);
}

class ServWithHandler : public DimService
{
        int value;

        void serviceHandler()
        {
                value++;
//              setData(value);
        }
public :
        ServWithHandler(char *name) : DimService(name, value) { value = 0;};
};

int main()
{
        int ival = 0;
//      ErrorHandler errHandler;
//      ExitHandler exHandler;
//      DimServer::setDnsNode("axdes2.cern.ch");
        string s1;
        bool boolval;
        ServWithHandler *testServ;
        DimServerDns *newDns;
        char *extraDns = 0;
        DimService *new_servint;

        DimServer::start("TEST");
        extraDns = DimUtil::getEnvVar("EXTRA_DNS_NODE");
        if(extraDns)
                newDns = new DimServerDns(extraDns, 0, "new_TEST");

/*
        int i, arr[15000];
        DimService *servp;
        DimCommand *cmndp;
        char str[132];
*/
//      float farr[4];
//      DimService *farrp;

        s1 = "hello";
        add_serv(ival);
        DimService servint("TEST/INTVAL",ival);

        if(extraDns)
        {
                new_servint = new DimService(newDns, "new_TEST/INTVAL",ival);
        }

        add_serv_str(s1);
        boolval = 0;
        add_serv_bool(boolval);
        CmndServ cmdsvr;

        testServ = new ServWithHandler("MY_NEW_TEST_SERVICE_WITH_HANDLER");

//      farr[0] = 1.2;
//      farr[1] = 2.3;
//      farrp = new DimService("/PCITCO147/sensors/fan/input","F", farr, sizeof(farr));


/*
//      DimServer::autoStartOff();
        DimServer::start("TEST");

        for(i = 0; i < 15000; i++)
        {
                arr[i] = i;
                sprintf(str,"ServiceManyTest/%05d",i);
                servp = new DimService(str,arr[i]);
                servp->setQuality(1);
                servp->updateService(arr[i]);
//      DimServer::start("TEST");
                sprintf(str,"CommandManyTest/%05d",i);
                cmndp = new CmndServMany(str);
//      DimServer::start("TEST");
        }
*/
        while(1)
        {
                sleep(5);

/*
                while(cmdsvr.hasNext())
                {
                        cmdsvr.getNext();
                        cmdsvr.handleIt();
                }
*/
                s1 = "hello1";
                if(!boolval)
                        boolval = 1;
                else
                        boolval = 0;
                ival++;
                
                int inCallback = DimServer::inCallback();
                cout << "main: In callback "<< inCallback << endl; 
                servint.updateService();
                if(extraDns)
                        new_servint->updateService();
        }
        return 0;
}