diff options
| author | huangming <huangminghuang@users.noreply.github.com> | 2003-11-27 01:36:13 +0000 |
|---|---|---|
| committer | huangming <huangminghuang@users.noreply.github.com> | 2003-11-27 01:36:13 +0000 |
| commit | f827756c0e4e7681300421942b620ca984cb177a (patch) | |
| tree | 5ec59517953da235629598769729b0f2bd6fb54c | |
| parent | 93097e4c6a56a3088584542b3b9ea31131e61ef4 (diff) | |
| download | ATCD-f827756c0e4e7681300421942b620ca984cb177a.tar.gz | |
*** empty log message ***
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/FTEC_Gateway.cpp | 2 | ||||
| -rw-r--r-- | TAO/orbsvcs/orbsvcs/FtRtEvent/Utils/Log.cpp | 9 | ||||
| -rw-r--r-- | 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() && |