pvss_dim_server.cxx

Go to the documentation of this file.

#include <dis.hxx>
#include <iostream>
#include <stdio.h>
#include <time.h>
using namespace std;

typedef struct{
        int bitset;
        char boolval;
        int intval;
        float floatval;
        char stringval[128];
}COMPLEXDATA;

typedef struct{
        float farr[10];
        int intval;
        int iarr[3];
        char str[20];
        int intval1;
}COMPLEXDATA1;

class RecvCommand : public DimCommand
{
        int reset_flag;
        void commandHandler()
        {
                cout << "Size: " << getSize() << endl;
                cout << "Command " << getString() << " received" << endl;
                reset_flag = 1;
        }
public :
        RecvCommand(const char *name) : DimCommand(name,"C") {reset_flag = 0;};
        int isReset() {return reset_flag;};
        void clearReset() {reset_flag = 0;};
};

class RecvCommandComplex : public DimCommand
{
        void commandHandler()
        {
                COMPLEXDATA *complexData;

                complexData = (COMPLEXDATA *)getData();
                cout << "Command " << complexData->intval 
                         << " received " << complexData->stringval << endl;
        }
public :
        RecvCommandComplex(const char *name) : DimCommand(name,"I:1;C:1;I:1;F:1;C") {};
};
/*
typedef struct{
        char oper;
        char data[128];
}MEMCMND;

typedef struct{
        int code;
        float data[128];
}MEMDATA;

DimService *TestMem[1010];
MEMDATA TestMemData;

class RecvCommandMem : public DimCommand
{
        int itsIndex;
        void commandHandler()
        {
                MEMCMND *complexData;

                complexData = (MEMCMND *)getData();
                cout << "Command " << complexData->oper
                         << " received " << complexData->data[0] << endl;
                TestMemData.code = 1;
                TestMemData.data[0] = 123;
                TestMemData.data[1] = 456;
                TestMem[itsIndex]->updateService();
        }
public :
        RecvCommandMem(char *name, int index) : DimCommand(name,"C:1;C"),itsIndex(index) {};
};
*/

class RpcService : public DimRpc
{
        int val;

        void rpcHandler()
        {
                val = getInt();
                val++;
cout << "Received " << val -1 << " Answering " << val << endl;
                setData(val);
        }
public:
        RpcService(const char *name): DimRpc(name,"I","I") {val = 0;};
};

int main()
{
        COMPLEXDATA complexData;
        COMPLEXDATA1 cData;
        float simpleData;

        int index = 0;
        complexData.bitset = 0x1;
        complexData.boolval = 1;
        complexData.intval = index;
        complexData.floatval = (float)3.4;
        strcpy(complexData.stringval,"IDLE");


        cData.farr[0] = (float)1.2; 
        cData.farr[1] = (float)2.2; 
        cData.farr[2] = (float)3.2;
        cData.farr[3] = 0;
        cData.farr[4] = 0;
        cData.farr[5] = 0;
        cData.farr[6] = 0;
        cData.farr[7] = 0;
        cData.farr[8] = 0;
        cData.farr[9] = 0;
        cData.intval = 123;
        cData.iarr[0] = 12; 
        cData.iarr[1] = 13; 
        cData.iarr[2] = 14;
        cData.intval1 = 456;
        strcpy(cData.str,"hello");

        DimService cTestService("COMPLEX_SERVICE_TEST","F:10;I:1;I:3;C:20;I:1",
                (void *)&cData, sizeof(cData));

        DimService complexService("COMPLEX_SERVICE","I:1;C:1;I:1;F:1;C",
                (void *)&complexData, sizeof(complexData));

        simpleData = (float)1.23;

        DimService simpleService("SIMPLE_SERVICE", simpleData);
        simpleService.setQuality(1);

        RecvCommand recvCommand("SIMPLE_COMMAND");
        RecvCommandComplex recvCommandComplex("COMPLEX_COMMAND");
/*
        {
        char tstr[128];
        int i;
        RecvCommandMem *rmem;
//      TestMem = new DimService("TEST_MEM", "I:1;F", (void *)&TestMemData, sizeof(TestMemData)); 
//      RecvCommandMem recvCommandMem("TEST_MEM_CMND");

        for(i = 1; i <= 1000; i++)
        {
                sprintf(tstr,"TEST_MEM%04d",i);
                TestMem[i] = new DimService(tstr, "I:1;F", (void *)&TestMemData, sizeof(TestMemData)); 
                sprintf(tstr,"TEST_MEM_CMND%04d",i);
                rmem = new RecvCommandMem(tstr, i);
        }
        }
*/
        RpcService rpc("RPC");

        DimServer::start("PVSS_DIM_TEST");

        while(1)
        {
                sleep(5);
                
                if( recvCommand.isReset() )
                {
                        
                        index = 0;
                        complexData.bitset = 0x1;
                        complexData.boolval = 1;
                        complexData.intval = index;
                        complexData.floatval = (float)3.4;
                        strcpy(complexData.stringval,"IDLE");
                        simpleData = (float)1.23;
                        recvCommand.clearReset();
                }
                else
                {
                        index++;
                        complexData.bitset <<= 1;
                        complexData.boolval = index;
                        complexData.intval = index;
                        complexData.floatval = index * (float)1.1;
                        sprintf(complexData.stringval,"State %d", index);
                        simpleData += (float)1.1;
                }
                
                complexService.updateService();

//              simpleService.setQuality(complexData.bitset);
/*
                {
                        int secs;
                        time_t tsecs;

                        tsecs = time((time_t)NULL);
                        secs = (int)tsecs;
                        secs -=60;
                        simpleService.setTimestamp(secs, 123);
                        simpleService.setQuality(index);
                        tsecs = (time_t)secs;
                        cout << "quality "<< index << " time "<< ctime(&tsecs) << endl;
                }
*/
                simpleService.updateService();
//              simpleData += (float)1;
//              simpleService.updateService();
//              simpleData += (float)1;
//              simpleService.updateService();
//              simpleData += (float)1;
//              simpleService.updateService();
//              simpleData += (float)1;
//              simpleService.updateService();
//              simpleData += (float)1;
//              simpleService.updateService();
//              simpleData += (float)1;
//              simpleService.updateService();
//              simpleData += (float)1;
//              simpleService.updateService();
//              simpleData += (float)1;
//              simpleService.updateService();
//              simpleData += (float)1;
//              simpleService.updateService();

                if((int)strlen(cData.str) < 16)
                        strcat(cData.str," abc");
                cTestService.updateService();
        }
        return 0;
}