source: trunk/FACT++/dim/src/benchmark/benchClient.cxx@ 13778

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

#define TEST_TIME 10

char ServerName[128];
int MsgSize;
int Done = 0;
int NReceived;

class Service : public DimInfo
{
        void infoHandler()
        {
          if(!Done)
          {
                MsgSize = getSize();
                strcpy(ServerName, DimClient::getServerName());
                Done = 1;
          }
          NReceived++;
        }
public :
        Service(char *name) : DimInfo(name,"--") {/*nReceived = 0;*/}
};

int main(int argc, char *argv[])
{
        int i, nServices = 0;
        Service **services;
        float mps,tpm;
        DimBrowser br;
        char *name, *format, *cltptr, *srvptr, clientName[128];

        br.getServices("BENCH_SERVICE_*");

        while(br.getNextService(name, format)!= 0)
        {
                nServices++;
        }
        services = new Service*[nServices];
        i = 0;
        while(br.getNextService(name, format)!= 0)
        {
          services[i++] = new Service(name);
        }
        dic_get_id(clientName);
        if(cltptr = strchr(clientName,'@'))
                cltptr++;
        sleep(5);
        NReceived = 0;

        sleep(TEST_TIME);

        mps = NReceived/TEST_TIME;
        if(srvptr = strchr(ServerName,'@'))
                srvptr++;
        cout << "Benchmark from "<< srvptr << " to " << cltptr << " :" << endl;
        cout << "Server publishes " << nServices << " services of " << MsgSize << " bytes each"<< endl;
        cout << "Result :" << endl;
        cout << "\tMessages/s = " << mps << endl;
        tpm = 1/(float)mps*1000;
        cout << "\tTime(ms)/message = " << tpm << endl;
        cout << "\tThroughput (Kb/s) = " << mps*MsgSize/1024 << endl;
        return 1;
}