---

multest2.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"
#include "SoapBridge.h"
#include "SoapBridge_skel.h"

CORBA::ORB_var orb;
ServerTime::Time_var tv;
bool running = true;

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:
    int wt;

    virtual void run ()
    {
        JTCThread::sleep (500 + wt);
        while (running) {
            int w4 = 1;
            double start = -sec_u ();       
            try {
                tv->WaitThisLong (w4);
            }
            catch (...) {
                printf ("\n\n**** test failed ****\n\n");
                return;
            }
            start += sec_u ();
            OV->Stats (start - (double) w4);
        }
    }
};

class CORBACallback_impl : virtual public POA_SOAPBridge::CORBACallback
{
public:
    CORBACallback_impl ()
    {
    };
    ~CORBACallback_impl ()
    {
    };
    void tellMe (const char *sa, const char *ifn, const char *mtn, const char *ctx, const char *err)
        throw (CORBA::SystemException)
    {
        running = false;
        printf ("\n\nInvocation failure!\n");
        printf ("\tSOAP address was: %s\n", sa);
        printf ("\tInterface name  : %s\n", ifn);
        printf ("\tInterface method: %s\n", mtn);
        printf ("\tContext key     : %s\n", ctx);
        printf ("\tFailure reason  : %s\n", err);
    };
};

int main (int argc, char *argv [])
{
    JTCInitialize initialize;
    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 poaObj = orb->resolve_initial_references ("RootPOA");
            PortableServer::POA_var poa = PortableServer::POA::_narrow (poaObj);
            PortableServer::POAManager_var mgr = poa->the_POAManager ();
            mgr->activate ();
            CORBA::Object_var obj = orb->resolve_initial_references ("NameService");
            inc = CosNaming::NamingContext::_narrow (obj);
            assert (!CORBA::is_nil (inc));
            name.length (2);
            printf ("Resolving 'SOAPBridge/CORBACall'\n");
            name [0].id = CORBA::string_dup ("SOAPBridge");
            name [0].kind = CORBA::string_dup ("");
            name [1].id = CORBA::string_dup ("CORBACall");
            name [1].kind = CORBA::string_dup ("");
            try {
                CORBA::Object_var ccObj =  inc->resolve (name);
                SOAPBridge::CORBACall_var cc = SOAPBridge::CORBACall::_narrow (ccObj);
                CORBACallback_impl cb;
                obj = cc->CreateSession ("http://soap2corba/cgi-bin/SBCGI.xml", "ServerTime/Time", 1,
                    cb._this ());
                {
                    CORBA::String_var whatCtx = cc->contextKey ();
                    printf ("We've been assigned context: %s\n", (char *) whatCtx);
                }
                tv = ServerTime::Time::_narrow (obj);
                // do a test call
                tv->WaitThisLong (1);
                int i;
                for (i = 0; running && i < ntr; i ++) {
                    JTCHandleT<Torture> t = new Torture;
                    t->wt = i * 20;
                    t->start ();
                }
            }
            catch (...) {
                printf ("Failed\n");
                return 1;
            }
            printf ("Test initialization done.\n");
            orb->run ();
        }
        catch (...) {
            printf ("NameService down?\n");
            return 1;
        }
    }
    catch (...) {
        printf ("Oops!\n");
        return 1;
    }
    return 0;
}

---