From f827756c0e4e7681300421942b620ca984cb177a Mon Sep 17 00:00:00 2001 From: huangming Date: Thu, 27 Nov 2003 01:36:13 +0000 Subject: *** empty log message *** --- TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/FTEC_Gateway.cpp | 2 ++ TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/Log.cpp | 9 +++++++-- TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp | 8 ++------ 3 files changed, 11 insertions(+), 8 deletions(-) diff --git a/TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/FTEC_Gateway.cpp b/TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/FTEC_Gateway.cpp index 444eb65e460..16daa60e23c 100644 --- a/TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/FTEC_Gateway.cpp +++ b/TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/FTEC_Gateway.cpp @@ -348,6 +348,8 @@ void FTEC_Gateway_ProxyPushSupplier::connect_push_consumer ( PortableServer::ObjectId** oid_ptr = get_remote_oid_ptr(impl_->orb.in() ACE_ENV_ARG_PARAMETER); ACE_CHECK; + FTRTEC_LOGTIME("FTEC_Gateway_ProxyPushSupplier::connect_push_consumer"); + *oid_ptr = impl_->ftec->connect_push_consumer(push_consumer, qos ACE_ENV_ARG_PARAMETER); ACE_CHECK; } diff --git a/TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/Log.cpp b/TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/Log.cpp index e912ac6b04e..077ca0b1120 100644 --- a/TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/Log.cpp +++ b/TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/Log.cpp @@ -33,9 +33,14 @@ namespace TAO_FTRTEC { TimeLogger::~TimeLogger() { - ACE_Time_Value result = ACE_OS::gettimeofday () - start_time_; + ACE_Time_Value stop = ACE_OS::gettimeofday (); + ACE_Time_Value result = stop - start_time_; + int time_in_usec = result.sec()*1000000+result.usec(); - int n = ACE_OS::snprintf(now, buffer-now+sizeof(buffer), "%s %d\n", msg_, time_in_usec); + int n = ACE_OS::snprintf(now, buffer-now+sizeof(buffer), + "%s %d , start = %d.%d, stop = %d.%d\n", + msg_, time_in_usec, start_time_.sec(), start_time_.usec(), + stop.sec(), stop.usec()); now+=n; } diff --git a/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp b/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp index 77f2dfd5bc6..1c9e7e1eb69 100644 --- a/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp +++ b/TAO/orbsvcs/tests/FtRtEvent/PushSupplier.cpp @@ -68,7 +68,7 @@ int PushSupplier_impl::init(CORBA::ORB_ptr orb, ACE_TRY { RtecEventComm::PushSupplier_var supplier = supplier_servant_._this(); - ACE_Time_Value time_val = ACE_OS::gettimeofday (); + FTRTEC_LOGTIME("subscription latency"); RtecEventChannelAdmin::SupplierAdmin_var supplier_admin = channel->for_suppliers(ACE_ENV_SINGLE_ARG_PARAMETER); @@ -80,11 +80,6 @@ int PushSupplier_impl::init(CORBA::ORB_ptr orb, consumer_->connect_push_supplier(supplier.in(), qos ACE_ENV_ARG_PARAMETER); ACE_TRY_CHECK; - - - time_val = ACE_OS::gettimeofday () - time_val; - - ACE_DEBUG((LM_DEBUG, "connected to proxy_push_consumer, subscription latency = %d\n", time_val.sec () * 1000000 + time_val.usec ())); } ACE_CATCHANY { @@ -93,6 +88,7 @@ int PushSupplier_impl::init(CORBA::ORB_ptr orb, } ACE_ENDTRY; ACE_CHECK; + TAO_FTRTEC::TimeLogger::output(); /* if (!reactor_task_.thr_count() && -- cgit v1.2.1