---

multest.cpp

Go to the documentation of this file.

/* --------------------------------------------------------------
Copyright (C) 2001 LifeLine Networks BV <soap2corba@lifeline.nl>

This program is free software; you can redistribute it and/or
modify it under the terms of the GNU General Public License
as published by the Free Software Foundation; either
version 2 of the License, or (at your option) any later
version.

This program is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
GNU General Public License for more details.

You should have received a copy of the GNU General Public License
along with this program; if not, write to the Free Software
Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
-------------------------------------------------------------- */
#include <OB/CORBA.h>
#include <OB/CosNaming.h>
#include <ServerTime.h>
#include "BridgeStub.h"

CORBA::ORB_var orb;
ServerTime::Time_var tv;

class Overhead : public JTCMonitor
{
public:
    double mn, mx, sm, cn;

    Overhead ()
    {
        mn = 100000;
        mx = -100000;
        cn = sm = 0;
    };
    void Stats (double ov)
    {
        JTCSynchronized sync (*this);
        if (ov < mn) mn = ov;
        if (ov > mx) mx = ov;
        sm += ov;
        cn ++;
        printf ("%8.3lf %8.3lf/%5.0lf=%8.3lf %8.3lf\r", mn, sm, cn, sm / cn, mx);
        fflush (stdout);
    };
} *OV;

class Torture : public JTCThread
{
public:
    virtual void run ()
    {
        for (;;) {
            int w4 = 1;
            double start = -sec_u ();       
            tv->WaitThisLong (w4);
            start += sec_u ();
            OV->Stats (start - (double) w4);
        }
    }
};


int main (int argc, char *argv [])
{
    sbInitialize (argc, argv);
    OV = new Overhead;
    int ntr = (argc == 2) ? atoi (argv [1]) : 5;
    try {
        CosNaming::Name name;
        CosNaming::NamingContext_var inc;
        CosNaming::NamingContext_var myinc;
        orb = CORBA::ORB_init(argc, argv);
        try {
            CORBA::Object_var obj = orb->resolve_initial_references ("NameService");
            inc = CosNaming::NamingContext::_narrow (obj);
            assert (!CORBA::is_nil (inc));
            name.length (2);
            printf ("Resolving 'ServerTime/Time'\n");
            name [0].id = CORBA::string_dup ("ServerTime");
            name [0].kind = CORBA::string_dup ("");
            name [1].id = CORBA::string_dup ("Time");
            name [1].kind = CORBA::string_dup ("");
            try {
                obj = inc->resolve (name);
                tv = ServerTime::Time::_narrow (obj);
                int i;
                for (i = 0; i < ntr; i ++) {
                    JTCThread *t = new Torture;
                    t->start ();
                }
            }
            catch (...) {
                printf ("Failed\n");
                return 1;
            }
        }
        catch (...) {
            printf ("NameService down?\n");
            return 1;
        }
    }
    catch (...) {
        printf ("Oops!\n");
        return 1;
    }
    return 0;
}

---