source: trunk/FACT++/dim/src/examples/test_Browser.cxx@ 13913

#include <iostream>
#include <dic.hxx>
using namespace std;

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

class StrService : public DimInfo
{

        void infoHandler()
        {
                int index = 0;
                char **services;
//              cout << "Dns Node = " << DimClient::getDnsNode() << endl;
                cout << "Received STRVAL : " << getString() << endl;
                services = DimClient::getServerServices();
                cout<< "from "<< DimClient::getServerName() << " services:" << endl;
                while(services[index])
                {
                        cout << services[index] << endl;
                        index++;
                }
        }
public :
        StrService() : DimInfo("TEST/STRVAL","not available") {};
};


void **AllServices;
int *AllServiceStates;
int NServices;
int NBytes;

class MyTimer: public DimTimer
{
  void timerHandler()
    {
      int i;
      int missing = 0;
      for(i = 0; i < NServices; i++)
      {
        if(AllServiceStates[i] == -2)
          {
            missing++;
          }
      }
      dim_print_date_time();
      printf("Missing %d, NBytes = %d\n", missing, NBytes);
      if(missing)
        start(1);
    }
 public:
  MyTimer(): DimTimer(2){};
};

class TestGetService: public DimInfo
{
  void infoHandler()
  {
    int i, index, size, done = 1;
    char *dataptr;
    
    size = getSize();
    NBytes += size;
    dataptr = new char[size];
    memcpy(dataptr, getData(), size);
    for(i = 0; i < NServices; i++)
      {
        if(AllServices[i] == this)
          {
            index = i;
            break;
          }
      }
    AllServiceStates[index] = getInt();
    //    printf("Got %s, %d, %d\n", getName(), index, AllServiceStates[index]);
    for(i = 0; i < NServices; i++)
      {
        if(AllServiceStates[i] == -2)
          {
            done = 0;
            break;
          }
      }
    if(done)
      {
        dim_print_date_time();
        printf("All Services Received\n");
      }
  }
public :
  TestGetService(char *name): DimInfo(name, -1){};
};


int main(int argc, char **argv)
{
                
        ErrorHandler errHandler;
//      StrService servstr;
        char *server, *ptr, *ptr1;
        DimBrowser br;
        int type, n, index, i, ret;
        MyTimer *myTimer;
        char findStr[132];

        ret = 0;
        strcpy(findStr,"*");
        if(argc > 1)
        {
                if(!strcmp(argv[1],"-f"))
                {
                  if(argc > 2)
                    strcpy(findStr,argv[2]);
                  else 
                    ret = 1;
                }
                else
                  ret = 1;
                if(ret)
                {
                        printf("Parameters: [-f <search string>]\n");
                        exit(0);
                }
        }
//      DimClient::addErrorHandler(errHandler);
dim_print_date_time();
printf("Asking %s\n", findStr);
        n = br.getServices(findStr);
dim_print_date_time();
        cout << "found " << n << " services" << endl; 
        
        AllServices = (void **) new TestGetService*[n];
        AllServiceStates = new int[n];
        NServices = n;
        NBytes = 0;
        index = 0;
        for(i = 0; i < n; i++)
          AllServiceStates[i] = 0;
        while((type = br.getNextService(ptr, ptr1))!= 0)
        {
          
          //            cout << "type = " << type << " - " << ptr << " " << ptr1 << endl;
          AllServiceStates[index] = -2;
          AllServices[index] = new TestGetService(ptr);
          index++;
          //      if(index >= 1000)
          //        break;
        }
        myTimer = new MyTimer();
        dim_print_date_time();
        printf("Got Service Names\n");
        /*
        br.getServers();
        while(br.getNextServer(server, ptr1))
        {
                cout << server << " @ " << ptr1 << endl;
        }

        br.getServerClients("DIS_DNS");
        while(br.getNextServerClient(ptr, ptr1))
        {
                cout << ptr << " @ " << ptr1 << endl;
        }
        DimInfo servint("TEST/INTVAL",-1); 
        */
        while(1)
        {
                sleep(10);
                /*
                cout << "Current INTVAL : " << servint.getInt() << endl;
                DimClient::sendCommand("TEST/CMND","UPDATE_STRVAL");
                */
        }
        return 0;
}